[ATLAS-1908] Updating old Kafka consumer api properties to reflect change in new KafkaConsumer configs for Atlas.

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 0.8.1, 1.0.0
• Assignee: Nixon Rodrigues
• Reporter: Nixon Rodrigues
• Created: 03/Jul/17 07:40
• Updated: 17/Jul/17 16:43
• Resolved: 17/Jul/17 16:43

Description

In ATLAS-1766, the old Kafka consumer api was updated with new Kafka consumer api.
Due to this update, there were changes in configs.

New property:
atlas.kafka.session.timeout.ms=30000

Renamed property:
atlas.kafka.auto.commit.enable=false to atlas.kafka.enable.auto.commit=false

New default value:
atlas.kafka.auto.offset.reset=smallest to atlas.kafka.auto.offset.reset=earliest

Need to handle old configs, so that Kafka consumer starts gracefully even if new configs are not added explicitly.

Issue Links

• links to: Review request