kafka发送消息代码

在使用spring-kafka发送消息到Kafka时，可以使用以下代码实现：

1. 首先，需要在pom.xml文件中添加spring-kafka依赖：

   <dependency>
       <groupId>org.springframework.kafka</groupId>
       <artifactId>spring-kafka</artifactId>
       <version>2.3.7.RELEASE</version>
   </dependency>

2. 在Spring Boot的配置类中，配置Kafka的相关信息，例如Kafka的地址和端口号：

   @Configuration
   @EnableKafka
   public class KafkaConfig {

       @Value("${spring.kafka.bootstrap-servers}")
       private String bootstrapServers;

       @Bean
       public ProducerFactory<String, String> producerFactory() {
           Map<String, Object> configProps = new HashMap<>();
           configProps.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers);
           configProps.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
           configProps.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
           return new DefaultKafkaProducerFactory<>(configProps);
       }

       @Bean
       public KafkaTemplate<String, String> kafkaTemplate() {
           return new KafkaTemplate<>(producerFactory());
       }
   }

3. 在需要发送消息的地方，使用KafkaTemplate发送消息：

   @Autowired
   private KafkaTemplate<String, String> kafkaTemplate;

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

以上是使用spring-kafka发送消息到Kafka的代码示例。根据你的具体需求，可以在代码中添加更多的配置和逻辑。