查看Kafka的进程是否在运行
#命令行终端中运行如下命令
ps -ef | grep kafka
find / -iname kafka-server-start.sh
cd /usr/local/kafka/bin/
#启动kafka
./kafka-server-start.sh -daemon /usr/local/kafka/config/server.properties
Kafka默认使用9092端口提供服务,可以使用以下命令查看该端口是否已经打开
netstat -tnlp | grep 9092
或者jps
如果Kafka进程正在运行,则会出现一个类似于以下的输出:
2705是kafka进程
zookeeper 配置
find / -iname zoo.cfg
cd /usr/local/zookeeper/conf
kafka 配置
find / -iname server.properties
cd /usr/local/kafka/config/
待更新
启动zookeeper
find / -iname zkServer.sh
cd /usr/local/zookeeper/bin/
#修改配置重新启动
/zkServer.sh restart
查看 zookeeper 是否正常启动成功
sudo netstat -tulnp | grep 2181
查看Kafka日志
tail /usr/local/kafka/logs/server.log
测试Kafka服务
可以通过在命令行终端中执行一些Kafka命令来测试Kafka服务是否正常工作。例如,可以使用以下命令查看Kafka当前可用的主题列表:
/usr/local/kafka/bin/kafka-topics.sh --zookeeper localhost:2181 --list
启动生产者
./kafka-console-producer.sh --broker-list localhost:9092 --topic helloKafka
启动消费者
./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic helloKafka