hadoop - Apache Apex - 自定义编写的 Kafka 偏移管理器

Question

如果我为 kafka 输入运算符编写自己的 OffsetManager 实现，

我应该如何配置 kafka 输入运算符以使用我的自定义构建偏移管理器？我知道“OffsetManager”属性，但是有人可以分享一些如何设置偏移管理器的工作示例吗？

非常感谢。