spring-kafka 相关问题

Spring for Apache Kafka（spring-kafka）项目将核心Spring概念应用于基于Kafka的消息传递解决方案的开发。

我正在尝试创建一个多线程侦听器，但所有消息都在同一个线程中执行。运行时，线程ID始终相同，即使KafkaListerContainerFactory是（...

spring-boot apache-kafka spring-kafka

回答 1 投票 1

带有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

回答 1 投票 10

Spring-Kafka Consumer KafkaListener无法将GenericMessage转换为Java Object

我通过在Centos7实例上的Confluent-3.3.0平台上运行的kafka-rest服务发布一些自定义Java类型'InventoryEvent'的事件，使用以下两个步骤：命令POST POST JSON ...

spring-boot apache-kafka spring-amqp spring-kafka

回答 1 投票 1

在使用自动配置时，如何为Spring Kafka设置自定义使用者任务执行程序？

在org.springframework.kafka.listener.KafkaMessageListenerContainer的第226-230行中，Spring Kafka将默认的SimpleAsyncTaskExecutor指定为侦听器容器的使用者任务执行器：if ...

spring-boot spring-kafka

回答 1 投票 0

Spring Kafka没有正常关闭

我已经将ConcurrentMessageListenerContainer配置为3并发消耗3个分区，还有kafkaTemplate和producerFactory生成消息到3个分区。春豆......

apache-kafka spring-kafka

回答 1 投票 2

使用spring-kafka保证消息顺序的指数退避

我正在尝试实现一个基于Spring Boot的Kafka消费者，它具有一些非常强大的消息传递保证，即使在出现错误的情况下也是如此。如果......，必须按顺序处理来自分区的消息

apache-kafka messaging spring-kafka spring-retry exponential-backoff

回答 1 投票 6

随机有效消息的Kafka消息发布失败，如何解决这个问题？

我们在我们的应用程序中使用kafka，我们发送了太多的消息，每条消息的大小都很小，我的意思是消息大小不是问题，如果你试图发布太多很多就是他们的问题...

apache-kafka kafka-producer-api spring-kafka jms-topic

回答 1 投票 1

在API调用上停止和启动订阅者

我一直试图停止并启动SubscribableChannel的订阅者，但似乎无法获取用于调用unsubscribe函数的MessageHandler。使用默认的自动装配...

spring-cloud-stream spring-kafka

回答 2 投票 0

在Spring Kafka Consumer Unit Test中没有调用MessageListner的onMessage

我正在编写Kafka Consumer Unit Test，需要模拟我的KafkaConsumer的服务，以独立测试Kafka Consumer。但是，不会调用服务的mockObject，而是......

spring-boot mockito spring-kafka

回答 1 投票 0

如何将spring.cloud.stream.kafka.bindings配置属性应用于所有使用者

我可以使用application.properties中的以下属性为单个通道应用partition.assignment.strategy：spring.cloud.stream.kafka.bindings.input.consumer.configuration.partition ....

java spring spring-boot spring-cloud spring-kafka

回答 1 投票 2

可能是什么原因，卡夫卡消费者承认，抛出InterruptedException？

这是来自KafkaMessageListenerContainer的代码，在什么情况下它们是InterruptedException的可能性，可以被这个代码抛出，突然在我的应用程序日志中，这正在消耗......

apache-kafka kafka-consumer-api spring-kafka

回答 1 投票 0

ListenerContainerIdleEvent被触发的次数需要一些解释吗？

这个问题与此有关。我有1个消费者从1个主题和3个分区消费。我已经设置了idleEventInterval = 30secs。每隔30秒，我会得到以下日志消息。 12：12：51.517 [...

spring-kafka

回答 1 投票 -1

无法为Spring KafkaTemplate指定valueSerializer实例

我需要将自定义值序列化器设置为Spring的KafkaTemplate。值序列化器如下所示：JsonSerializer serializer = new JsonSerializer <>（...

java spring apache-kafka spring-kafka

回答 1 投票 0

kafka AdminClient无法在已部署的环境中工作

我使用spring kafka连接到kafka并检查kafka服务器的状态，我正在使用org.apache.kafka.clients.admin.AdminClient。它在我当地工作正常但是当我部署时......

apache-kafka spring-kafka

回答 1 投票 0

spring boot-kafka java 8次序列化

目前正在使用spring-boot 2.0.4 with spring-kafka 2.1.8.RELEASE。我想简化交换有点发送对象到kafka模板并使用json作为格式。一些消息......

spring-boot spring-kafka

回答 1 投票 2

@KafkaListener 每次都从头读

我正在使用以下示例来使用 spring Kafka 消费者读取消息。我的用例要求每次生成一条消息时，听众每次都从头开始阅读。 @

spring apache-kafka spring-kafka

回答 5 投票 0

春天Kafka集成测试听众不工作

我正在尝试使用spring-boot和spring嵌入式Kafka进行集成测试。我能够为Spring嵌入式Kafka服务器生成消息，但是服务类中的监听器不是测试监听器，而是...

java spring-boot spring-kafka spring-kafka-test

回答 1 投票 0

Spring Kafka - 事务回滚后重试时，通过侦听器容器事务发布消息和提交记录偏移失败

我在Apache Kafka v2.0.1中使用spring-boot＆spring-kafka（请参阅pom.xml了解特定版本），并且在通过Listener Container使用事务时遇到了一个奇怪的问题。问题是......

spring-boot spring-kafka

回答 1 投票 0

spring-kafka 相关问题

最新问题