[APEXMALHAR-1093] AbstractKafkaInputOperator is not committing the txn to Kafka in commit call back

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.0.1
• Assignee: gaurav gupta
• Reporter: gaurav gupta
• Created: 12/May/14 21:50
• Updated: 03/Jan/16 10:01
• Resolved: 12/May/14 23:00

Description

Currently AbstractKafkaInputOperator is not committing the txn to Kafka in commit call back. but AbstractPartitionableKafkaInputOperator that extends AbstractKafkaInputOperator does it.

This commiting of the txn to Kafka should be part of AbstractKafkaInputOperator operator