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