kafka
版本:2.4.0
操作系统:
CentOS 7.8
1、下载软件包
> wget http://mirrors.tuna.tsinghua.edu.cn/apache/kafka/2.4.0/kafka_2.12-2.4.0.tgz
2、解压
> tar -zxvf kafka_2.12-2.4.0.tgz
3、移动到你想要安装的位置
> mv kafka_2.12-2.4.0/ /opt/kafka_2.12-2.4.0
4、后台启动自带的zookeeper
kafka
使用zookeeper
管理服务节点,如果没有安装zookeeper
,可以使用kafka
功能目录bin/zookeeper-server-start.sh
脚本启动一个单节点的zookeeper
实例:
> cd /opt/kafka_2.12-2.4.0
> bin/zookeeper-server-start.sh -daemon config/zookeeper.properties
加上-daemon
参数就不会将启动日志打印到控制台了,然后通过jps
(查看java
进程命令)查看:
> jps
2289 QuorumPeerMain
3079 Jps
出现QuorumPeerMain
就说明zookeeper
启动成功了。zookeeper
的默认监听端口是2181
。
5、后台启动kafka
> bin/kafka-server-start.sh -daemon config/server.properties
加上-daemon
参数就不会将启动日志打印到控制台了,然后通过jps
(查看java
进程命令)查看:
> jps
2289 QuorumPeerMain
3058 Kafka
3079 Jps
出现Kafka
就说明kafka
启动成功了。kafka
默认监听端口是9092
。
6、创建一个topic
首先创建一个名为test
的topic
来接收和发送消息。
通过以下命令创建test
主题:
> bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --partitions 1 --replication-factor 1 --topic test
其中:
-
--partitions 1
指定该topic
只有一个分区;扫描二维码关注公众号,回复: 9232405 查看本文章 -
--replication-factor 1
指定该分区只有一个副本处理消息。
可以执行以下命令查看test
主题是否创建成功:
> bin/kafka-topics.sh --list --bootstrap-server localhost:9092
7、消费者订阅topic
消息
执行以下脚本订阅test
主题消息:
> bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
8、发送者发布消息
运行kafka
提供的生产者脚本,发送消息,默认情况下,每一行都将作为一个独立的消息被发送:
> bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
然后键入你想要发送的消息,按回车,消息就会发送到test
这个topic
上,被订阅的消费者接收。