Kafka正确的投票方式没有记录
为了使消费者保持活动（非常长的可变长度处理），我在后台线程中实现了一个空的poll（）调用，如果我在poll（）之间花费了太多时间，它将防止代理重新平衡。我已经将我的轮询间隔设置得很长，但我不想为了越来越长的处理而一直增加它。
什么是正确的投票没有记录？当前我正在调用poll()，然后重新查找poll call（）中返回的每个分区的最早偏移量，这样主线程在处理完前面的消息后就可以正确地读取这些偏移量。
ConsumerRecords<String, String> msgs = kafkaConsumer.poll(timeout);
Map<Integer, Long> partitionToOffsets = getEarliestPartitionOffsets(msgs); // helper method
seekToOffsets(partitionToOffsets);
共有1个答案
处理长处理时间（并避免消费者重新平衡）的正确方法是使用kafkaconsumer.pause()/kafkaconsumer.resume()方法。你可以在这里阅读更多关于它的内容：
- Kafkaconsumer Javadoc
- 阿帕奇卡夫卡吉拉
-
我想找到一种方法，使悬停属性在投票后保持活动状态，这是状态，并让Javascript或Firebase记住为该用户保持投票图标处于该状态。所以当一个用户投了几个名字，然后再回到页面时，他们会看到他们投了哪些名字，他们投的是什么。 我正在寻找如何实现这一目标的想法。 目前，在firebase中，我将用户的身份验证ID(uid)保存在他们投票的每个人的名字中，或者是1或者是-1表示支持或支持。我确信可
-
一、简介 系统的投票功能提供了两种投票类型,第一个是单选投票.第二种是多选投票.网站编辑人员可以根据实际的需求,选择类型进行操作。 何处使用投票： 常用于首页、内容页、及专题页面。所有你想放投票的区域。 如何使用： 只需要根据投票所放位置不同，复制对应代码到模版里即可。 系统信息发布页 和 专题管理内置提供了投票选择功能，只需手动点选，即可添加投票。 针对不同位置CSS样式不同，系统提供了三种常用
-
现在我们的系统更完善了，但是想要找到最受欢迎的帖子有点难。我们需要一个排名系统来给我们的帖子排个序。 我们可以建立一个基于 karma 的复杂排名系统，权值随着时间衰减，和许多其他因素（很多功能都在 Telescope 中实现了，他是 Microscope 的大哥）。但是对于我们的例子 app, 我们尽量保持简单，我们只按照帖子收到的投票数为它们排序。 让我们实现一个给用户为帖子投票的方法。 数据
-
获取投票信息 Mudu.Room.Vote.Get(function (response) { response = JSON.parse(response) if (response.status === 'y') { console.log('获取成功，数据为：', response.data) } if (response.status === 'n') {
-
Kafka 消费者在每个投票中轮询 500 条消息。我们禁用了， 假设我们已成功处理 100 条消息，偏移量也为 100 现在在第101条消息中，我们遇到了一个错误，我们没有提交偏移量 但是因为我们已经有了500条消息，所以我们处理了第102条消息，我们成功地处理了它，并且我们还提交了第102条消息的偏移量。 雀： 第 101 条消息会发生什么。 如何克服这个问题。
-
我不想使用@KafKalistener或@StreamListener，但我想手动轮询Kafka。我正在使用spring-cloud-starter-stream-kafka库，我有以下Kafka制作人