Kafka(二)搭建

一、下载kafka的安装文件

访问官方地址:http://kafka.apache.org/downloads
我下载的是以下版本:

下载地址
下载地址

上传到服务器/opt,并解压:

[root@iZ2ze7sn66bchxncut8rgsZ /]# cd /opt
[root@iZ2ze7sn66bchxncut8rgsZ opt]# tar -xvf kafka_2.12-2.7.0.tgz
[root@iZ2ze7sn66bchxncut8rgsZ opt]# cd kafka_2.12-2.7.0/
[root@iZ2ze7sn66bchxncut8rgsZ kafka_2.12-2.7.0]# ll
总用量 56
drwxr-xr-x 3 root root  4096 12月 16 22:01 bin
drwxr-xr-x 2 root root  4096 12月 16 22:01 config
drwxr-xr-x 2 root root  8192 2月   1 14:44 libs
-rw-r--r-- 1 root root 29975 12月 16 21:58 LICENSE
-rw-r--r-- 1 root root   337 12月 16 21:58 NOTICE
drwxr-xr-x 2 root root    44 12月 16 22:01 site-docs

二、启动服务

这里有两种方式配置ZK:
1)自己搭建单独的一套服务
2)使用kafka提供的单节点zk服务。

这里为了演示且zk不是关注点,我们直接使用自带的zk。

[root@iZ2ze7sn66bchxncut8rgsZ bin]# cd ../
[root@iZ2ze7sn66bchxncut8rgsZ kafka_2.12-2.7.0]# ./bin/zookeeper-server-start.sh config/zookeeper.properties 

启动kafka服务:

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

以上启动都是直接启动的,真实请使用后台启动nohup

#启动zk
nohup ./bin/zookeeper-server-start.sh config/zookeeper.properties >/dev/null &
#启动kafka服务
nohup ./bin/kafka-server-start.sh config/server.properties >/dev/null &

三、验证

有一款插件,朋友们可以下载下,利于我们分下线上的问题。
下载地址如下:https://www.kafkatool.com/

kafka tool

打开新窗口,验证kafka服务是否成功:
1、创建一个topic,名为“test-kafka”,它有一个分区和一个副本:

[root@iZ2ze7sn66bchxncut8rgsZ kafka_2.12-2.7.0]# bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test-kafka
Created topic test-kafka.

2、查看当前存在的topic

[root@iZ2ze7sn66bchxncut8rgsZ kafka_2.12-2.7.0]# bin/kafka-topics.sh --list --zookeeper localhost:2181
__consumer_offsets
test
test-kafka

3、创建生产者

[root@iZ2ze7sn66bchxncut8rgsZ kafka_2.12-2.7.0]# bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test-kafka
>

4、打开新窗口,创建消费者

[root@iZ2ze7sn66bchxncut8rgsZ kafka_2.12-2.7.0]# bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test-kafka --from-beginning

5、发送消息,查看结果
使用生产者发送消息“hello world”:

image.png

查看消费者:

消费者

从上面看到消费者成功接收到生产者发送的消息了。

下一章节,我们看下如何部署kafka集群。

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
【社区内容提示】社区部分内容疑似由AI辅助生成,浏览时请结合常识与多方信息审慎甄别。
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

相关阅读更多精彩内容

友情链接更多精彩内容