我使用 spring boot 版本 2.5.3、spring-cloud-stream-binder-kafka-stream 版本 3.1.3 和 kafka-clients 版本 2.8.0。我...

在弹簧上下文中作为单例连接是正确的方法，还是我可以使用原型范围？org.springframework.kafka.core.KafkaTemplate 单例示例： @Slf4j @Require...

我正在尝试使用 Kafka 发送一些信息。我有一个类来处理这个任务。该类包括一个名为“timestamp”的私有变量，类型为 Instant。生成时间戳后，它会正确呈现。但是，当我在消费者端收到消息时...

您好，我有一个使用 Spring Boot 的批处理，其中有一个在处理期间注释的 kafka 消费者有一个静态布尔值，在运行过程中采用不同的值 如果为 true，我想暂停我的 consommer，并在...

我创建了 kafka 侦听器，设置为 .ACK modeMANUAL_IMMEDIATE 我正在使用 DefaultErrorHandler 和 DeadLetterPublishingRecove...

我正在使用弹簧卡夫卡，我有一个问题。 Spring Kafka 版本为 2.6.X。 我将自动提交设置设置为 false。 此时，使用消息的使用者强制犯了错误。 正如我所料，提交不是手动完成的，因此...

我在 thransaction 中按限制从 DB 项目列表中进行选择（一次选择 10 个项目），然后必须将它们全部发送到 kafka 并在同一事务中从数据库中删除所有项目。select for upd...

我正在使用 spring kafka 批处理侦听器。为了处理异常，我抛出带有失败消息索引的 BatchListenerFailedException。在 kafka config 类中，我添加了这个逻...

我是 Kafka 的新手，我正在尝试读取一个文本文件并创建一个我想发送给消费者的字符串列表。我正在使用 Java 21 和 Spring Boot 3.2.0 （SNAPSHOT）。 这是 Kafk...

在 Spring Kafka 中，我有两个 Kafka 听众在听同一个主题。我希望两个侦听器都有自己的重试和死信主题，因此如果一个侦听器发生故障，它不会重播给另一个侦听器。使用以下配置，它们最终都将使...