File tree Expand file tree Collapse file tree 2 files changed +2
-2
lines changed
polling-publisher/polling-service/src/main/java/com/iluwatar/polling Expand file tree Collapse file tree 2 files changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -48,7 +48,7 @@ public String healthCheck() {
48
48
49
49
@ PostMapping ("/send" )
50
50
public String sendMessage (@ RequestParam ("message" ) String message ) {
51
- kafkaProducer .sendMessage ("api-message " , message );
51
+ kafkaProducer .sendMessage ("API " , message );
52
52
return "Message sent: " + message ;
53
53
}
54
54
}
Original file line number Diff line number Diff line change @@ -52,7 +52,7 @@ public void pollDataSource() {
52
52
53
53
if (data != null ) {
54
54
System .out .println ("🟢 Publishing Data: " + data );
55
- kafkaProducer .sendMessage ("update " , data );
55
+ kafkaProducer .sendMessage ("updates " , data );
56
56
} else {
57
57
System .out .println ("🔴 No Data Found for ID: " + id );
58
58
}
You can’t perform that action at this time.
0 commit comments