kafka客户端自带的脚本生产-消费消息
2018-02-20 21:44
771 查看
使用控制台脚本生产-消费消息
使用控制台的生产者脚本生产消息➜ bin sh kafka-console-producer.sh --broker-list localhost:9092 --topic test >one >two >three
使用控制台的消费者脚本消费消息
➜ bin sh kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning one two three
管理consumer分区
列出所有的consumersh kafka-consumer-groups.sh --bootstrap-server localhost:9092 --list
查询所有的topic
sh kafka-topics.sh --list --zookeeper 192.168.10.151:2181
参考文档
http://kafka.apache.org/documentation/#basic_ops_add_topic相关文章推荐
- java利用kafka生产消费消息
- 简单搭建kafka + zookeeper,附简单Java生产和消费客户端
- kafka消费者客户端启动之后消费不到消息的原因分析
- Java API 生产和消费Kafka消息
- Kafka消息生产消费的一个java小案例(伪分布)
- rocketMq的消息的生产和消费
- Kafka利用Java实现数据的生产和消费实例教程
- Kafka 使用Java实现数据的生产和消费demo
- kafka无法消费消息
- 使用eclipse自带插件生产WebService客户端代码
- Kafka生产与消费实战
- 从Message生产到消费的过程理解Handler消息机制
- Kafka:Kafka的生产和消费(Java版本)
- spring整合kafka项目生产和消费测试结果记录(一)
- kafka0.8.2集群的环境搭建并实现基本的生产消费
- [Kafka] - Kafka内核理解:消息的收集/消费机制
- Kafka消息保证不丢失和重复消费问题
- 使用Java代码实现实时消费kafka的消息
- Kafka 使用Java实现数据的生产和消费demo
- Kafka生产与消费实战