kafka 安装和启动
作者:互联网
kafka中文教程 学习记录
首先准备好linux机器环境,参考此篇文章:快速搭建Linux服务器环境
单机版
1. 下载代码
https://kafka.apache.org/downloads.html
官方的下载链接比较慢,这里可以使用第三方下载转发的链接地址:
wget --no-check-certificate https://dl0.serctl.com/downloads8/2021-11-05-12-14-20--kafka_2.13-3.0.0.tgz
$ ll
total 84372
-rw-rw-r--. 1 vagrant vagrant 86396520 Sep 20 08:46 2021-11-05-12-14-20--kafka_2.13-3.0.0.tgz
$ tar -xzf 2021-11-05-12-14-20--kafka_2.13-3.0.0.tgz
$ cd kafka_2.13-3.0.0/
2. 启动服务
启动kafka 需要jdk环境,可参考这篇文章:在linux上面安装jdk
kafka自带打包和配置好的Zookeeper
启动Apache Kafka 内置的zookeeper
$ cd kafka_2.13-3.0.0/
$ bin/zookeeper-server-start.sh config/zookeeper.properties
启动kafka服务
$ cd kafka_2.13-3.0.0/
$ bin/kafka-server-start.sh config/server.properties
3. 创建一个主题(topic)
创建一个名为“test”的Topic,只有一个分区和一个备份
$ cd kafka_2.13-3.0.0/
$ bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test
查看已创建的topic信息:
$ cd kafka_2.13-3.0.0/
$ bin/kafka-topics.sh --describe --topic test --bootstrap-server localhost:9092
Topic: test TopicId: DdW4QskuTH2DwnGvM0Mjdg PartitionCount: 1 ReplicationFactor: 1 Configs: segment.bytes=1073741824
Topic: test Partition: 0 Leader: 0 Replicas: 0 Isr: 0
4. 发送消息
生产者
$ bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
This is a message
This is another message
5. 消费消息
$ cd kafka_2.13-3.0.0/
$ bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
上面我们使用命令的方式简单演示了一下kafka的基本流程。
你有哪些疑问吗?
标签:bin,启动,--,安装,kafka,3.0,test,2.13 来源: https://blog.csdn.net/weixin_45847167/article/details/121111390