Kafka命令
  9JCEeX0Eg8g4 2023年11月13日 32 0

以下是一些常用的Kafka命令及其用途:

  1. 启动Kafka服务:
bin/kafka-server-start.sh config/server.properties
  1. 创建一个主题(topic):
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic myTopic
  1. 列出所有主题:
bin/kafka-topics.sh --list --zookeeper localhost:2181
  1. 查看特定主题的详细信息:
bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic myTopic
  1. 发送消息到指定主题:
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic myTopic
  1. 从指定主题消费消息:
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic myTopic --from-beginning
  1. 查看消费者组的偏移量:
bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --group myGroup --describe
  1. 在消费者组中重置偏移量:
bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --group myGroup --reset-offsets --to-earliest --execute --topic myTopic

这只是一些基本的Kafka命令示例,Kafka还有许多其他功能和命令可以根据需要使用。你可以参考Kafka官方文档来了解更多详细信息和更高级的用法。

【版权声明】本文内容来自摩杜云社区用户原创、第三方投稿、转载,内容版权归原作者所有。本网站的目的在于传递更多信息,不拥有版权,亦不承担相应法律责任。如果您发现本社区中有涉嫌抄袭的内容,欢迎发送邮件进行举报,并提供相关证据,一经查实,本社区将立刻删除涉嫌侵权内容,举报邮箱: cloudbbs@moduyun.com

  1. 分享:
最后一次编辑于 2023年11月13日 0

暂无评论