[
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)
