Spring Kafka-收到相同消息的多个消费者
我正在使用Spring Kafka来消费Kafka的消息。消费者听众如下。 @KafkaListener(topics = "topicName", groupId = "groupId", containerFactory = "kafk…
kafkatemplate生产商发送回调onfailure未调用异常
因此，我正在测试生产者的弹性，我有要将其发送到Kafka（以JSON格式）发送的对象，然后根据结果，它将更新我的数据库。 OnSuccess回调非常有效，但是O…
春季集成kafka侦听器线程读取多个分区时，当并发=分区计数
我设置了一个弹簧集成流，以处理一个具有3个分区的主题，并将侦听器容器的并发设置为3。但是，我看到在某些情况下，其中一个侦听器线程可能会处理包含…
Spring-Kafka异常处理具有手动确认模式
经过大量的努力和研究Kafka例外处理，在Spring Boot应用程序中进行了处理，我在这里寻求帮助。 我正在使用Spring Boot版本2.5.9。要求是处理Spring Ka…
Spring Cloud流 - 无法应对 - 无法解决类名称。找不到课
应用程序A将用户对象下方的KAFKA主题写入（JSON）： public class UserEvent { private UUID id; private Object payload; // contains User fields n…
contractverifiermessaging.receive为无效
我正在用 spring-cloud-contract-samples/producer_kafka_middleware/。与嵌入式kafka一起工作，但不能与测试范围内的kafka一起使用。 当我尝试运行生…
Spring-kafka用@refreshscope注释启动另一个容器
我将我的Spring-Kafka消费者与Spring-Cloud集成在一起。这是基本上具有 @kafkalistener 的bean @ConditionalOnMissingBean @Bean @RefreshScope SinkG…
带有cogroup和过滤的多个输入上的kafka-stream聚合
我正在尝试在多（4）个输入主题上实现KAFKA-Stream聚合。 让我们的话题是：a，b，c，d; 拓扑应该： 从A和B中摘下2封单一消息，应用聚合，应用过滤器，…
SyncGroup失败了：小组开始了另一个重新平衡。需要重新加入该组 - Kubernetes的Kafka消费者组中的错误
我正在使用Java编写的kafka消费者组（10个实例），该应用程序使用Spring Cloud流。消费者应用程序部署在AWS Kubernetes群集中。消费者配置使用的是默…
有没有办法订购@kafkalistener方法的执行？
目前，我有2种@kafkalistener方法，可以从两个不同的主题中消费事件。问题是我需要“让”其中一个首先执行，然后始终执行，然后再执行第二个。我尝试…
Spring Kafka Messagelistener和Max.poll.Records
我正在使用Spring Kafka 2.7.8来消费Kafka的消息。 消费者听众在上面 @KafkaListener(topics = "topicName", groupId = "groupId", containerFactory …
带有DSL Kafka的Kafka嵌入式服务器。
我正在使用Kafka消息驱动的通道适配器来阅读KAFKA主题的消息。它可以正常工作，但是当我使用嵌入式Kafka经纪人进行集成测试时，它不起作用，也不听取…
在kafka听众中睡觉
我正在尝试暂停/恢复Kafka容器。使用以下代码段这样做： kafkaListenerEndpointRegistry.getListenerContainer("MAIN").pause(); 当我呼叫暂停时，我…
Spring Kafka错误将Spring Boot升级到2.6.6之后
在将Spring Boot版本从2.4.0升级到2.6.6（和Spring Cloud版本2021.0.2）之后，我将面临运行时错误。我的应用程序会消耗来自Kafka主题的消息，并在进行…
