Kafka 2.11 基本配置

前置条件

/opt/kafka

1.zookeeper 配置

/opt/kafka/config/zookeeper.properties

添加：

initLimit=5

syncLimit=2

server.1=master1:2888:3888

server.2=slave1:2888:3888

2.kafka Server 配置

/opt/kafka/config/server.properties

第一台：【broker.id，hostname不能重复】

broker.id=1

port=9092

host.name=master1

zookeeper.connect=master1:2181,slave1:2181

__________________________________________

第二台

broker.id=2

port=9092

host.name=slave1

zookeeper.connect=master1:2181,slave1:2181

3.测试

3.1 启动zookeeper服务【所有服务器都执行】

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

3.2 启动kafka服务【所有服务器都执行】

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

3.3 创建主题：

bin/kafka-topics.sh --create --replication-factor 1 --partition 2--topic user-behavior-topic --zookeeper master1:2181,slave1:2181

3.4 生产消息：

bin/kafka-console-producer.sh --broker-list  master1:9092 --topic user-behavior-topic

3.5 消费消息：

bin/kafka-console-consumer.sh --zookeeper master1:2181 --topic user-behavior-topic --from-beginning