后台形式启动kafka
./bin/kafka-server-start.sh -daemon /usr/local/kafka/config/server.properties
查询当前所有 topic
./bin/kafka-topics.sh --list --zookeeper localhost:2181
创建生产者
./kafka-console-producer.sh --broker-list localhost:9092 --topic testkafka
启动消费者
./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic testkafka --from-beginning
完美
转载:
https://www.orchome.com/454
问题汇总：
1.
在做kafka测试的时候，使用命令bin/kafka-console-consumer.sh --zookeeper 192.168.0.140:2181,192.168.0.141:2181 --topic test --from-beginning启动消费者，发现一只报错consumer zookeeper is not a recognized option，搜索了半天，一只没有解决，最后，换了一个低版本的kakfa，发现在启动的时候说使用 --zookeeper是一个过时的方法，此时，才知道原来在最新的版本中，这种启动方式已经被删除了，
最后附上0.90版本之后启动消费者的方法： bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
2.
WARN [Consumer clientId=consumer-1, groupId=console-consumer-77498] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)
说明broker挂掉了，在zookeeper上可以查看当前运行的broker数量
在zkCli.sh打开命令行后，ls /brokers/ids查看当前运行的broker数量
为什么会发生这个问题，因为meta.properties（在tmp或者logs目录下）跟service.properties（在config目录下）中的brokerid不一致造成的。