安装部署后
consumer.properties
group.id=test-group
单机测试,自己开俩窗口,一个测试消费者,一个测试生产者(创建消息那步)
创建主题
bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic mytesttopic
查看主题
bin/kafka-topics.sh --list --bootstrap-server localhost:9092 hd-topic
删除消费者
bin/kafka-topics.sh --bootstrap-server localhost:9092 --topic mytopic --delete?
查看消费者组
bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --list
创建消息
kafka-console-producer.sh --bootstrap-server localhost:9092 --topic mytesttopic
>? 11111111
出现上边的大于号,就可以输入消息了。
再开启个窗口,消费者角度查看消息
kafka-console-consumer.sh --bootstrap-server localhost:9092 ?--topic mytesttopic --group test-group --from-beginning
--from-beginning是从头消费,不带他是之前的不消费,生产者再创建时消费最新的
刚开始研究,还不是太明白。只研究了这些基本步骤。