安装kafka

首先安装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

然后在生产者中输入什么，在消费者中就会输出什么，以此判断连通性