You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by cm...@apache.org on 2022/10/24 23:11:01 UTC
[kafka] branch 3.3 updated: MINOR: Update the README file in examples. (#12272)
This is an automated email from the ASF dual-hosted git repository.
cmccabe pushed a commit to branch 3.3
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/3.3 by this push:
new 4c63f7e2e14 MINOR: Update the README file in examples. (#12272)
4c63f7e2e14 is described below
commit 4c63f7e2e14545464bfcec490cc8af974d0f05d6
Author: liuzhuang2017 <95...@users.noreply.github.com>
AuthorDate: Tue Oct 18 13:03:52 2022 +0800
MINOR: Update the README file in examples. (#12272)
Modify Intellij to IntelliJ IDEA, and mention KRaft in example docs.
Reviewers: Divij Vaidya <di...@gmail.com>, Kvicii <kv...@gmail.com>, dengziming <de...@gmail.com>
---
examples/README | 4 ++--
examples/src/main/java/kafka/examples/KafkaExactlyOnceDemo.java | 2 +-
2 files changed, 3 insertions(+), 3 deletions(-)
diff --git a/examples/README b/examples/README
index 388001185c6..dc5b3947cd1 100644
--- a/examples/README
+++ b/examples/README
@@ -2,11 +2,11 @@ This directory contains examples of client code that uses kafka.
To run the demo:
- 1. Start Zookeeper and the Kafka server
+ 1. In Zookeeper mode, Start Zookeeper and the Kafka server. In KRaft mode, start the Kafka server.
2. For unlimited sync-producer-consumer run, `run bin/java-producer-consumer-demo.sh sync`
3. For unlimited async-producer-consumer run, `run bin/java-producer-consumer-demo.sh`
4. For exactly once demo run, `run bin/exactly-once-demo.sh 6 3 50000`,
this means we are starting 3 EOS instances with 6 topic partitions and 50000 pre-populated records.
5. Some notes for exactly once demo:
5.1. The Kafka server has to be on broker version 2.5 or higher.
- 5.2. You could also use Intellij to run the example directly by configuring parameters as "Program arguments"
+ 5.2. You could also use IntelliJ IDEA to run the example directly by configuring parameters as "Program arguments"
diff --git a/examples/src/main/java/kafka/examples/KafkaExactlyOnceDemo.java b/examples/src/main/java/kafka/examples/KafkaExactlyOnceDemo.java
index 50a1ad14bc4..8fbab1e6226 100644
--- a/examples/src/main/java/kafka/examples/KafkaExactlyOnceDemo.java
+++ b/examples/src/main/java/kafka/examples/KafkaExactlyOnceDemo.java
@@ -39,7 +39,7 @@ import java.util.concurrent.TimeUnit;
* - records: number of records
* An example argument list would be `6 3 50000`.
*
- * If you are using Intellij, the above arguments should be put in the configuration's `Program Arguments`.
+ * If you are using IntelliJ IDEA, the above arguments should be put in the configuration's `Program Arguments`.
* Also recommended to set an output log file by `Edit Configuration -> Logs -> Save console
* output to file` to record all the log output together.
*