kafka基本操作

1、查看topic列表

bin/kafka-topics.sh --list --zookeeper 127.0.0.1:2181

2、创建topic

bin/kafka-topics.sh --create --zookeeper 127.0.0.1:2181 --replication-factor 1 --partitions 1 --topic test

3、删除topic，这是最新版本的kafka删除方式，最新版本删除须在server.properties中配置 delete.topic.enable=true

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

4、在控制台启动一个生产者，启动后输入发送内容即可

bin/kafka-console-producer.sh --broker-list 127.0.0.1:9092 --topic test

5、在控制台启动一个消费者，配合上面生产者使用，上面发送消息，这里控制台即打印出发送的消息，这里的消费不会影响你程序中对数据的消费，可以大胆使用

从开始位置打印
bin/kafka-console-consumer.sh --zookeeper 127.0.0.1:2181 --from-beginning --topic test
不打印历史数据
bin/kafka-console-consumer.sh --zookeeper 127.0.0.1:2181 --topic test
bin/kafka-console-consumer.sh --bootstrap-server 192.168.1.161:9092 --topic test --from-beginning