Kafka安装和消息操作
Kafka安装和消息操作
仝玉甫 发表于5个月前
Kafka安装和消息操作
  • 发表于 5个月前
  • 阅读 4
  • 收藏 1
  • 点赞 0
  • 评论 0

腾讯云 技术升级10大核心产品年终让利>>>   

摘要: Kafka下载、安装、启动、发布消息、接收消息

下载

下载地址:http://kafka.apache.org/downloads

当前最新版本为0.11.0.0,建议下载 kafka_2.11-0.11.0.0.tgz

解压

tar -xzf kafka_2.11-0.11.0.0.tgz
cd kafka_2.11-0.11.0.0

启动服务

Kafka使用ZooKeeper,首先需要启动Zookeeper,Kafka内置了Zookeeper,可以用命令启动一个单节点Zookper:

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

Zookeeper默认端口为2181,可在zookeeper.properties中修改。

开启一个新的终端,启动Kafka:

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

创建Topic

创建一个单分片,单复制,名为test的topic

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

查看当前topic列表

bin/kafka-topics.sh --list --zookeeper localhost:2181

相对于手动创建topic,也可以设置当发送信息到不存在的topic时,自动创建topic。

查看topic明细:

bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic test

删除topic:

bin/kafka-topics.sh --zookeeper localhost:2181 --delete --topic test

永久删除topic:
删除kafka存储目录(server.properties文件log.dirs配置,默认为"/tmp/kafka-logs")相关topic目录 
删除zookeeper "/brokers/topics/"目录下相关topic节点
cd /usr/lib/zookeeper,或 cd <zookeeper安装目录>
bin/zkCli.sh -server 127.0.0.1
ls /brokers/topics/test
rmr /brokers/topics/test
rmr /admin/delete_topics/test

发送消息

开启一个新的终端,启动一个消息生产者:

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

发送消息:

This is a message
This is another message

接收消息

开启一个新的终端,启动一个消费者:

bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

可以看到接收到的消息。

停止Kafka服务

bin/kafka-server-stop.sh
bin/zookeeper-server-stop.sh

 

标签: Kafka
共有 人打赏支持
粉丝 6
博文 11
码字总数 8927
×
仝玉甫
如果觉得我的文章对您有用,请随意打赏。您的支持将鼓励我继续创作!
* 金额(元)
¥1 ¥5 ¥10 ¥20 其他金额
打赏人
留言
* 支付类型
微信扫码支付
打赏金额:
已支付成功
打赏金额: