Centos安装Kafka
2023-09-27 14:29:10 时间
点对点消息系统:生产者发送一条消息到queue,一个queue可以有很多消费者,但是一个消息只能被一个消费者接收,当没有消费者可用时,这个消息会被保存直到有一个可用的消费者,所以Queue实现了一个可靠的负载均衡。
发布订阅消息系统:发布者发送到topic的消息,只有订阅了topic的订阅者才会收到消息。topic实现了发布和订阅,当你发布一个消息,所有订阅这个topic的服务都能得到这个消息,所以从1到N个订阅者都能得到这个消息的拷贝。
kafka介绍
Apache Kafka是一种高吞吐量的分布式发布订阅消息系统。它最初由LinkedIn公司开发,之后成为Apache项目的一部分。
1、下载Kafka
cd /root/soft
wget https://mirrors.bfsu.edu.cn/apache/kafka/2.4.1/kafka_2.11-2.4.1.tgz
2、解压
tar -zxvf kafka_2.11-2.4.1.tgz
cd /root/soft/kafka_2.11-2.4.1
3、修改 kafka-server 配置文件
vim /root/soft/kafka_2.11-2.4.1/config/server.properties
修改其中的:
broker.id=0
log.dir=/usr/local/kafka/kafka-logs
#配置zookeeper管理kafka的路径
zookeeper.connect=localhost:2181
#配置kafka的监听端口
listeners=PLAINTEXT://:9092
#把kafka的地址端口注册给zookeeper,如果是远程访问要改成外网IP
advertised.listeners=PLAINTEXT://203.195.205.63:9092
4、启动 Kafka 服务
Kafka依赖zk,需先启动zk。
4.1、启动 zk
cd /root/soft/zookeeper-3.4.14/bin
./zkServer.sh start #启动
./zkServer.sh stop #关闭
4.2、启动 Kafka
使用 kafka-server-start.sh 启动 kafka 服务:
cd /root/soft/kafka_2.11-2.4.1/bin
##Kafka启动方法一
./kafka-server-start.sh ../config/server.properties
##Kafka启动方法二
./kafka-server-start.sh ../config/server.properties > /logs/kafka.log 2>&1 &
5、验证kafka是否可以使用
5.1、进入 /root/soft/kafka_2.11-2.4.1/bin 目录下
$ cd /root/soft/kafka_2.11-2.4.1/bin
5.2、运行kafka生产者发送消息
$ ./kafka-console-producer.sh --broker-list localhost:9092 --topic sun
发送消息
> aa
5.3、运行kafka消费者接收消息
$ ./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic sun --from-beginning
aa
5.4、查看主题列表
./kafka-topics.sh --list --zookeeper localhost:2181
sun
相关文章
- Building Apache Thrift on CentOS 6.5
- RHEL/CentOS 7 中配置 PXE 网络启动服务器
- CentOS的free命令
- CentOS Linux下VNC Server远程桌面配置详解
- centos下安装go环境两种方法
- 阿里云服务器安装图形化界面(CentOS)
- Linux-019-Centos Shell 安装 Nginx 后启动时提示找不到Lua模块的libluajit-5.1.so.2文件,具体提示信息:./nginx: error while loading shared libraries: libluajit-5.1.so.2: cannot open shared object file: No such file or directory
- docker安装与配置(CentOS 7)
- Centos yum的源 设置为阿里云源
- #Centos#SSH 新安装的Centos7系统如何进行SSH访问
- CentOS下的一些基础问题解答
- 查看centos版本及32还是64位
- CentOS找不到想要的镜像版本?