spring-kafka 相关问题

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

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

apache-kafka kafka-consumer-api spring-kafka

回答 1 投票 0

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

spring-kafka

回答 1 投票 -1

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

java spring apache-kafka spring-kafka

回答 1 投票 0

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

apache-kafka spring-kafka

回答 1 投票 0

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

spring-boot spring-kafka

回答 1 投票 2

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

spring apache-kafka spring-kafka

回答 5 投票 0

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

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

回答 1 投票 0

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

spring-boot spring-kafka

回答 1 投票 0