Spring for Apache Kafka（spring-kafka）项目将核心Spring概念应用于基于Kafka的消息传递解决方案的开发。
我正在创建一个消息处理器，它接收来自一个kafka主题的事件，处理它并将结果转发给另一个主题。我用@SendTo创建了一个@KafkaListener方法，效果很好......
使用spring boot kafka消费者客户端存储消费者抵消的理想方式是什么？
我有春天kafka消费者应用程序。该应用程序充当传递，从中轮询来自kafka代理的消息并发送到IBM MQ。存储...的最佳/简单方法是什么？
当我重新启动我的应用程序时，我需要处理Kafka中剩余的消息，直到它为空，然后我的应用程序应该继续正常工作。我的问题是如何检查Kafka是否为空。 ...
当我重新启动我的kafka经纪人时，为什么或如何丢失一些消息？
我在单节点中运行kafka，我希望在关闭我的kafka代理时看到kafka Producer行为然后我在几个secondes中重启我的代理，所以我创建spring boot projet我可能会...
如果kafka中不存在属性中的kafka主题名称，如何中断启动spring-boot应用程序？
我尝试在启动spring-boot应用程序上检查Kafka主题。我想抛出异常并中断启动。这是我的配置：@Slf4j @Configuration公共类KafkaTopicConfig实现...
Spring Boot Kafka Listener vs Consumer
有什么不同？ KafkaConsumer和KafkaListener一词可以互换使用吗？
我和kafka制作人有问题。其实我正在使用spring kafka，并通过KafkaTemplate发送消息：默认KafkaProducerFactory defaultKafkaProducerFactory = new ...
启动spring boot kafka项目时出错。 spring boot：2.1.2.RELEASE Spring kafka版本：2.2.5.RELEASE消费者无法配置自动提交ackMode MANUAL_IMMEDIATE ...
我有一个Kafka消费者，重试5次，我使用Spring Kafka重试模板。现在，如果所有重试都失败了，那么在这种情况下如何确认工作。如果我已设置确认...
我需要在包含以下组件的系统中应用事务：Kafka生产者，这是一些将在kafka主题上发布消息的外部应用程序。一个Kafka消费者，这......
Spring Kafka与Dynamic @KafkaListener
我正在使用带有spring-kafka的Spring Boot 2.x（而不是spring-integration-kafka）我有多个使用@KafkaListener注释的bean ...每个人都使用一个主题...所以因为我有12个主题然后.. 。
我正在使用spring-kafka 2.1.10.RELEASE。我有一个使用下一个属性的消费者（几乎复制了所有属性）：auto.commit.interval.ms = 5000 auto.offset.reset = earliest bootstrap.servers = ...
我的Spring-boot应用程序（消费者）处理来自Apache Kafka的消息。定期，按摩不能处理和消费者抛出异常。无论如何，消费者承诺抵消。我可以区分成功......
Spring @KafkaListener在一定的时间间隔后执行并轮询记录
我们希望在一定间隔（例如每5分钟）之后消耗记录。消费者属性是标准的：@Bean public KafkaListenerContainerFactory
我已将我的消费者配置为批量接受来自主题的消息。如何将其转发到新主题？我希望每条消费的消息都按照自己的消息进行转发。所以X消息量......
Spring Kafka属性用于设置SeekToCurrentBatchErrorHandler
是否有spring.kafka属性错误处理批处理spring.kafka.listener.type = BATCH和spring.kafka.listener.ack-mode = BATCH与SeekToCurrentBatchErrorHandler？提前致谢。
onPartitionsRevokedBeforeCommit vs onPartitionsRevokedAfterCommit
我正在写一个Kafka消费者并且为了学习目的，这次我想到了使用Spring-Kafka实现。直到现在，我正在使用Java API来编写消费者。我想管理......
Spring-Cloud-Stream-Kafka Custom Health检查不起作用
我在我的spring-boot（消费者）应用程序中使用spring-cloud-stream-kafka。应用程序的运行状况不准确，即使应用程序无法连接到Kafka（Kafka经纪人已关闭），也“UP”。我读过了 ...
我有一个使用spring-kafka的Spring启动项目。在这个项目中，我构建了一些事件驱动的组件来包装spring-kafka bean（即KafkaTemplate和ConcurrentKafkaListenerContainer）。一世 ...
我正在使用kafka制作人和Spring kafka消费者。我正在使用Json序列化器和反序列化器。每当我尝试从主题中读取消费者中的消息时，我会收到以下错误：org ....