创建主题
<代码> kafka-topics。sh -创造- bootstrap-server localhost: 9092——主题abt分区2——复制因子1
查看主题都有哪些
<代码> kafka-topics。sh——列表管理员localhost: 2181
生产者,将文件中的数据写入卡夫卡生产者
<代码> kafka-console-producer。sh——券商名单上localhost: 9092——主题order_topic & lt;abc.txt
消费者,从最开始的位移,消费中主题的数据
<代码> kafka-console-consumer。sh - bootstrap-server localhost: 9092——主题order_topic从头
重置消费者团体的抵消到最新位移
<代码> kafka-consumer-groups。sh - bootstrap-server localhost: 9092——集团group_name_1——reset-offsets——主题order_topic——最新执行
查看消费者组消费者团体位移
<代码> [homework@test ~] kafka-consumer-groups美元。sh - bootstrap-server host1:9092, host2:9092 groupname_1——描述组 主题分区当前偏移量LOG-END-OFFSET滞后用户id主机客户机id 订单5 20781271 20781556 285 - - - - - - - - 订单1 10553765 10554032 267 - - - - - - - - 订单2 10634508 10634808 300 - - - - - - - - 订单7 10375128 10375355 227 - - - - - - - - 订单6 10435147 10435467 320 - - - - - - - - 0 10640342 10640643 301 - - - 订单3 13762141 13762478 337 - - - - - - - - 订单8 11176468 11176707 239 - - - - - - - - 订单4 10443088 10443320 232 - - - - - - - -
