Spring for Apache Kafka（spring-kafka）项目将核心Spring概念应用于基于Kafka的消息传递解决方案的开发。
有人可以解释使用NonResponsiveConsumerEvent spring-kafka事件看到的行为吗？
我正在我的spring-kafka（版本2.0.1）消费者中收听NonResponsiveConsumerEvent事件 - @EventListener public void eventHandler（NonResponsiveConsumerEvent event）{LOG.info（...
ConcurrentMessageListenerContainer不是并发的
我正在尝试创建一个多线程侦听器，但所有消息都在同一个线程中执行。运行时，线程ID始终相同，即使KafkaListerContainerFactory是（...
带有spring-kafka 2.1.0和SpringBoot 1.5.9的Kafka Consumer上的java.lang.NoSuchMethodError
我正在尝试使用SpringBoot（1.5.9）和Spring-kafka（2.1.0）来设置Kafka Consumer。但是，当我启动我的应用程序时，我得到java.lang.NoSuchMethodError：org.springframework.util.Assert.state（ZLjava / util / ...
Spring-Kafka Consumer KafkaListener无法将GenericMessage转换为Java Object
我通过在Centos7实例上的Confluent-3.3.0平台上运行的kafka-rest服务发布一些自定义Java类型'InventoryEvent'的事件，使用以下两个步骤：命令POST POST JSON ...
在使用自动配置时，如何为Spring Kafka设置自定义使用者任务执行程序？
在org.springframework.kafka.listener.KafkaMessageListenerContainer的第226-230行中，Spring Kafka将默认的SimpleAsyncTaskExecutor指定为侦听器容器的使用者任务执行器：if ...
我已经将ConcurrentMessageListenerContainer配置为3并发消耗3个分区，还有kafkaTemplate和producerFactory生成消息到3个分区。春豆......
我正在尝试实现一个基于Spring Boot的Kafka消费者，它具有一些非常强大的消息传递保证，即使在出现错误的情况下也是如此。如果......，必须按顺序处理来自分区的消息
我们在我们的应用程序中使用kafka，我们发送了太多的消息，每条消息的大小都很小，我的意思是消息大小不是问题，如果你试图发布太多很多就是他们的问题...
我一直试图停止并启动SubscribableChannel的订阅者，但似乎无法获取用于调用unsubscribe函数的MessageHandler。使用默认的自动装配...
在Spring Kafka Consumer Unit Test中没有调用MessageListner的onMessage
我正在编写Kafka Consumer Unit Test，需要模拟我的KafkaConsumer的服务，以独立测试Kafka Consumer。但是，不会调用服务的mockObject，而是......
如何将spring.cloud.stream.kafka.bindings配置属性应用于所有使用者
我可以使用application.properties中的以下属性为单个通道应用partition.assignment.strategy：spring.cloud.stream.kafka.bindings.input.consumer.configuration.partition ....
可能是什么原因，卡夫卡消费者承认，抛出InterruptedException？
这是来自KafkaMessageListenerContainer的代码，在什么情况下它们是InterruptedException的可能性，可以被这个代码抛出，突然在我的应用程序日志中，这正在消耗......
ListenerContainerIdleEvent被触发的次数需要一些解释吗？
这个问题与此有关。我有1个消费者从1个主题和3个分区消费。我已经设置了idleEventInterval = 30secs。每隔30秒，我会得到以下日志消息。 12：12：51.517 [...
无法为Spring KafkaTemplate指定valueSerializer实例
我需要将自定义值序列化器设置为Spring的KafkaTemplate。值序列化器如下所示：JsonSerializer serializer = new JsonSerializer <>（...
我使用spring kafka连接到kafka并检查kafka服务器的状态，我正在使用org.apache.kafka.clients.admin.AdminClient。它在我当地工作正常但是当我部署时......
目前正在使用spring-boot 2.0.4 with spring-kafka 2.1.8.RELEASE。我想简化交换有点发送对象到kafka模板并使用json作为格式。一些消息......
我正在使用以下示例来使用 spring Kafka 消费者读取消息。我的用例要求每次生成一条消息时，听众每次都从头开始阅读。 @
我正在尝试使用spring-boot和spring嵌入式Kafka进行集成测试。我能够为Spring嵌入式Kafka服务器生成消息，但是服务类中的监听器不是测试监听器，而是...
Spring Kafka - 事务回滚后重试时，通过侦听器容器事务发布消息和提交记录偏移失败
我在Apache Kafka v2.0.1中使用spring-boot＆spring-kafka（请参阅pom.xml了解特定版本），并且在通过Listener Container使用事务时遇到了一个奇怪的问题。问题是......