赞
踩
1.pom引入依赖
<dependency>
<groupId>org.springframework.kafka</groupId>
<artifactId>spring-kafka</artifactId>
</dependency>
2.yml文件增加配置
spring: kafka: bootstrap-servers: localhost:9092 producer: # 重试次数 retries: 0 # 应答级别:多少个分区副本备份完成时向生产者发送ack确认(可选0、1、all/-1) acks: 1 # 批量大小 batch-size: 16384 # 生产端缓冲区大小 buffer-memory: 33554432 key-serializer: org.apache.kafka.common.serialization.StringSerializer value-serializer: org.apache.kafka.common.serialization.StringSerializer properties: max.request.size: 5242880 consumer: # 默认消费者组 group-id: test # 最早未被消费的offset auto-offset-reset: earliest enable-auto-commit: true # 批量一次最大拉取数据量 # max-poll-records: 1000 # 自动确认offset的时间间隔 auto-commit-interval: 1000 # key的序列化类 key-deserializer: org.apache.kafka.common.serialization.StringDeserializer # value的序列化类 value-deserializer: org.apache.kafka.common.serialization.StringDeserializer # 消费监听接口监听的主题不存在时 listener: missing-topics-fatal:
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。