You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ch...@apache.org on 2021/02/17 04:20:19 UTC
[kafka] branch trunk updated: MINOR: Fix typo (thread -> threads)
in MirrorMaker (#10130)
This is an automated email from the ASF dual-hosted git repository.
chia7712 pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 0bdb469 MINOR: Fix typo (thread -> threads) in MirrorMaker (#10130)
0bdb469 is described below
commit 0bdb469b56c63aa4dfae1ab24bb1868471cfa7bf
Author: runom <je...@gmail.com>
AuthorDate: Wed Feb 17 13:19:20 2021 +0900
MINOR: Fix typo (thread -> threads) in MirrorMaker (#10130)
Reviewers: Chia-Ping Tsai <ch...@gmail.com>
---
core/src/main/scala/kafka/tools/MirrorMaker.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/core/src/main/scala/kafka/tools/MirrorMaker.scala b/core/src/main/scala/kafka/tools/MirrorMaker.scala
index c1146f2..70b70a8 100755
--- a/core/src/main/scala/kafka/tools/MirrorMaker.scala
+++ b/core/src/main/scala/kafka/tools/MirrorMaker.scala
@@ -44,7 +44,7 @@ import scala.util.{Failure, Success, Try}
/**
* The mirror maker has the following architecture:
- * - There are N mirror maker thread, each of which is equipped with a separate KafkaConsumer instance.
+ * - There are N mirror maker threads, each of which is equipped with a separate KafkaConsumer instance.
* - All the mirror maker threads share one producer.
* - Each mirror maker thread periodically flushes the producer and then commits all offsets.
*