Andrew Olson created CRUNCH-654: ----------------------------------- Summary: KafkaSource should use new Kafka Consumer API instead of Simple Consumer Key: CRUNCH-654 URL: https://issues.apache.org/jira/browse/CRUNCH-654 Project: Crunch Issue Type: Improvement Components: Core Reporter: Andrew Olson Assignee: Josh Wills
We should update the KafkaSource to use the modern Consumer API. The old Consumer used by KafkaUtils#getBrokerOffsets(...) is considered deprecated as of Kafka 0.11 (https://issues.apache.org/jira/browse/KAFKA-3264) -- This message was sent by Atlassian JIRA (v6.4.14#64029)