Apache Apex - Пользовательский менеджер смещения Кафки
Если я напишу свою собственную реализацию OffsetManager для оператора ввода Кафка,
Как мне настроить оператор ввода kafka для использования моего собственного менеджера смещений сборки? Я знаю о свойстве "OffsetManager", но может кто-нибудь поделиться с вами рабочим примером того, как установить менеджер смещений?
Большое спасибо.