操作命令 (66) 查找 相同
> bin/kafka-topics.sh --bootstrap-server broker_host:port --create --topic my_topic_name --partitions 20 --replication-factor 3 --config x=y > bin/kafka-topics.sh --bootstrap-server broker_host:port --alter --topic my_topic_name --partitions 40 > bin/kafka-topics.sh --bootstrap-server br

> bin/kafka-configs.sh --bootstrap-server broker_host:port --entity-type topics --entity-name my_topic_name --alter --add-config x=y > bin/kafka-configs.sh --bootstrap-server broker_host:port --entity-type topics --entity-name my_topic_name --alter --delete-config x > bin/kafka-configs.s

Balancing leadership   > bin/kafka-preferred-replica-election.sh --bootstrap-server broker_host:port

检查消费者位置 Checking consumer position   > bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group my-group 管理消费者组 Managing Consumer Groups   > bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --list > bin/kafka-consumer-grou

自动迁移数据到新机器  Automatically migrating data to new machines   > bin/kafka-reassign-partitions.sh --bootstrap-server localhost:9092 --topics-to-move-json-file topics-to-move.json --broker-list "5,6" --generate > bin/kafka-reassign-partitions.sh --bootstrap-server local

Securing Clusters and Topics: Authentication, Authorization, Encryption bin/kafka-acls.sh     --bootstrap-server broker1:9092     --add --allow-principal User:Alice     --producer     --resource-pattern-type prefixed --topic acme.infosec.

从远程消费到本地 Best Practice: Consume from Remote, Produce to Local > bin/connect-mirror-maker.sh connect-mirror-maker.properties --clusters secondary Example: Multi-Cluster Geo-Replication > bin/connect-mirror-maker.sh connect-mirror-maker.properties --clusters west-1 west-2 > bin/conne