kafka centos安装发送消费消息

Posted zhongwei.xiao

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了kafka centos安装发送消费消息相关的知识,希望对你有一定的参考价值。

1. 请先下载安装文件,java环境需提前安装,解压到指定目录:
tar -zxvf kafka_2.11-2.3.1.tgz -C /root/soft/

从官网下载文件,上传到centos虚拟机指定路径下,当前download文件夹下面

 

 解压到指定目录soft文件夹下面:

2. 创建zk日志目录。
mkdir zklogs
3. 查看是否启动成功,
ps -ef | grep zookeeper

 4. 启动zookeeper

nohup bin/zookeeper-server-start.sh ./config/zookeeper.properties &

 5. 修改kafka配置

vim config/server.properties
执行命令 vi config/server.properties 修改kafka的配置信息
修改advertised.host.name和advertised.port信息
修改日志文件路径:
修改log.dirs=/root/soft/kafka-logs为log.dirs=/root/soft/kafka/logs 该参数为kafka日志文件存放路径

advertised.host.name=192.168.132.152
advertised.port=9092

log.dirs=/root/soft/kafka/logs

 

 

 6. 启动kafka

nohup bin/kafka-server-start.sh ./config/server.properties

 执行命令ps -ef | grep kafka查看kafka是否启动成功

7. 创建mytest主题
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic mytest

 获取所有topic

bin/kafka-topics.sh --list --zookeeper localhost:2181
8. 生产测试消息
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic mytest

 9. 消费消息

bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic mytest --from-beginning

 kafka和java安装文件网盘下载地址:

链接:https://pan.baidu.com/s/1DhbzsKvqB7Y3S9QJQUUK9A
提取码:zim2

 

以上是关于kafka centos安装发送消费消息的主要内容,如果未能解决你的问题,请参考以下文章

CentOS 7 安装 Zookeeper + Kafka 集群

Kafka安装之二 在CentOS 7上安装Kafka

Spring Kafka和Spring Boot整合实现消息发送与消费简单案例

Kafka的安装与使用(转)

Centos7安装zookeeper+kafka集群

Kafka的安装与使用