Custom Kafka Offset Manager

[Raja . Aravapalli]

Hi,

If I write my own implementation of OffsetManager for kafka input operator,

How should I configure kafka input operator to use my custom build offset 
manager ? I know about the property “OffsetManager”, But can someone please 
share a small example of how to set the offset manager ?


Thanks a lot.


Regards,
Raja.