首先安装kafka，以单机为例：
wget https://mirrors.tuna.tsinghua.edu.cn/apache/kafka/2.8.1/kafka_2.12-2.8.1.tgz --no-check-certificate tar -zxf kafka_2.12-2.8.1.tgz cd kafka_2.12-2.8.1/启动kafka
nohup ./bin/zookeeper-server-start.sh config/zookeeper.properties & ./bin/kafka-server-start.sh -daemon config/server.properties
使用jps命令查看一下进程：
78022 Kafka 70379 QuorumPeerMain自导自演
启动生产者：
./bin/kafka-console-producer.sh --broker-list localhost:9092 --topic check_kafka
另开一个窗口，启动消费者：
./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic check_kafka --from-beginning
然后在生产者中输入什么，在消费者中就会输出什么，以此判断连通性
