springboot自带的kafka配置参数
时间: 2023-07-25 20:49:19 浏览: 154
详解Spring Kafka中关于Kafka的配置参数
Spring Boot提供了以下Kafka配置参数:
1. spring.kafka.bootstrap-servers:Kafka集群的地址列表,用逗号分隔。
2. spring.kafka.client-id:Kafka客户端ID,默认为空。
3. spring.kafka.consumer.auto-commit-interval:自动提交偏移量的时间间隔(毫秒)。默认值为5000。
4. spring.kafka.consumer.auto-offset-reset:当服务器上没有初始偏移量或当前偏移量不可用时,应该从哪里开始消费。可选值为latest(从最新记录开始消费)或earliest(从最早的记录开始消费)。默认为latest。
5. spring.kafka.consumer.enable-auto-commit:是否启用自动提交偏移量。默认为true。
6. spring.kafka.consumer.fetch-max-wait:等待从Kafka获取消息的最长时间(毫秒)。默认为500。
7. spring.kafka.consumer.group-id:这个消费者所属的消费者组ID。
8. spring.kafka.consumer.key-deserializer:键的反序列化程序类。
9. spring.kafka.consumer.value-deserializer:值的反序列化程序类。
10. spring.kafka.listener.concurrency:侦听器容器的并发性级别。默认为1。
11. spring.kafka.producer.acks:producer期望从broker收到的确认数。可选值为0(不需要确认),1(需要确认leader),all(需要确认所有副本)。默认为1。
12. spring.kafka.producer.batch-size:单个批次的大小(字节)。默认为16384。
13. spring.kafka.producer.bootstrap-servers:Kafka集群的地址列表,用逗号分隔。
14. spring.kafka.producer.buffer-memory:生产者可以使用的总内存字节来缓冲消息。默认为33554432。
15. spring.kafka.producer.compression-type:消息压缩类型(gzip,snappy或lz4)。默认为none。
16. spring.kafka.producer.key-serializer:键的序列化程序类。
17. spring.kafka.producer.retries:在抛出异常之前重试发送消息的次数。默认为0。
18. spring.kafka.producer.value-serializer:值的序列化程序类。
阅读全文