/springboot-kafka

springboot集成kafka

Primary LanguageJava

1.下载kafka安装包、并安装:

下载地址:http://kafka.apache.org/

    
安装:
tar -zxvf kafka_2.11-0.11.0.0.tgz

2.修改kafka配置文件 server.properties 加入如下配置:

listeners=PLAINTEXT://192.168.0.195:9092      #使其他主机访问
auto.create.topics.enable = true       #自动创建topic

3.开启9092端口,使外部可以访问。

4.启动kafka:

cd kafka_2.11-0.11.0.0
bin/zookeeper-server-start.sh config/zookeeper.properties &  # 先启动zookeeper
bin/kafka-server-start.sh config/server.properties & # 启动kafka服务

5.打开项目选择KafkaApplication并运行。