spring-kafka
-
使用Spring Embedded Kafka测试@KafkaListener 我正在尝试为我正在使用Spring Boot 2.x开发的Kafka听器编写一个单元测试。作为一个单元测试,我不想启动一个完整的Kafka服务器作为Zookeeper的实例。所以,我决定使用Spring Embedded Kafka。 我的听众
-
如何编写 Kafka 使用者 - 单线程与多线程 我写了一个单一的Kafka消费者(使用Spring Kafka),它从一个主题阅读,并且是消费者群体的一部分。使用消息后,它将执行所有下游操作并转到下一个消息偏移。我已将其打包为 WAR 文件,我的部
-
在春季卡夫卡中,我是否需要将@EnableKafka注释添加到我的应用程序中? 我看到有些人在他们的弹簧靴应用程序中添加了@EnableKafka,我想知道为什么。我有一个有效的弹簧靴卡夫卡生产者和消费者,我没有使用@EnableKafka。那么,为什么人们需要明确地添加它呢? 谢
-
Kafka 使用者异常和偏移量提交 我一直在尝试为Spring Kafka做一些POC工作。具体来说,我想尝试在Kafka中使用消息时处理错误的最佳实践。 我想知道是否有人能够帮助: 分享有关 Kafka 消费者在发生故障时应执行的操作的最佳
-
Dead Letter queue (DLQ) for Kafka with spring-kafka 在 Spring Boot 2.0 应用程序中实现死信队列 (DLQ) 概念的最佳方法是什么,使用 spring-kafka 2.1.x 将所有失败的消息发送到 @KafkaListener某个预定义的 Kafka DLQ 主题,而不会丢失单个消息? 所以消耗的
-
春季卡夫卡 - 如何使用组ID将偏移量重置为最新? 我目前正在使用Spring Integration Kafka进行实时统计。但是,组名使Kafka搜索侦听器未读取的所有先前值。 我想开始最新的偏移量,而不是被旧值所困扰。是否可以重置组的偏移量?
-
春季卡夫卡集成测试写入高水位线文件时出错 我正在使用spring-kaka-2.2.0在spring boot应用程序中编写集成测试,我几乎成功了,我的测试用例仍然返回true,但之后我仍然看到多个错误。
-
如何从 kafka 主题按键获取消息 我尝试通过密钥从kafka获取消息。我发现唯一的一个解决方案是使用StateStore,但我认为这可能不是一个好主意。如何从kafka主题按键获取消息?使用 StateStore 进行此操作是一个好主意吗?
-
何时使用 ConcurrentKafkaListenerContainerFactory? 我是kafka的新手,我浏览了,但我什么也听不懂。有人可以解释一下何时使用这个类吗?我已经使用了该类,但我看到在我当前的项目中被使用。请解释它的作用。
-
Kafka 错误反序列化分区的键/值 我有一个集成测试,当我发送到没有键的Kafka主题时,该测试会通过。但是,当我添加一个键时,我开始收到序列化错误。 与往常一样,任何帮助将不胜感激。 所有要重现的代码均可在
标签