kafka单机版部署文档(linux)
程序员文章站
2022-05-27 17:05:42
...
一、下载kafka2.10的包(kafka自带zookeeper,所以无需单独安装zookeeper)
请切换到自己kafka的安装目录再下载,我是在/usr/local/kafka下安装,没有此目录请新建。
wget http://labfile.oss.aliyuncs.com/courses/859/kafka_2.10-0.10.2.1.tgz
二、解压压缩包
tar -zxvf kafka_2.10-0.10.2.1.tgz
mv kafka_2.10-0.10.2.1 kafka
三、修改配置文件
切换到kafka/config目录下,修改配置文件server.properties
broker.id=0
port=9092
# 如果需要外网访问(例如java-api),必须有此项配置,将IP替换成本机的IP
listeners=PLAINTEXT://IP:9092
advertised.listeners=PLAINTEXT://IP:9092
zookeeper.connect=localhost:2181
log.dirs=/usr/local/logs/kafka
四、启动kafka
启动zookeeper(后台启动),再启动kafka(后台启动)
bin/zookeeper-server-start.sh -daemon config/zookeeper.properties
bin/kafka-server-start.sh -daemon config/server.properties
五、测试
开启两个客户端,一个作为peoducer一个作为consumer
# producer执行
bin/kafka-console-producer.sh --broker-list *.*.*.*:9092 --topic topic1
# consumer执行
bin/kafka-console-consumer.sh --bootstrap-server *.*.*.*:9092 --topic topic1 --from-beginning
producer发送消息,consumer可以接收到。
六、引用一个常见的问题以及修改方法 - Broker may not be available
上一篇: Java中时间日期的操作
下一篇: 时间日期选择