Ubuntu 部署 kafka2.12

Ubuntu 部署 kafka2.12

kafka官网下载 kafka_2.12-3.0.0.tgz

解压启动：

> tar -xzf kafka_2.12-3.1.0.tgz
cd kafka_2.12-3.0.0

zookeeper配置修改config/zookeeper.properties：

#修改为自定义的zookeeper数据目录
dataDir=/usr/local/kafka/zookeeper

#修改为自定义的zookeeper日志目录
dataLogDir=/usr/local/kafka/log/zookeeper 

# 端口
clientPort=2181

后台启动Zookeeper服务。

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

kafka配置修改config/server.properties：

broker.id=0

listeners=PLAINTEXT://192.168.100.200:9092

zookeeper.connect=192.168.100.200:2181

后台启动kafka：

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

停止

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

创建主题

./bin/kafka-topics.sh --create --bootstrap-server 192.168.100.200:9092 --replication-factor 1 --partitions 1 --topic test123

删除主题

./bin/kafka-topics.sh --delete --bootstrap-server 192.168.100.200:9092 --topic test123

查看主题列表

./bin/kafka-topics.sh --bootstrap-server 192.168.100.200:9092 --list

./bin/kafka-topics.sh --bootstrap-server 192.168.100.200:9092 --topic test123 --describe

启动生产者

./bin/kafka-console-producer.sh --broker-list 192.168.100.200:9092 --topic test123

启动消费者

./bin/kafka-console-consumer.sh --bootstrap-server 192.168.100.200:9092 --topic test123 --from-beginning