用于与Apache Kafka使用者API相关的问题
如何设置NestJS微服务集成/e2e测试KafkaJS消费者（MessagePattern/EventPattern处理程序）
我正在验证与 NestJS/KafkaJS 的集成测试。 除了我要发送到的主题的事件监听器（消费者）上的函数没有被调用之外，我已经实现了所有内容。 我读过
Spring-Boot-Kafka：如何在java中设置主题配置
我正在将 Spring-Boot 与 Kafka 结合使用。 pom.xml 的部分 ... org.springframework.boot spring-boot-starter-parent...
消费者中的@KafkaHandler不会将主题消息作为对象类消费，而仅作为字符串消费
我有一个简单的 Java Spring Boot 应用程序，它应该将来自 Kafka 的主题消息作为对象类使用，但它只能作为字符串调用。仅调用了handleDefault..为什么？ @
我有一个主题“oranges”，有 10 个分区，1 个消费者组内有 2 个消费者。我正在使用 Spring Kafka。 由于某些原因，我需要时不时地重新读取数据，我需要重置
Spring Cloud Kafka Binder 设置指定消费者组的自动偏移重置不会更改默认值
我正在尝试从最新的可用偏移量中读取（没有为消费者组提交偏移量），所以我在属性中指定 spring.cloud.stream.bindings.process-in-0.group=测试组 spring.cloud.stream.
我正在使用kafka-python。我试图在 kafka_consumer 中定义消息以在后台运行异步。目前，在我看来，它是同步运行的，从而阻止了其他方法。 kafka-pyt 吗...
我正在为 Kafka 创建一个非常基本的消费者/生产者设置。我正在使用 Zookeper 和 Kafka 以及 Docker compose。两者似乎都有联系，但当涉及到生产或消费时，没有什么……
验证@KafkaListener在Kafka生产者发送到Spock后是否被调用
我有一个带有 @KafkaListener 的 Spring 消费者： @服务 @Slf4j 公共类事件监听器{ @KafkaListener(topics = "主题", groupId = "组id") 公共无效消费者（
我有一个 Spring Boot 应用程序，其侦听器如下： @KafkaListener(id = "演示", 主题 = "演示", containerFactory =“重试KafkaListenerContainerFactory”） 公共空间
我正在每半小时运行一次的服务中调用该课程。我只想从主题列表中获取最后一条消息。 但随机我没有得到最新的记录。相反，它显示了
我是卡夫卡新手。并对 kafka 及其配置有了基本的了解。 我的问题是： 如果消费者应用程序在消费者组中有2个消费者。现在，如果我自动缩放（增加）pod，
当自动提交设置为 false 时，Kafka 监听器开始消费消息时如何重新传递消息
假设我启动消费者时将自动提交设置为 false 并且消费者开始监听消息。 我的监听器处理了 50 条消息，轮询总数为 100 条，然后只处理了 50 条......
大家 我是卡夫卡的新手。我正在为一个 python 模块编写代码，该模块将处理来自 Kafka 的消息。该模块将使用 docker 进行容器化。该模块将读取 Kafka 消息，执行一些操作
卡夫卡版本：0.9 我们有一个 Java 应用程序尝试从 Kafka 读取数据。但我们看到 kafka 消息中的数据损坏 以下是 Java 应用程序的错误： org.apache.kafka.common.
如何实现ReplyingKafkaTemplate而不使用@KafkaListener和@SendTo发送响应到回复主题
美好的一天。 我正在尝试使用 ReplyingKafkaTemplate 实现同步请求回复消息流。作为个人 POC，它运行良好。但我的应用程序已经实现了 kafka 来消费
Kafka Consumer 第一次 poll(0) 没有返回数据
我正在使用 confluence-kafka-client。我有一个生产者生产一个主题，其中一个分区和一个组 ID 内有一个消费者。首先，我为该主题创建一个生产者（使用默认配置）...
引起：org.apache.common.config.ConfigException：bootstrap.server 中没有给出可解析的引导 URL 当我在配置中添加此内容时： @配置 类主题配置{ 公关...
Golang Segmentio 在消费者组迁移时获取半分区
我正在使用 github.com/segmentio/kafka-go lib。 我的服务托管在 Kubernetes 集群上，我的用例是，我有一个消费者组 C1，它正在使用来自主题 T1 的消息，该主题有 70
组 ID 未注册的应用程序信息 kafka.consumer
我在使用 Spring Cloud Stream 的 Kafka 消费者服务的日志中多次看到这个特定的日志“App info kafka.consumer for group-id unregistered”。我无法理解...
我在卡夫卡消费者端遇到了下面的异常。令人惊讶的是，这个问题与旧版本的代码不一致（具有完全相同的配置，但有一些新的不相关...