You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@kafka.apache.org by "Jiankang Liu (JIRA)" <ji...@apache.org> on 2015/06/17 15:12:01 UTC

[jira] [Created] (KAFKA-2282) ConsumerConnector enhance

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)