官方这个kafka版本集成了zookeeper,不需要单独安装。
[root@localhost ~]# wget -c http://mirror.bit.edu.cn/apache/kafka/2.3.0/kafka_2.12-2.3.0.tgz [root@localhost ~]# mv kafka_2.12-2.3.0.tgz /usr/local [root@localhost ~]# cd /usr/local/ [root@localhost local]# tar zxvf kafka_2.12-2.3.0.tgz [root@localhost local]# ln -s kafka_2.12-2.3.0 kafka [root@localhost local]# cd kafka/bin/
# 启动zookeeper,默认端口2181
[root@localhost bin]# ./zookeeper-server-start.sh -daemon ../config/zookeeper.properties
# kafka配置文件需要注意 listeners 参数,直接写服务器ip
[root@localhost config]# cat server.properties | grep -vE "^#|^$" broker.id=0 # listeners 这个值会返给客户端(因为这里卡了2天没解决),具体信息看配置文件里的解释。 listeners=PLAINTEXT://192.168.10.74:9092 num.network.threads=3 num.io.threads=8 socket.send.buffer.bytes=102400 socket.receive.buffer.bytes=102400 socket.request.max.bytes=104857600 log.dirs=/tmp/kafka-logs num.partitions=1 num.recovery.threads.per.data.dir=1 offsets.topic.replication.factor=1 transaction.state.log.replication.factor=1 transaction.state.log.min.isr=1 log.retention.hours=168 log.segment.bytes=1073741824 log.retention.check.interval.ms=300000 # 指定zookeeper地址,因为在本机,直接默认localhost zookeeper.connect=localhost:2181 zookeeper.connection.timeout.ms=6000 group.initial.rebalance.delay.ms=0
# 启动kafka
[root@localhost bin]# ./kafka-server-start.sh -daemon ../config/server.properties
# 创建topic,类似创建一个数据库。
[root@localhost ~]# /usr/local/kafka/bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
# 查看已创建的topic
[root@localhost ~]# /usr/local/kafka/bin/kafka-topics.sh --list --zookeeper localhost:2181
# 查看指定的topic信息
[root@localhost ~]# /usr/local/kafka/bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic test
# 启动一个生产者
[root@localhost ~]# /usr/local/kafka/bin/kafka-console-producer.sh --broker-list 192.168.10.74:9092 --topic test
# 启动一个消费者
[root@localhost ~]# /usr/local/kafka/bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --from-beginning --topic test
在生产者里输入内容并回车,在消费者里就可以显示出生产者输入的内容。
原创文章,转载请注明。本文链接地址: https://www.rootop.org/pages/4508.html