Java优学网SpringBoot整合Kafka教程：快速实现高效消息队列，让开发更轻松

spring: kafka:

producer:
  bootstrap-servers: localhost:9092
  key-serializer: org.apache.kafka.common.serialization.StringSerializer
  value-serializer: org.apache.kafka.common.serialization.StringSerializer
  acks: all
  retries: 3
  batch-size: 16384
  linger-ms: 1

@Service public class MessageProducer {

@Autowired
private KafkaTemplate<String, String> kafkaTemplate;

public void sendMessage(String topic, String message) {
    kafkaTemplate.send(topic, message);
}

// 发送带键的消息，相同键的消息会被路由到同一个分区
public void sendMessageWithKey(String topic, String key, String message) {
    kafkaTemplate.send(topic, key, message);
}

}