kafka配置笔记

Posted on 2018-01-29 17:20 哈哈丶大傻瓜 阅读(…) 评论(…) 编辑 收藏

借鉴官网教程：http://kafka.apache.org/082/documentation.html#quickstart

安装kafka

1.安装

2.启动

（1）start the server 

  先启动zookeeper server

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


再启动kafka server
bin/kafka-server-start.sh config/server.properties
 

（2）create topic 

bin/kafka-topics.sh --create --zookeeper 192.168.1.244:8780 --replication-factor 1 --partitions 1 --topic test_1

 

 

（3）send messages 

生产者生产数据

 

其中broker的端口为9092 

（4）start a consumer

消费者消费数据：

（5）setting up a multi-broker cluster

cp config/server.properties config/server-1.properties 
cp config/server.properties config/server-2.properties 
cp config/server.properties config/server-3.properties

然后，改一下3个配置

 

config/server-1.properties:
    broker.id=1
    port=9093
    log.dir=/home/luo/qzd/kafka-logs-1
 
config/server-2.properties:
    broker.id=2
    port=9094
    log.dir=/home/luo/qzd/kafka-logs-2
config/server-3.properties:
    broker.id=3
    port=9095
    log.dir=/home/luo/qzd/kafka-logs-3

 

循环上面的步骤

版权声明：本文为BigStupid原创文章，遵循 CC 4.0 BY-SA 版权协议，转载请附上原文出处链接和本声明。
本文链接：https://www.cnblogs.com/BigStupid/p/8378416.html