apache-kafka - 从 Apache Storm Trident 记录 Kafka 分区和偏移量
问题描述
使用 Apache Storm Trident 使用来自 Kafka 的消息时，Kafka 分区和相应的偏移量存储在哪里？我可以在 Storm Zookeeper 下找到一些东西ls /transactional/<StreamName>/coordinator/meta。但我无法理解这些偏移量是什么以及它们属于哪个分区？如何在运行 Trident Topology 时检查消费者滞后？
解决方案
推荐阅读
- ajax - iCheck JS 和 CSS 在服务器端脚本引导数据表上不起作用
- python - 超过最大递归深度
- ignite - Apache Ignite 是否支持分布式事务
- ovh - 有没有办法在第一次 ssh 时检查我的 OVH VPS 服务器的指纹？
- vmware-workstation - 为什么即使网络是桥接，我也无法从 vm 机器 ping 我的主机？
- tensorflow - 出现错误“IndexError：列表索引超出范围”
- android - 在 Kotlin 中使用新参数的分页 3.0 列表
- openshift - 如何使用 Openshift OAuth 服务器作为我在 openshift 集群中运行的 Web 应用程序的身份验证提供程序？
- python-3.x - Bigcommerce API 连接断开且无响应
- amazon-web-services - lambda 与 Greengrass lambda 配置的内存限制、超时设置有什么区别？