Kafka基本使用

查看Kafka的进程是否在运行

#命令行终端中运行如下命令
ps -ef | grep kafka

find / -iname  kafka-server-start.shcd /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.cfgcd /usr/local/zookeeper/conf

kafka 配置

 find / -iname server.propertiescd /usr/local/kafka/config/

待更新

 

  启动zookeeper

find / -iname  zkServer.shcd /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

kafka可视化工具Kafka