We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent a59362c commit 5aa46acCopy full SHA for 5aa46ac
polling-publisher/subscriber-service/src/main/java/com/iluwatar/subscriber/KafkaConsumer.java
@@ -34,7 +34,12 @@
34
public class KafkaConsumer {
35
36
@KafkaListener(topics = "updates", groupId = "subscriber-group")
37
- public void listen(String message) {
38
- System.out.println("Received message: " + message);
+ public void listenUpdates(String message) {
+ System.out.println("[updates]: Received message: " + message);
39
+ }
40
+
41
+ @KafkaListener(topics = "API", groupId = "subscriber-group")
42
+ public void listenApi(String message) {
43
+ System.out.println("[API]: Received message from /send : " + message);
44
}
45
0 commit comments