消费者有没有办法向使用Kafka（kafka.js）和node.js?
我相信这三种类型的确认由于生产者属性仅限于领导者和生产者，我希望生产者在消费者通过kafka broker消费来自存储/队列的消息时收到具体的消息。还请纠正我，如果我在制作人的“acks”属性上有错误，它的默认值是“-1”，它确认所有副本是否已接收/存储消息，但它是否与消费者有关，或者我们是否可以在消费者提交且Kafka向制作人发送确认时创建一个桥梁？
共有1个答案
消费者和生产者是独立的组件，在KafkaAPI中，两者之间没有现成的确认框架；你必须自己实现这一点
您对ACK的理解是正确的，但无法控制消费者行为，当消息可用时，消费者行为总是从leader分区读取
-
这是一个场景：我知道，使用与Spring kafka相关的最新API（如Spring集成kafka 2.10），我们可以执行以下操作： 以及来自与相同kafka主题相关的不同分区的读取。 我想知道我们是否可以使用同样的方法，例如spsping-集成-Kafka1.3.1 我没有找到任何关于如何做到这一点的提示（我对xml版本很感兴趣）。
-
我正在尝试使用Kafka-Python编写一个消费者，以确保精确的once语义。分区中的消息是使用事务感知生成器生成的。我从Kafka文档中了解到，我应该将指定为，这样它将只读取提交的消息。问题是，我在Python客户机的文档中没有看到关于如何指定的任何地方。关于如何让我的消费者只阅读提交的消息，有什么想法吗？ 预期结果：只需获取transation committed消息实际结果：使用者甚至读取
-
例如，分区有1-10的偏移量。我只想从3-8消费。在消耗了第8条消息后，程序应该退出。
-
消费者使用Spring的JavaConfig类如下： Kafka主题侦听器使用@KafkaListener注释，如下所示： 我的pom包括依赖项： 现在当我打包到war并部署到tomcat时，它不会显示任何错误，即使在调试模式下也不会显示任何错误，只是部署war什么都没有。 请帮助我了解是否缺少触发kafkalistner的某些配置。 谢谢Gary我添加了上下文。xml和web。xml，但我得到了
-
我有一个kafka主题，3个分区，只有一个带批处理的消费者。我在消费者方面使用的是spring kafka和以下消费者道具： 即使队列中有数千条消息（GBs数据）在等待，kafka consumer在每次轮询中也会收到大约10条消息（总大小约为1MB)。使用者应该获取（在我的示例中为15MB)或（在我的示例中为10000）的批处理。有什么问题？
-
现在，我有一个Spring Boot CLI应用程序，当应用程序启动时，它会自动启动Kafka消费者。我的任务是更新提供API的应用程序，允许在特定条件下启动或停止Kafka消费者。所以，我将使用SpringBootStarterWeb创建该API。但我找不到一种方法来手动管理消费过程。我需要的是 在不使用消费者的情况下启动API 关于如何手动管理消费过程的任何建议？ 技术细节： 用于创建侦听器