当前位置: 首页 > >

kafka单节点单broker的部署和使用

发布时间:

1、下载kafka安装包
这里需要注意的是因为kafka的是用scala开发的,所以这里要注意scala的版本。
kafka_2.12-2.0.0.tgz 从安装包的名称可以看出“2.12”为scala的版本号,“2.0.0”为kafka的版本号


2、重要参数讲解
$KAFKA_HOME/config/server.properties


# The id of the broker. This must be set to a unique integer for each broker.
# 这个就是broker id,在kafka集群中,这个id不能重复
broker.id=0
# kafka监听的端口
listeners=PLAINTEXT://localhost:9092
# 这个是存储kafka的日志文件的,默认是放在临时目录下的,当机器*艉螅募投Я耍哉饫镆匦屡渲
log.dirs=/tmp/kafka-logs
# 配置zookeeper地址
zookeeper.connect=localhost:2181

3、启动kafka
kafka-server-start.sh $KAFKA_HOME/config/server.properties

4、创建topic
kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test



replication-factor:副本系数,单节点就是1
partitions:分区数




查看所有的topic
kafka-topics.sh --list --zookeeper localhost:2181


5、生产消息
kafka-console-producer.sh --broker-list localhost:9092 --topic test


6、消费消息
kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning



这里需要注意的是创建topic是向zookeeper中注册节点,所以用的是 --zookeeper localhost:2181
而生产消息和消费消息是往broker中生产和消息消息的,所以用的是 --broker-list localhost:9092
?from-beginning 表示从头开始消费



7、查看topic状态
kafka-topics.sh --describe --zookeeper localhost:2181 --topic test



Replicas:副本数量
Isr:活着的是哪几个(多broker的时候才能看出来)



8、在zookeeper中查看注册的broker节点
在$ZOOKEEPER_HOME/bin目录中使用zkCli.sh命令,进入控制台使用如下命令,就能够查看到注册的broker节点

END!!!



友情链接: