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.
1 parent f846334 commit 10ca9cbCopy full SHA for 10ca9cb
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