mindol1004/spring-cloud-stream-kafka-communication
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Updating gitignore

Browse Source
This commit is contained in:
amrutprabhu
2021-12-08 18:50:53 +01:00
parent a295d83693
commit 8762f97c9c
2 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
spring-kafka-communication-service/src/main/java/com/amrut/prabhu/kafkacommunicationservice/KafkaConsumer.java
View File

@@ -3,9 +3,9 @@ package com.amrut.prabhu.kafkacommunicationservice;
import com.amrut.prabhu.kafkacommunicationservice.dto.Message; import com.amrut.prabhu.kafkacommunicationservice.dto.Message;
import org.apache.kafka.clients.consumer.ConsumerRecord; import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.springframework.kafka.annotation.KafkaListener; import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Component;
@Service @Component
public class KafkaConsumer { public class KafkaConsumer {
@KafkaListener(id = "my-client-application", topics = "${topic.name}") @KafkaListener(id = "my-client-application", topics = "${topic.name}")

2
spring-kafka-communication-service/src/main/resources/application.yml
View File

@@ -13,6 +13,6 @@ spring:
value-serializer: com.amrut.prabhu.kafkacommunicationservice.dto.converters.MessageSerializer value-serializer: com.amrut.prabhu.kafkacommunicationservice.dto.converters.MessageSerializer
topic: topic:
name: "first-topic" name: "transaction.000"
server: server:
port: 9191 port: 9191