diff --git a/post-processing-service/src/main/java/gov/cdc/etldatapipeline/postprocessingservice/service/PostProcessingService.java b/post-processing-service/src/main/java/gov/cdc/etldatapipeline/postprocessingservice/service/PostProcessingService.java index 72016941..98a903ad 100644 --- a/post-processing-service/src/main/java/gov/cdc/etldatapipeline/postprocessingservice/service/PostProcessingService.java +++ b/post-processing-service/src/main/java/gov/cdc/etldatapipeline/postprocessingservice/service/PostProcessingService.java @@ -119,7 +119,8 @@ enum Entity { "${spring.kafka.topic.case_management}", "${spring.kafka.topic.interview}", "${spring.kafka.topic.ldf_data}", - "${spring.kafka.topic.observation}" + "${spring.kafka.topic.observation}", + "${spring.kafka.topic.place}" }) public void postProcessMessage( @Header(KafkaHeaders.RECEIVED_TOPIC) String topic, diff --git a/post-processing-service/src/main/resources/application.yaml b/post-processing-service/src/main/resources/application.yaml index b57491f2..e816798f 100644 --- a/post-processing-service/src/main/resources/application.yaml +++ b/post-processing-service/src/main/resources/application.yaml @@ -10,8 +10,8 @@ spring: case_management: nrt_investigation_case_management interview: nrt_interview ldf_data: nrt_ldf_data - datamart: nbs_Datamart place: nrt_place + datamart: nbs_Datamart dlq: retry-suffix: -retry dlq-suffix: -dlt