Kafka shell

2019/09/13 16:46
阅读数 10

Topic:可以理解为一个队列,生产者和消费者面向的都是一个 topic。

Partition:主要为了做负载,实现扩展性,一个非常大的 topic 可以分布到多个 broker(即服务器)上,一个 topic 可以分为多个 partition,每个 partition 是一个有序的队列。

 

 

一、topic 操作

# 查看当前服务器中的所有 topic
kafka-topics.sh --zookeeper h136:2181 --list

# 创建 topic,副本数不能超过节点数
kafka-topics.sh --zookeeper h136:2181 --create --replication-factor 3 --partitions 1 --topic first
# 选项说明:
# --topic:定义 topic 名
# --replication-factor:定义副本数
# --partitions:定义分区数

# 查看某个 Topic 的详情
bin/kafka-topics.sh --zookeeper h136:2181 --describe --topic first

# 修改分区数
bin/kafka-topics.sh --zookeeper h136:2181 --alter --topic first --partitions 3

# 删除 topic
kafka-topics.sh --zookeeper h136:2181 --delete --topic first

 

二、生产者与消费者

# 生产者
kafka-console-producer.sh --broker-list h136:9092 --topic first

# 消费者,可连接 Kafka 集群和 Zookeeper 集群
kafka-console-consumer.sh --bootstrap-server h136:9092 --topic first --from-beginning
# 0.90 版本之前启动消费者的方法
kafka-console-consumer.sh --zookeeper h140:2181 --topic first
# --from-beginning:会把主题中以往所有的数据都读取出来。

 


http://kafka.apache.org/documentation/#quickstart_createtopic

展开阅读全文
打赏
0
0 收藏
分享
加载中
更多评论
打赏
0 评论
0 收藏
0
分享
返回顶部
顶部