From 8762f97c9c1da8e4e1f7f916351709c9b487ce1e Mon Sep 17 00:00:00 2001 From: amrutprabhu Date: Wed, 8 Dec 2021 18:50:53 +0100 Subject: [PATCH] Updating gitignore --- .../amrut/prabhu/kafkacommunicationservice/KafkaConsumer.java | 4 ++-- .../src/main/resources/application.yml | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/spring-kafka-communication-service/src/main/java/com/amrut/prabhu/kafkacommunicationservice/KafkaConsumer.java b/spring-kafka-communication-service/src/main/java/com/amrut/prabhu/kafkacommunicationservice/KafkaConsumer.java index aed40e1..3d8436a 100755 --- a/spring-kafka-communication-service/src/main/java/com/amrut/prabhu/kafkacommunicationservice/KafkaConsumer.java +++ b/spring-kafka-communication-service/src/main/java/com/amrut/prabhu/kafkacommunicationservice/KafkaConsumer.java @@ -3,9 +3,9 @@ package com.amrut.prabhu.kafkacommunicationservice; import com.amrut.prabhu.kafkacommunicationservice.dto.Message; import org.apache.kafka.clients.consumer.ConsumerRecord; import org.springframework.kafka.annotation.KafkaListener; -import org.springframework.stereotype.Service; +import org.springframework.stereotype.Component; -@Service +@Component public class KafkaConsumer { @KafkaListener(id = "my-client-application", topics = "${topic.name}") diff --git a/spring-kafka-communication-service/src/main/resources/application.yml b/spring-kafka-communication-service/src/main/resources/application.yml index d13496b..04028c8 100755 --- a/spring-kafka-communication-service/src/main/resources/application.yml +++ b/spring-kafka-communication-service/src/main/resources/application.yml @@ -13,6 +13,6 @@ spring: value-serializer: com.amrut.prabhu.kafkacommunicationservice.dto.converters.MessageSerializer topic: - name: "first-topic" + name: "transaction.000" server: port: 9191 \ No newline at end of file