Kafka：SpringBoot配置文件基本配置 た 入场券 2024-03-25 23:29 24阅读 0赞 spring: kafka: bootstrap-servers: 192.168.25.129:9092,192.168.25.129:9092 producer: # 生产者配置 retries: 3 # 设置大于0的值，则客户端会将发送失败的记录重新发送 batch-size: 16384 #16K buffer-memory: 33554432 #32M acks: 1 # 指定消息key和消息体的编解码方式 key-serializer: org.apache.kafka.common.serialization.StringSerializer value-serializer: org.apache.kafka.common.serialization.StringSerializer consumer: enable-auto-commit: false # 关闭自动提交 auto-offset-reset: earliest # 当各分区下有已提交的offset时，从提交的offset开始消费；无提交的offset时，从头开始消费 key-deserializer: org.apache.kafka.common.serialization.StringDeserializer value-deserializer: org.apache.kafka.common.serialization.StringDeserializer listener: ack-mode: manual_immediate ###### **生产者重要参数列表** ###### ![f7e379f3d13ec900ad66d3660df0c2a6.png][] ![acdc11c58edfcb0f6c992f0865a7e46e.png][] ![4dbbb767d891d58c8bc94a5dfc447a73.png][] ![63a6df7b32da1d5f78137d88c476d257.png][] ###### **消费者重要参数** ###### ![50ec06148228fc6f530c70a24c9bce2b.png][] ![429d133f4137abe6ae9f4906eeca1f94.png][] ![b376ac129e1afe39556b385ffbca499f.png][] [f7e379f3d13ec900ad66d3660df0c2a6.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/25/108ec6f52bf2491a8674ece80127ab37.png [acdc11c58edfcb0f6c992f0865a7e46e.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/25/9010009a3a394c42af510a25f4f93818.png [4dbbb767d891d58c8bc94a5dfc447a73.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/25/7ca5954a28254626bb93c58284a46a85.png [63a6df7b32da1d5f78137d88c476d257.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/25/ec27d0323e1e40c8acfd2cca47dab551.png [50ec06148228fc6f530c70a24c9bce2b.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/25/431b2c37a06f4efc8279598e58fd246e.png [429d133f4137abe6ae9f4906eeca1f94.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/25/adb5dbac2607429693c6e028a6145bf7.png [b376ac129e1afe39556b385ffbca499f.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/25/bd68010e26634f3bbc0ad2c7824c4991.png
还没有评论，来说两句吧...