多语言展示
当前在线:955今日阅读:168今日分享:49

命令行使用kafka方法

kafka是在linux下面安装的,这样可以多开几个终端配合进行测试。下面是使用kafka的一些方法
方法/步骤
2

查看创建的topicbin/kafka-topics.sh --list --zookeeper localhost:2181

3

创建一个消费者bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

4

创建一个生产者bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

5

生产者生产消息

6

消费者消费消夏联斤息

7

bin/kafka-topics.sh --delete --zookeeper localhost:2181 --topic test

8

验证芬八topic是否离孝删除成功 bin/kafka-topics.sh --list --zookeeper localhost:2181

推荐信息