centOS7安装kafka
2019-01-01 本文已影响0人
SetsunaHao
解压
tar -xf kafka_2.11-2.0.0.tgz
修改配置文件
vi /kafka_2.11-2.0.0/config/server.properties
修改配置文件
advertised.listeners=PLAINTEXT://192.168.3.201:9092 # 公布访问地址和端口 192.168.3.201 是你安装kafka的主机地址
zookeeper.connect= 192.168.199.124:2181 #依赖的zookeeper的地址(在下安装的是192.168.199.124这台主机)
broker.id= #订阅id
log.dir= #日志目录
启动kafka
/kafka_2.11-2.0.0/bin/kafka-server-start.sh /kafka_2.11-2.0.0/config/server.properties
检测是否启动
netstat -tunlp | egrep "(2181|9092)"
创建主题
/kafka_2.11-2.0.0/bin/kafka-topics.sh --create --zookeeper 192.168.199.124:2181 --replication-factor 1 --partitions 1 --topic test
创建生产者
/kafka_2.11-2.0.0/bin/kafka-console-producer.sh --broker-list 192.168.199.124:9092 --topic test
创建消费者
/kafka_2.11-2.0.0/bin/kafka-console-consumer.sh --bootstrap-server 192.168.199.124:9092 --topic test --from-beginning
