I wrote a custom Hbase offset manager, and tried to set this for Kafka input operator as below!! When I trigger the application with this setting, application is staying long time in ACCEPTED state, and even it moves to RUNNING state… all the operators are staying INACTIVE without processing any records.
HBaseOffsetManager hbaseOffMgr = new HBaseOffsetManager(); kafkaInput.setOffsetManager(hbaseOffMgr); Any help will immensely help me. Thanks. Regards, Raja. From: "Raja.Aravapalli" <[email protected]<mailto:[email protected]>> Reply-To: "[email protected]<mailto:[email protected]>" <[email protected]<mailto:[email protected]>> Date: Friday, June 10, 2016 at 5:07 PM To: "[email protected]<mailto:[email protected]>" <[email protected]<mailto:[email protected]>> Subject: Custom Kafka Offset Manager 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.
