apacheapex-custom编写的kafka偏移管理器

szqfcxe2  于 2021-06-02  发布在  Hadoop
关注(0)|答案(0)|浏览(189)

如果我为kafka输入操作符编写自己的offsetmanager实现,
我应该如何配置kafka输入操作符来使用我的自定义生成偏移管理器?我知道“offsetmanager”属性,但是有人能分享一些如何设置offsetmanager的工作示例吗?
谢谢。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题