kafka配置

1、kafka配置server.properties文件

1.1、进入kafka的config目录下

1.2、然后进入server.properties进行配置

[root@cjh1 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

[root@cjh1 config]# zkServer.sh start

2、启动kafka

[root@cjh1 bin]# ./kafka-server-start.sh ../config/server.properties 
# 这是后台启动kafka，两者选其一即可
[root@cjh1 bin]# ./kafka-server-start.sh -daemon ../config/server.properties

然后jps查看一下启动的服务

[root@cjh1 bin]# jps
2181 QuorumPeerMain
2872 Kafka
2941 Jps

# 创建topic
[root@cjh1 bin]# ./kafka-topics.sh --create --topic mydemo --zookeeper 192.168.48.141:2181 --partitions 1 --replication-factor 1 
Created topic "mydemo".

# 查看当前kafka中topic列表
[root@cjh1 bin]# kafka-topics.sh --zookeeper 192.168.48.141:2181 --list
mydemo

# 查看topic详细情况
[root@cjh1 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消费者
[root@cjh1 /]# kafka-console-consumer.sh --bootstrap-server 192.168.48.141:9092 --topic mydemo --from-beginning

# 启动kafka生产者
[root@cjh1 /]# kafka-console-producer.sh --broker-list 192.168.48.141:9092 --topic mydemo

# 查看topic消息数量
[root@cjh1 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
[root@cjh1 kafka-logs]# kafka-topics.sh --delete --zookeeper 192.168.48.141:2181 --topic mydemo

ps：删除topic的前提是需要将kafka的消费者和生产者停止。

ps：望多多支持，在下必再接再厉！！！