We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
2 parents f846334 + 10ca9cb commit 84f5d7fCopy full SHA for 84f5d7f
kafka-java-console-sample/src/main/java/com/eventstreams/samples/ProducerRunnable.java
@@ -70,7 +70,7 @@ public void run() {
70
try {
71
while (!closing) {
72
String key = "key";
73
- String message = "{\"message\":\"This is a test message #\",\"message number\":" + producedMessages + "}";
+ String message = "{\"message\":\"This is a test message #\",\"message_number\":" + producedMessages + "}";
74
75
76
// If a partition is not specified, the client will use the default partitioner to choose one.
0 commit comments