2.kafka的Topic操作指令

分类栏目：Kafka

版权信息：站内文章为学习与参考提供良好的资源。如果您发现了您的版权信息，请联系我们，我们会及时处理。同时，也欢迎您的分享与参与，让我们共同打造一个丰富的学习社区。

资讯

IT技能网发布于2024-07-21

创建一个主题:

kafka-topics.sh --create --topic hello --bootstrap-server localhost:9092

查看主题详情:

kafka-topics.sh --describe --topic quickstart-events --bootstrap-server localhost:9092

查看主题列表:

kafka-topics.sh --list --bootstrap-server localhost:9092

删除主题:

kafka-topic --delete --topic helloe --bootstrap-server localhost:9092

生产消息:

kafka-console-producer.sh --topic hello --broker-list localhost:9092

消费消息:

kafka-console-consumer.sh --topic hello --bootstrap-server localhost:9092

重头消费:

kafka-console-consumer.sh --topic hello --from-beginning --bootstrap-server localhost:9092

指定消费者组:

kafka-console-consumer.sh --topic hello --bootstrap-server localhost:9092 --consumer.config ./config/consumer.properties 或者
kafka-console-consumer.sh --topic hello --bootstrap-server localhost:9092 --group test