code review

DiSSCo · Aug 23, 2024 · b4e12d6 · b4e12d6
1 parent 01b64fe
commit b4e12d6
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/java/eu/dissco/core/datacitepublisher/kafka/KafkaConsumerService.java b/src/main/java/eu/dissco/core/datacitepublisher/kafka/KafkaConsumerService.java
@@ -64,7 +64,7 @@ public void getMediaMessages(@Payload String message) throws DataCiteApiExceptio
   @RetryableTopic(
       attempts = "1",
       dltStrategy = DltStrategy.FAIL_ON_ERROR)
-  @KafkaListener(topics = "tombstone", groupId = "${spring.kafka.consumer.group-id}")
+  @KafkaListener(topics = "${kafka.consumer.topic.tombstone}", groupId = "${spring.kafka.consumer.group-id}")
   public void tombstoneDois(@Payload String message) throws DataCiteApiException, InvalidRequestException {
     try {
       var event = mapper.readValue(message, TombstoneEvent.class);