We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 1b3d933 commit a59362cCopy full SHA for a59362c
polling-publisher/polling-service/src/main/java/com/iluwatar/polling/PollingController.java
@@ -48,7 +48,7 @@ public String healthCheck() {
48
49
@PostMapping("/send")
50
public String sendMessage(@RequestParam("message") String message) {
51
- kafkaProducer.sendMessage("api-message", message);
+ kafkaProducer.sendMessage("API", message);
52
return "Message sent: " + message;
53
}
54
polling-publisher/polling-service/src/main/java/com/iluwatar/polling/PollingScheduler.java
@@ -52,7 +52,7 @@ public void pollDataSource() {
if (data != null) {
System.out.println("🟢 Publishing Data: " + data);
55
- kafkaProducer.sendMessage("update", data);
+ kafkaProducer.sendMessage("updates", data);
56
} else {
57
System.out.println("🔴 No Data Found for ID: " + id);
58
0 commit comments