主页 / 问题 / 1587448
Accepted
alex_us
Asked:2024-07-18 00:09:17 +0000 UTC2024-07-18 00:09:17 +0000 UTC

如何正确从Java Springboot向Kafka发送消息？

  • 772

问题是这样的。当我调用该服务时，我会收到响应正文。我需要将其发送到现有的 Kafka 主题。到目前为止，我只遇到过创建生产者类的示例，其中我需要定义与要发送到 Kafka 主题的消息相对应的所有字段。但就我而言，它大约有一百个字段，具有不同程度的嵌套。我可以以某种方式只获取响应正文并将 Kafka 主题作为字符串发送，而不创建任何其他类吗？

目前 application.yml 看起来像这样：

  events:
    enabled: true
    kafka.url: ......
    produces:
      - package bft.com.needy_registry.kafka.events.FamilyRequestScmzToRpuEvent
    kafka:
      idempotency-enabled: false

我可以不在 application.yml 中定义 Produce 字段，而只向所需主题发送消息吗？

java

1 个回答

  1. Best Answer

    首先你需要定义几个bean

    @Bean
public ProducerFactory<UUID, String> producerFactory() {
    return new DefaultKafkaProducerFactory<>(
        properties.buildProducerProperties(),
        new UUIDSerializer(),
        new StringSerializer()
    );
}

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

    然后将模板注入到正确的位置

    @Qualifier("kafkaTemplate")
private final KafkaTemplate<UUID, Strin> kafkaTemplate;

    并发送消息

        List<Header> headers = new ArrayList<>();
    ProducerRecord<UUID, String> record = new ProducerRecord<>(topicName, null, messageId, message, headers);
    kafkaTemplate.send(record);
    • 0

相关问题