IT评测·应用市场-qidao123.com

标题: centos7安装单机kafka [打印本页]
作者: 半亩花草    时间: 2025-3-23 23:20
标题: centos7安装单机kafka
下载安装包并进行解压：kafka_2.12-2.2.1.tgz
  1. #解压
  2. tar -zxvf /usr/local/kafka/kafka_2.12-2.2.1.tgz
复制代码

  1. #修改服务配置：server.properties
  2. vi /usr/local/kafka/kafka_2.12-2.2.1/config/server.properties
复制代码
  1. # 唯一标识，集群里每个broker的id需不同
  2. broker.id=0
  3. #定义 Kafka Broker 实际监听的地址和端口
  4. listeners=PLAINTEXT://192.168.159.100:9092
  5. #定义客户端连接 Broker 的地址
  6. advertised.listeners=PLAINTEXT://192.168.159.100:9092
  7. # 日志路径，路径需提前创建好，且必须有读写权限
  8. log.dirs=/tmp/kafka-logs
  9. #设置zk的连接地址及端口。申明kafka所连接的zookeeper的地址 ，需配置为zookeeper的地址。
  10. zookeeper.connect=192.168.159.100:2181
复制代码
启动kafka：
  1. #进入目录
  2. cd /usr/local/kafka/kafka_2.12-2.2.1
  3. #启动
  4. ./bin/kafka-server-start.sh -daemon config/server.properties
复制代码
验证kafka是否启动成功
  1. #查看java进程
  2. jps
  4. #输出：
  5. 43267 QuorumPeerMain
  6. 45498 Kafka
  7. 63343 Jps
复制代码
kafka-topics.sh创建topic：
  1. ./bin/kafka-topics.sh --bootstrap-server 192.168.159.100:9092 --create --topic testTopic --partitions 1 --replication-factor 1
  3. # --bootstrap-server 表示要连接到哪台机器上
  4. # --create 表示要创建一个 topic
  5. # --topic 表示要创建的topic的名称，这里是 testTopic
  6. # --partitions 表示分区数
  7. # --replication-factor 表示副本数，不能大于 kafka 的节点数
复制代码
kafka-console-consumer.sh 利用 consumer 控制台订阅 topic
  1. ./bin/kafka-console-consumer.sh --bootstrap-server 192.168.159.100:9092 --topic testTopic --from-beginning
  2. # --from-beginning 消费者订阅topic之前，生产者如果已经发布了一个event，这时消费者是拿不到这个event的，如果想要拿到之前已经发布的event，就加上该参数。
复制代码
kafka-console-producer.sh 利用 producer 控制台发布 event
  1. ./bin/kafka-console-producer.sh --broker-list 192.168.159.100:9092 --topic testTopic
  2. # 在箭头后输入要发送的 event，每行代表一个 event
复制代码
测试：
生产者发送消息：

消耗者收到消息：


免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。



欢迎光临 IT评测·应用市场-qidao123.com (https://dis.qidao123.com/) Powered by Discuz! X3.4