apache-kafka - 为什么消费者读取数据在Kafka中不一致
问题描述
我正在通过订阅 Kafka 来阅读消息。我每 30 秒轮询一次，但我能够在 10 分钟内阅读一次消息。还有一个问题是，如果我使用 fetch.max.wait.ms，记录会被发回还是不发回任何记录。
解决方案
推荐阅读
- java - java从SequenceInputStream问题中读取内容
- ruby-on-rails - has_many 的 Rails 验证消息
- java - 这是一个java编译器错误吗？
- scala - DynamoDB EMR 集成 + WARN 任务计算器警告 - 映射任务小于 1
- pentaho - pentaho 勺子/PDI：如何创建具有当前日期的文件夹？
- reactjs - 如何进行多重过滤？
- javascript - addEventListener中不带括号的函数如何使用？
- python - 如何在python中输入输入的数量
- python - unittest 从迭代器收到 None 而不是引发的错误
- ruby-on-rails - local_time 的国际化（Rails）