Spring for Apache Kafka（spring-kafka）项目将核心Spring概念应用于基于Kafka的消息传递解决方案的开发。
也许这是一个初学者的问题，但是读取KSQL中生成的数据的推荐方法是什么？我们假设我做了一些流处理并将数据写入KSQL表。现在我想访问这个...
org.apache.kafka.common.KafkaException：无法构造kafka使用者
我手动启动Zookeeper，然后是Kafka服务器，最后是Kafka-Rest服务器及其各自的属性文件。接下来，我在tomcat上部署我的Spring Boot应用程序在Tomcat中......
如何从Spring Cloud Stream中的producer.send（）发送的异常中恢复
我们遇到了以下情况：我们有一个由3个节点组成的Kafka集群，每个创建的主题都有3个分区。消息通过MessageChannel.send（）发送，生成一条记录，让我们...
TLDR：我希望能够在同一主题中的其他人之前处理一些紧急消息。更多解释：我正在开发一个相当大的应用程序，使用许多弹簧微服务依赖...
有没有办法使用log4j记录日志中的所有spring-kafka配置？我尝试在我的应用程序log4j2.yml中使用以下记录器配置，我可以看到所有信息和调试日志，但是......
在Spring-Kafka中哪个方法和onPartitionsRevoked一样？
我知道在Sping-Kafka中我们有以下方法：void registerSeekCallback（ConsumerSeekCallback callback）; void onPartitionsAssigned（Map assignment，ConsumerSeekCallback callback）;无效......
下面有一个类似的问题：一个Spring的KafkaConsumer监听器可以监听多个主题吗？所以我现在明白我可以为主题参数提供一个字符串数组...
在消费者spring.kafka.consumer.group-id指定组与@KafkaListener指定的组有什么区别？ @KafkaListener（topic =“test”，group =“test-grp”）
Spring Integration Kafka ClassNotFoundException：KafkaHeaderMapper
在使用spring-integration-kafka库运行Spring Boot应用程序时，我收到以下错误：引起：java.lang.ClassNotFoundException：org.springframework.kafka.support ....
有人可以解释使用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 ....