kafka配置及启动等命令总结
程序员文章站
2024-01-14 19:21:04
...
kafka配置跟启动等操作
kafka配置
1、kafka配置server.properties文件
1.1、进入kafka的config目录下
1.2、然后进入server.properties进行配置
[aaa@qq.com config]# vi ./server.properties
1.3、 通过显示行号进行查找并修改
:set nu
然后分别在下面指定行号修改以下内容（137行是最后加上去的，方便删除topic）
36 advertised.listeners=PLAINTEXT://192.168.48.141:9092
60 log.dirs=/opt/bigdata/kafka211/kafka-logs
123 zookeeper.connect=192.168.48.141:2181
137 delete.topic.enable=true
效果图如下：
2、配置kafka环境变量
vi /etc/profile:
export KAFKA_HOME=/opt/bigdata/kafka211
export PATH=$PATH:$KAFKA_HOME/bin
kafka启动
ps：启动kafka前需要启动zookeeper
1、启动zookeeper
[aaa@qq.com config]# zkServer.sh start
2、启动kafka
[aaa@qq.com bin]# ./kafka-server-start.sh ../config/server.properties
# 这是后台启动kafka，两者选其一即可
[aaa@qq.com bin]# ./kafka-server-start.sh -daemon ../config/server.properties
然后jps查看一下启动的服务
[aaa@qq.com bin]# jps
2181 QuorumPeerMain
2872 Kafka
2941 Jps
# 创建topic
[aaa@qq.com bin]# ./kafka-topics.sh --create --topic mydemo --zookeeper 192.168.48.141:2181 --partitions 1 --replication-factor 1
Created topic "mydemo".
# 查看当前kafka中topic列表
[aaa@qq.com bin]# kafka-topics.sh --zookeeper 192.168.48.141:2181 --list
mydemo
# 查看topic详细情况
[aaa@qq.com bin]# kafka-topics.sh --describe --zookeeper 192.168.48.141:2181 --topic mydemo
Topic:mydemo PartitionCount:1 ReplicationFactor:1 Configs:
Topic: mydemo Partition: 0 Leader: 0 Replicas: 0 Isr: 0
# 启动kafka消费者
[aaa@qq.com /]# kafka-console-consumer.sh --bootstrap-server 192.168.48.141:9092 --topic mydemo --from-beginning
# 启动kafka生产者
[aaa@qq.com /]# kafka-console-producer.sh --broker-list 192.168.48.141:9092 --topic mydemo
# 查看topic消息数量
[aaa@qq.com kafka-logs]# kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list 192.168.48.141:9092 --topic mydemo --time -1 --offsets 1
mydemo:0:2
# 删除topic
[aaa@qq.com kafka-logs]# kafka-topics.sh --delete --zookeeper 192.168.48.141:2181 --topic mydemo
ps：删除topic的前提是需要将kafka的消费者和生产者停止。
ps：望多多支持，在下必再接再厉！！！