Kafka提供了一个命令行工具,用于管理和与Kafka集群交互。这个命令行工具通常称为Kafka Shell,它允许您执行各种操作,如创建主题、发送和消费消息、查看主题列表等。
以下是一些常用的Kafka Shell命令:
-
创建主题(Topic):
kafka-topics.sh --create --topic my-topic --partitions 3 --replication-factor 2 --zookeeper localhost:2181
-
列出所有主题:
kafka-topics.sh --list --zookeeper localhost:2181
-
查看特定主题的详细信息:文章来源:https://www.toymoban.com/news/detail-726150.html
kafka-topics.sh --describe --topic my-topic --zookeeper localhost:2181
-
发送消息到主题:文章来源地址https://www.toymoban.com/news/detail-726150.html
kafka-console-producer.sh --broker-list localhost:9092 --topic my-topic
-
--broker-list
:指定Kafka broker的地址列表,格式为host:port
。例如,--broker-list localhost:9092
。 -
--topic
:指定要将消息发送到的主题名称。例如,
到了这里,关于Kafka Shell命令交互的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!