centos7安装单机kafka

下载安装包并进行解压：kafka_2.12-2.2.1.tgz

1. #解压
2. tar -zxvf /usr/local/kafka/kafka_2.12-2.2.1.tgz

复制代码

• consumer.properties 是消耗者的相干设置
  
• producer.properties 是生产者的相干设置
  
• server.properties 是 kafka 服务的设置
  
• zookeeper.properties 是 zookeeper 的相干设置
  
  
  
  • zookeeper 中记录kafka的broker等信息
    
  
  

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企服之家，中国第一个企服评测及商务社交产业平台。