轮询（）间隔基中的kafka消息？那么，如何在特定时间内阻止KafkListenerEndpointRegistry轮询消息呢
是否使用@kafkaListener在间隔基中轮询（）Kafka消息？如何在特定时间内阻止KafkaListenerEndpointRegistry轮询消息
共有1个答案
请参阅参考手册中的@KafkaListener Lifecycle Management。
-
我有一个Kafka主题，并为其附加了1个消费者(主题只有1个分区)。现在对于超时，我使用默认值(心跳:3秒，会话超时:10秒，轮询超时:5分钟)。 根据留档，轮询超时定义消费者必须在其他代理将该消费者从消费者组中删除之前处理消息。现在假设，消费者只需1分钟即可完成处理消息。 现在我有两个问题
-
任何建议或忠告都会真的很有帮助。提前道谢。
-
我有一个Kafka消费者，其中消息通过HTTP POST调用传递给另一个应用程序。我还使用手动提交偏移量 确认。确认（）； 有一些HTTP返回错误代码，我们忽略错误并提交偏移量，还有一些错误代码我们不提交偏移量。问题是，kafka使用者仅在我重新启动使用者时才轮询未提交的消息。如果分区中有未提交的消息，是否还有轮询消息的地方？
-
我的Kafka消费者的代码是这样的 我已经意识到，这种消费者设置无法读取所有信息。我无法再现这一点，因为这是一个间歇性的问题。 当我使用 将最后 100 条消息与此消费者进行比较时，我发现我的消费者间歇性地随机错过了几条消息。我的消费者有什么问题？ 在python中使用消息的方法太多了。应该有一种最好只有一种明显的方法来做到这一点。
-
我是Kafka新手，我正在使用Kafka1.0。 我使用拉取模式读取kafka消息，也就是说，我定期查看Kafka主题以获取新消息，但我没有将偏移量写回Kafka。 我会问Kafka如何知道我消耗了哪些偏移量，或者Kafka记住进度的机制是什么（Kafka偏移量）
-
需求：构建一个基于。NET的应用程序，该应用程序可以定期从IBM Websphere消息队列读取消息，并将这些消息保存到数据库中