mirror of
https://gitee.com/yudaocode/SpringBoot-Labs.git
synced 2026-09-10 01:07:39 +08:00
30 lines
1.1 KiB
Properties
30 lines
1.1 KiB
Properties
#============== kafka ===================
|
|
# 指定kafka 代理地址，可以多个
|
|
spring.kafka.bootstrap-servers=127.0.0.1:9092
|
|
|
|
#=============== provider =======================
|
|
|
|
spring.kafka.producer.retries=0
|
|
# 每次批量发送消息的数量
|
|
spring.kafka.producer.batch-size=16384
|
|
spring.kafka.producer.buffer-memory=33554432
|
|
|
|
# 指定消息key和消息体的编解码方式
|
|
spring.kafka.producer.key-serializer=org.apache.kafka.common.serialization.StringSerializer
|
|
spring.kafka.producer.value-serializer=org.apache.kafka.common.serialization.StringSerializer
|
|
|
|
#=============== consumer =======================
|
|
# 指定默认消费者group id
|
|
spring.kafka.consumer.group-id=test-consumer-group6
|
|
|
|
spring.kafka.listener.concurrency=10
|
|
|
|
spring.kafka.consumer.auto-offset-reset=earliest
|
|
spring.kafka.consumer.enable-auto-commit=true
|
|
spring.kafka.consumer.auto-commit-interval=100
|
|
enable.auto.commit=false
|
|
|
|
# 指定消息key和消息体的编解码方式
|
|
spring.kafka.consumer.key-deserializer=org.apache.kafka.common.serialization.StringDeserializer
|
|
spring.kafka.consumer.value-deserializer=org.apache.kafka.common.serialization.StringDeserializer
|