《kafka》专题
-
没有Spring boot的Spring Kafka消费者不消费消息
消费者使用Spring的JavaConfig类如下： Kafka主题侦听器使用@KafkaListener注释，如下所示： 我的pom包括依赖项： 现在当我打包到war并部署到tomcat时，它不会显示任何错误，即使在调试模式下也不会显示任何错误，只是部署war什么都没有。 请帮助我了解是否缺少触发kafkalistner的某些配置。 谢谢Gary我添加了上下文。xml和web。xml，但我得到了
-
Apache Kafka的Spring Boot：未读取消息
我目前正在使用Kafka listener设置Spring Boot应用程序。我试图只对消费者进行编码。对于producer，我现在正在从Kafka控制台手动发送消息。我举了一个例子：http://www.source4code.info/2016/09/spring-kafka-consumer-producer-example.html 我尝试将其作为Spring Boot应用程序运行，但无法
-
如何在反应器kafka中重试失败的消费者记录
我正在尝试使用reamer-kafka来消耗消息。其他一切都很好，但我想为失败的消息添加重试（2）。spring-kafka已经默认重试失败记录3次，我想使用reamer-kafka实现相同。 我用SpringKafka作为反应Kafka的包装。以下是我的消费者模板： 让我们考虑消耗方法如下 我使用以下逻辑在失败时重试消耗方法。 如果当前消费者记录异常失败，我想重试使用该消息。我试图用另一次重试（
-
使用Spring Kafka从相同的Kafka主题反序列化不同的JSON有效负载
我正在尝试从同一个Kafka主题反序列化不同的JSON有效负载。这里问的其他问题引导我进行了第一次尝试，但我无法让它运行。 正如Gary所提到的（这里），有一些提示（JsonSerializer.ADD\u TYPE\u INFO\u HEADERS），但当我发送和接收这两条消息时，我会收到一个异常。 ... LoggingErrorHandler在ConsumerRecord中已经提到了一个（正
-
@Kafkalistener的序列化
我使用的是spring-boot 2.3.2。使用spring-kafka->2.5.4发布。release kafka-clients->2.5.0 我有以下简单的监听器 null 如果我使用 然后它就会失败，不再有异常循环
-
将ObjectMapper注入Spring Kafka序列化/反序列化程序
我使用的是Spring Kafka 1.1.2-Spring Boot 1.5.0 RC版本，并且配置了一个自定义值serialiser/Deserialiser类，扩展/。这些类确实使用Jackson ObjectMapper，它可以通过构造函数提供。 是否可以从Spring上下文中注入ObjectMapper？我已经配置了一个ObjectMapper，我希望在序列化/反序列化程序中重用它。
-
仅当某些条件为真时才使用来自Kafka的消息
null 当应用程序正在消费消息时，但随后consumeEnabled变成false的情况就没有必要考虑了。 请定义用Spring Kafka和\或Kafka Java客户机实现决策的最佳方式
-
再次使用来自kafka日志压缩主题的消息
我有一个带有Kafka使用者的spring应用程序，它使用@KafKalisterner注释。正在使用的主题是日志压缩的，我们可能会遇到必须再次使用主题消息的情况。以编程方式实现这一目标的最佳方法是什么？我们不控制Kafka主题配置。
-
使Kafka使用者在订阅前消费现有消息
拥有发布者和N个消费者，如果消费者使用，那么他们将错过订阅主题之前发布到主题的所有消息...众所周知，使用的消费者不会重播订阅主题之前存在的消息... 所以我需要： null 我想使用者必须检查现有消息的主题，如果有消息就使用它们，然后启动使用。对我来说这是最好的方法...
-
通过忽略所有现有消息，开始只使用来自Kafka主题的最新消息
如何通过忽略主题中所有现有的消息来只使用来自Kafka主题的最新消息。我有两个相同主题的使用者，当我开始使用来自该主题的消息时，它会获取最早的消息。我需要在我的使用者启动后使用消息。我在消费者配置中尝试了此配置，但这不起作用。
-
Kafka客户线程，任务，分区？
我有一个有3台机器的Kafka集群。和一个有6个分区（每台机器2个分区）的主题。当我启动一个有6个使用者线程并且属于一个组的使用者应用程序时。我知道一个使用者线程将被分配一个分区。我想知道的是：使用者线程的任务将在分区所在的机器上运行？或者将运行在应用程序被SRARD的机器上？
-
未找到Spring Cloud Stream Kafka-Serde类：org。阿帕奇。Kafka。常见的序列化。Serde$StringSerde
我正在尝试使用Spring Cloud Stream框架构建一个简单的Kafka Streams应用程序。我可以连接到流以推送原始数据进行处理。但是当我尝试按键处理流进行事件计数时，我得到了未找到的运行应用程序时异常。我检查了我的项目包含的库，我可以找到类，它没有丢失。我不确定为什么在运行时它没有被加载！ 下面是我的源文件。 <代码>com。pgp。学Kafka。分析。分析应用程序 <代码>com
-
如何在Spring Kafka Stream中配置UncaughtExceptionHandler
我正在使用spring kafka来实现一个使用spring Boot 1.5.16的流应用程序。我们使用的SpringKafka版本是1.3.8。释放。 我正在搜索一种方法，以便在出现终止与Kafka流关联的所有线程的错误时关闭启动应用程序。我发现在KafkaStreams中，有可能为未捕获的异常注册句柄。方法是setGlobalStateRestoreListener。 我看到这个方法在类型k
-
Spring云总线和Spring for Apache Kafka有什么区别？
使用Spring for Apache Kafka或Spring AMQP，我可以实现消息发布/订阅。Spring云总线使用Kafka/rabbitmq来完成大致相同的事情，它们之间的区别是什么？
-
使用Spring访问Kafka Stream State Store
参考本文档的4.2.6https://docs.spring.io/spring-kafka/reference/htmlsingle/#kafka-streams 如何使用kafka stream spring支持访问州立商店？ 没有Spring你还能做什么？ 但我不知道如何才能接触到Kafka斯特雷姆的目标。