启动kafka首先启动zookeeper
./bin/zkServer.sh start

然后修改kafka的配置文件conf/server.properties，修改 listeners和log.dirs的值。

listeners的值不修改会报Broker may not be available.错误。修改listeners的值为自己的ip，示例listeners = PLAINTEXT://127.0.0.1:9092。

log.dirs的值不修改会报Error while loading log dir /tmp/kafka-logs (kafka.log.LogManager)错误。修改这个值为实际存在的路径，示例为log.dirs=/mnt/d/linux/kafka_2.12-2.8.0/kafka-logs

这之后就可以启动kafka了(-daemon表示后台运行)
./bin/kafka-server-start.sh -daemon ./config/server.properties

kafka 创建生产者
./bin/kafka-console-producer.sh --broker-list localhost:9092 --topic sensor

kafka 创建消费者
./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic sinktest