Kafka 提供了一些系统工具,用于管理和监控 Kafka 集群、主题等。以下是一些常见的 Kafka 系统工具:
-
kafka-topics.sh: 用于创建、列出和删除主题以及查看主题的详细信息。
kafka-topics.sh --create --topic my_topic --partitions 3 --replication-factor 3 --bootstrap-server localhost:9092 kafka-topics.sh --list --bootstrap-server localhost:9092 kafka-topics.sh --describe --topic my_topic --bootstrap-server localhost:9092
-
kafka-console-producer.sh 和 kafka-console-consumer.sh: 用于在命令行中创建生产者和消费者,进行消息的生产和消费。
kafka-console-producer.sh --bootstrap-server localhost:9092 --topic my_topic kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic my_topic
-
kafka-configs.sh: 用于修改和查看主题和分区的配置信息。
kafka-configs.sh --zookeeper localhost:2181 --entity-type topics --entity-name my_topic --describe
-
kafka-acls.sh: 用于管理 Kafka 的访问控制列表(ACL),控制用户对 Kafka 资源的访问权限。
kafka-acls.sh --authorizer-properties zookeeper.connect=localhost:2181 --add --allow-principal User:Bob --operation Read --topic my_topic
-
kafka-consumer-groups.sh: 用于查看和管理消费者组的状态和偏移量。
kafka-consumer-groups.sh --bootstrap-server localhost:9092 --list kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group my_group
-
kafka-dump-log.sh: 用于以可读的方式转储 Kafka 分区的消息日志。
kafka-dump-log.sh --files /tmp/kafka-logs/my_topic-0/00000000000000000000.log
-
kafka-preferred-replica-election.sh: 用于执行首选副本选举,重新分配每个分区的首选副本。
kafka-preferred-replica-election.sh --zookeeper localhost:2181
-
kafka-reassign-partitions.sh: 用于重新分配分区的 Leader 和副本。
kafka-reassign-partitions.sh --zookeeper localhost:2181 --reassignment-json-file reassignment.json --execute
这些系统工具提供了一组命令行界面工具,方便管理员和开发者对 Kafka 集群进行管理、监控和配置。注意,具体的命令和参数可能会根据 Kafka 的版本而有所不同,建议查阅相应版本的官方文档获取准确的命令和用法。
Was this helpful?
0 / 0