File tree Expand file tree Collapse file tree 1 file changed +6
-2
lines changed
polling-publisher/subscriber-service/src/main/java/com/iluwatar/subscriber Expand file tree Collapse file tree 1 file changed +6
-2
lines changed Original file line number Diff line number Diff line change 2525
2626package com .iluwatar .subscriber ;
2727
28+ import org .slf4j .Logger ;
29+ import org .slf4j .LoggerFactory ;
2830import org .springframework .kafka .annotation .KafkaListener ;
2931import org .springframework .stereotype .Service ;
3032
3133/** Kafka consumer service to consume messages / updates. */
3234@ Service
3335public class KafkaConsumer {
3436
37+ private static final Logger log = LoggerFactory .getLogger (KafkaConsumer .class );
38+
3539 @ KafkaListener (topics = "updates" , groupId = "subscriber-group" )
3640 public void listenUpdates (String message ) {
37- System . out . println ("[updates]: Received message: " + message );
41+ log . info ("[updates]: Received message: {}" , message );
3842 }
3943
4044 @ KafkaListener (topics = "API" , groupId = "subscriber-group" )
4145 public void listenApi (String message ) {
42- System . out . println ("[API]: Received message from /send : " + message );
46+ log . info ("[API]: Received message from /send : {}" , message );
4347 }
4448}
You can’t perform that action at this time.
0 commit comments