栏目分类:
子分类:
返回
文库吧用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
文库吧 > IT > 软件开发 > 后端开发 > Java

ubuntu 18 安装KAFKA

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

ubuntu 18 安装KAFKA

1.下载地址

kafka官方地址

2.安装

注意:kafka需要jdk支持,先安装jdk

# ubuntu环境下安装jdk
$ sudo apt install openjdk-11-jre-headless

kafka解压

$ tar -xzf kafka_2.13-3.1.0.tgz
$ cd kafka_2.13-3.1.0
3.启动kafka环境
# 启动ZooKeeper服务
# 将来,kafka将不在需要ZooKeeper
$ bin/zookeeper-server-start.sh config/zookeeper.properties
# 在另一个终端启动kafka服务
$ bin/kafka-server-start.sh config/server.properties
4.创建一个topic来存储事件
$ bin/kafka-topics.sh --create --topic quickstart-events --bootstrap-server localhost:9092
5.生产者将一些事件写入主题
$ bin/kafka-console-producer.sh --topic quickstart-events --bootstrap-server localhost:9092
This is my first event
This is my second event
6.消费者接收事件
$ bin/kafka-console-consumer.sh --topic quickstart-events --from-beginning --bootstrap-server localhost:9092
This is my first event
This is my second event
7.kafka结构


图:此示例主题有四个分区 P1–P4。两个不同的Producer客户端通过网络将事件写入主题的分区,彼此独立地向主题发布新事件。具有相同键的事件(在图中由它们的颜色表示)被写入同一个分区。请注意,如果合适的话,两个生产者都可以写入同一个分区。

转载请注明:文章转载自 www.wk8.com.cn
本文地址:https://www.wk8.com.cn/it/785542.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 wk8.com.cn

ICP备案号:晋ICP备2021003244-6号