Ubuntu Kafka的安装和使用

Posted 船长博客

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Ubuntu Kafka的安装和使用相关的知识,希望对你有一定的参考价值。

1. 到官网下载tgz文件:https://kafka.apache.org/downloads

2. 创建存放kafka的文件夹:sudo mkdir /opt/module

3. 解压下载的文件:

sudo tar -xvf kafka_2.12-2.8.0.tgz -C /opt/module
cd /opt/module
mv kafka_2.12-2.8.0 kafka
cd kafka

4. 使用默认配置启动zookeeper, 默认使用的端口是localhost:2181,(若2181端口被占用杀掉进程sudo fuser -k 2181/tcp)

sudo bin/zookeeper-server-start.sh config/zookeeper.properties

# 能看到一堆打印信息,其中有如下信息,显示启动成功:
[2021-08-10 20:37:18,482] INFO binding to port 0.0.0.0/0.0.0.0:2181

用bin/zookeeper-shell.sh连接ZK,显示如下信息即是成功:

bin/zookeeper-shell.sh localhost:2181

Connecting to localhost:2181 Welcome to ZooKeeper! JLine support is disabled WATCHER:: WatchedEvent state:SyncConnected type:None path:null

停止ZK命令:

sudo bin/zookeeper-server-stop.sh

5. 使用默认参数启动kafka,默认使用端口localhost:9092:

# 调试的时候去掉-daemon,这样日志能够显示出来
sudo bin/kafka-server-start.sh config/server.properties

# 连接ZK成功会打印下面的日志:
[2021-08-10 20:52:06,499] INFO starting (kafka.server.KafkaServer)
[2021-08-10 20:52:06,499] INFO Connecting to zookeeper on localhost:2181 (kafka.server.KafkaServer)
[2021-08-10 20:52:06,572] INFO Socket connection established, initiating session, client: /127.0.0.1:56418, server: localhost/127.0.0.1:2181 (org.apache.zookeeper.ClientCnxn)

# 调试稳定后使用此命令后台运行
# sudo bin/kafka-server-start.sh -daemon config/server.properties

# 停止kafka
sudo bin/kafka-server-stop.sh

6. 新建Topic,Name是first

bin/kafka-topics.sh --zookeeper localhost:2181 --create --replication-factor 1 --partitions 1 --topic first

# 创建成功提示:
# Created topic first.

# 查询创建的topic
bin/kafka-topics.sh --list --zookeeper localhost:2181

7. 生产者,消费者:

# 生产者准备生产
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic first
>ii
>aaa
>

# 消费者从头开始消费
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --from-beginning --topic first
ii
aaa

# 删除topic first
bin/kafka-topics.sh --zookeeper localhost:2181 --delete --topic first

参考:

https://kafka.apache.org/quickstart 官方快速指导

https://www.w3cschool.cn/apache_kafka/apache_kafka_basic_operations.html Apache Kafka 基本操作

https://xuzheng.blog.csdn.net/article/details/106873063 Kafka的学习和使用

https://support.huaweicloud.com/devg-kafka/Kafka-java-demo.html Kafka Java客户端接入示例

电信校园卡300一年500两年20GB+10GB通用流量200分钟通话30GB定向流量 v:13641304639

如果没有一直坚持,也不会有质的飞跃,当生命有了限度,每个人的价值就会浮现。

船长博客,期待共同交流提高!

本文如对您有帮助,记得点击右下边小球【赞一下】,热烈期待您关注博客 n(*≧▽≦*)n

以上是关于Ubuntu Kafka的安装和使用的主要内容,如果未能解决你的问题,请参考以下文章

续:纠正:ubuntu7.04可以安装,而且完美的安装 ! for《Oracle-10.2.0.1,打补丁10.2.0.5:在 debian 版本4不含4以上,及 ubuntu 7.04不含(代码片段

Java开发经验谈:ubuntu下安装java编译环境

ubuntu18.04下Kafka安装与部署

基于Ubuntu安装部署单机Kafka

Ubuntu16.04安装Kafka集群

Ubuntu 1604 安装配置 kafka,并配置开机自启(systemctl)