1、安装
brew install kafka
会一起安装zookeeper和Kafka两个插件
2、文件路径
(1)Kafka的bin目录路径
/usr/local/Cellar/kafka/2.5.0/bin,里面包含Kafka的各种操作命令
kafka-server-start,服务启动命令
kafka-server-stop,服务停止命令
kafka-topics,主题操作命令
kafka-console-producer,生产消息命令
kafka-console-consumer,消费消息
(2)Kafka的配置文件路径
/usr/local/etc/kafka
zookeeper.properties,zookeeper的配置文件
server.properties,Kafka服务的配置文件
3、必须的前提修改Kafka的配置文件,否则后面的启动会失败
vim /usr/local/etc/kafka/server.properties
增加:listeners=PLAINTEXT://localhost:9092
其中有改行,默认被注释掉了,打开修改即可
4、打开新终端窗口1,进入Kafka的bin目录启动zookeeper服务
kafka-server-start /usr/local/etc/kafka/server.properties &
都是info,没有报fatal或者error错误,即为启动成功。
如果不先修改第3步的配置文件,那么会报错如下
ERROR Exiting Kafka due to fatal exception (kafka.Kafka$)
5、打开新终端窗口2,进入Kafka的bin目录启动Kafka资深的服务
kafka-server-start /usr/local/etc/kafka/server.properties &
都是info,没有报fatal或者error错误,即为启动成功。
如果不先修改第3步的配置文件,那么会报错如下
ERROR Exiting Kafka due to fatal exception (kafka.Kafka$)
6、打开新终端窗口3,进入Kafka的bin目录,新建topic主题test
kafka-topics --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
出现:Created topic test. 表明建立topic成功
查看所有目前的topic,校验是否新建完毕
kafka-topics --list --zookeeper localhost:2181
会列出所有建立的topic
7、打开新终端窗口4,进入Kafka的bin目录,打开生产者客户端,topic为test的主题
kafka-console-producer --topic test --broker-list localhost:9092
出现>表示启动生产者客户端成功,等待输入生产者消息,输入消息,回车,即表示插入了一条消息到主题test的队列中
8、打开新终端窗口5,进入Kafka的bin目录,打开消费者客户端,topic为test的主题
kafka-console-consumer --bootstrap-server localhost:9092 -topic test
等待显示生产者输入的消息,并同步显示出来