# springboot-kafka

**Repository Path**: yinxicheng/springboot-kafka

## Basic Information

- **Project Name**: springboot-kafka
- **Description**: springboot-kafka 集成demo
- **Primary Language**: Java
- **License**: Apache-2.0
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 3
- **Forks**: 0
- **Created**: 2021-12-08
- **Last Updated**: 2023-07-12

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

#安装kafka (注意远程连接kafka 需配置server.properties中 advertised.listeners 、listeners 对应ip地址=PLAINTEXT://192.168.3.133:9092)
https://blog.csdn.net/qq_34892981/article/details/110668529

#下载zookeeper  端口 2181 38397 8080
wget https://mirrors.tuna.tsinghua.edu.cn/apache/zookeeper/zookeeper-3.5.8/apache-zookeeper-3.5.8-bin.tar.gz
tar -zxvf apache-zookeeper-3.5.8-bin.tar.gz

##修改配置文件
cd /usr/local/src/apache-zookeeper-3.5.8-bin/conf
cp zoo_sample.cfg zoo.cfg


##启动测试
cd /usr/local/src/apache-zookeeper-3.5.8-bin/bin
//启动
./zkServer.sh start
//停止
./zkServer.sh stop


##配置server.properties
cd kafka_2.13-2.6.0

vi /usr/local/src/kafka_2.13-2.6.0/config/server.properties

advertised.listeners=PLAINTEXT://localhost:9092
//指定服务的端口
listeners=PLAINTEXT://localhost:9092
//dataDir是数据存放位置，默认是/tmp/kafka-logs
dataDir=xxxx
//这个是删除topic时才用得到的，如果不想删除topic，可以不加
 delete.topic.enable=true
server.properties中有两个listeners。 listeners：
启动kafka服务监听的ip和端口，可以监听内网ip和0.0.0.0(不能为外网ip)，
默认为java.net.InetAddress.getCanonicalHostName()获取的ip。advertised.listeners：生产者和消费者连接的地址，kafka会把该地址注册到zookeeper中，所以只能为除0.0.0.0之外的合法ip或域名 ，默认和listeners的配置一致




前端启动
bin/kafka-server-start.sh config/server.properties
后台启动
nohup bin/kafka-server-start.sh config/server.properties >> /dev/null &

#创建topic（2181必须是zookeeper的端口号）
bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic testJc
#创建生产者 (启动成功会阻塞 需要另外重新打开 可以在控制台输出生产者数据 消费者能及时消费)
–broker-list：数指定了所使用的broker（Broker：Kafka 集群包含一个或多个服务器，这种服务器被称为 broker）
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic testJc

#创建消费者
字段说明：–bootstrap-server 从kafka开始 新的消费者 使用的参数设置
from-beginning 读取历史未消费的数据
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic testJc --from-beginning
bin/kafka-console-consumer.sh --bootstrap-server 192.168.3.133:9092 --topic testJc --from-beginning