以下是一些常用的Kafka命令及其用途:
- 启动Kafka服务:
bin/kafka-server-start.sh config/server.properties
- 创建一个主题(topic):
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic myTopic
- 列出所有主题:
bin/kafka-topics.sh --list --zookeeper localhost:2181
- 查看特定主题的详细信息:
bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic myTopic
- 发送消息到指定主题:
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic myTopic
- 从指定主题消费消息:
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic myTopic --from-beginning
- 查看消费者组的偏移量:
bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --group myGroup --describe
- 在消费者组中重置偏移量:
bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --group myGroup --reset-offsets --to-earliest --execute --topic myTopic
这只是一些基本的Kafka命令示例,Kafka还有许多其他功能和命令可以根据需要使用。你可以参考Kafka官方文档来了解更多详细信息和更高级的用法。
标签:bin,--,kafka,topic,命令,sh,Kafka,localhost From: https://blog.51cto.com/u_16161880/7246074