Jiankang Liu created KAFKA-2282:
-----------------------------------
Summary: ConsumerConnector enhance
Key: KAFKA-2282
URL: https://issues.apache.org/jira/browse/KAFKA-2282
Project: Kafka
Issue Type: Improvement
Components: consumer
Reporter: Jiankang Liu
Assignee: Neha Narkhede
1. As a developer, I want to manually handle rebalance situation, such as
commit offset to avoid consume duplicate message; thus export the
setConsumerRebalanceListener interface in java api.
2. It will throw a ClassCastException to just simply use asInstanceOf to cast
java.util.map to scala immutable.map; it'd better use JavaConversions, not use
JavaConverters to keep code style syched and compatible for scala under 2.8
version.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
