## 一、引入依赖 ``` <dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-clients</artifactId> <version>1.0.0</version> </dependency> ``` ## 二、配置 ``` # 指定kafka 代理地址，可以多个 spring.kafka.bootstrap-servers=localhost:9092 spring.kafka.producer.retries=0 设置大于0的值，则客户端会将发送失败的记录重新发送 # 每次批量发送消息的数量 spring.kafka.producer.batch-size=16384 spring.kafka.producer.buffer-memory=33554432 # 指定消息key和消息体的编解码方式 UTF-8 spring.kafka.producer.key-serializer=org.apache.kafka.common.serialization.StringSerializer spring.kafka.producer.value-serializer=org.apache.kafka.common.serialization.StringSerializer ```