kafka 常用命令行命令

1、创建topic。

kafka-topics.sh --create --zookeeper zookeeper01:2181 --replication-factor 1 --partitions 1 --topic test

2、消费端,消费数据。

kafka-console-consumer.sh --bootstrap-server kafka_node1:9092 --topic test --from-beginning

3、生产端,生产数据。注意应该在另外一个终端打开。

kafka-console-producer.sh --bootstrap-server kafka_node1:9092 --topic test

4、查看topic列表。

kafka-topics.sh --zookeeper zookeeper01:2181 --list

5、执行删除kafka命令时,应该注意的事项。

#需要server.properties中设置delete.topic.enable=true否则只是标记删除。


本文来自互联网用户投稿,文章观点仅代表作者本人,不代表本站立场,不承担相关法律责任。如若转载,请注明出处。 如若内容造成侵权/违法违规/事实不符,请点击【内容举报】进行投诉反馈!

相关文章

立即
投稿

微信公众账号

微信扫一扫加关注

返回
顶部