- 再过半小时，你就能明白kafka的工作原理了 – 知乎 (zhihu.com)
- https://blog.csdn.net/shangmingtao/article/details/79567921?spm=1001.2101.3001.6661.1&utm_medium=distribute.pc_relevant_t0.none-task-blog-2%7Edefault%7ECTRLIST%7ERate-1-79567921-blog-91975123.t0_edu_mix&depth_1-utm_source=distribute.pc_relevant_t0.none-task-blog-2%7Edefault%7ECTRLIST%7ERate-1-79567921-blog-91975123.t0_edu_mix
- 查看topic
- ./kafka-topics.sh –list –zookeeper hadoopm01:2181,hadoopm02:2181,hadoops01:2181
- 查看topic详细信息
- ./kafka-topics.sh –describe topic名称 –zookeeper hadoopm01:2181,hadoopm02:2181,hadoops01:2181
- 创建topic
- ./kafka-topics.sh –create –zookeeper hadoopm01:2181,hadoopm02:2181,hadoops01:2181 –replication-factor 3 –partitions 3 –topic testzyy
- 生产消息
- ./kafka-console-producer.sh –broker-list hadoops01:9092,hadoops02:9092,hadoops03:9092,hadoops04:9092,hadoops05:9092 –topic testliulin
- 消费消息
- ./kafka-console-consumer.sh –bootstrap-server hadooos01:9092,hadoops02:9092,hadoops03:9092,hadoops04:9092,hadoops05:9092 –topic testliulin –from-beginning
- 删除topic
- ./kafka-topics.sh –delete –topic testzyy –zookeeper hadoopm01:2181,hadoopm02:2181,hadoops01:2181
- 查看kafka的 group 信息
- /root/kafka_2.11-2.3.1/bin/kafka-consumer-groups.sh –zookeeper 172.16.31.55:2181 –list
- 查看kafka的group id 信息
- ./kafka-consumer-groups.sh –zookeeper 172.16.31.55:2181 –group console-consumer-64116 –describe
- 查看topic
作者 admin
张宴银，大数据开发工程师