[jira] [Updated] (KAFKA-2388) subscribe(topic)/unsubscribe(topic) should either take a callback to allow user to handle exceptions or it should be synchronous.

["Jiangjie Qin (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/KAFKA-2388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Jiangjie Qin updated KAFKA-2388:
--------------------------------
    Description: 
According to the mailing list discussion. The interface will be changed to:
void subscribe(List<String> topic, RebalanceCallback callback);
void assign(List<partition> partitions);
List<String> subscriptions();
List<Topic> assignments();

We don't need unsubscribe anymore.

The RebalanceCallback will have one more following method:
void onError(Exception e);

  was:
Currently subscribe/unsubscribe at topic level is asynchronous and it is difficult for user to know whether the  when the subscription finishes or whether the subscription succeeded or failed.
It should either take a callback to allow user handle exception or it should be synchronous.


> subscribe(topic)/unsubscribe(topic) should either take a callback to allow user to handle exceptions or it should be synchronous.
> ---------------------------------------------------------------------------------------------------------------------------------
>
>                 Key: KAFKA-2388
>                 URL: https://issues.apache.org/jira/browse/KAFKA-2388
>             Project: Kafka
>          Issue Type: Sub-task
>            Reporter: Jiangjie Qin
>            Assignee: Dong Lin
>
> According to the mailing list discussion. The interface will be changed to:
> void subscribe(List<String> topic, RebalanceCallback callback);
> void assign(List<partition> partitions);
> List<String> subscriptions();
> List<Topic> assignments();
> We don't need unsubscribe anymore.
> The RebalanceCallback will have one more following method:
> void onError(Exception e);



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)