mirror of https://github.com/apache/kafka.git
ecc1fb10fa
This PR implements KIP-78:Cluster Identifiers [(link)](https://cwiki.apache.org/confluence/display/KAFKA/KIP-78%3A+Cluster+Id#KIP-78:ClusterId-Overview) and includes the following changes: 1. Changes to broker code - generate cluster id and store it in Zookeeper - update protocol to add cluster id to metadata request and response - add ClusterResourceListener interface, ClusterResource class and ClusterMetadataListeners utility class - send ClusterResource events to the metric reporters 2. Changes to client code - update Cluster and Metadata code to support cluster id - update clients for sending ClusterResource events to interceptors, (de)serializers and metric reporters 3. Integration tests for interceptors, (de)serializers and metric reporters for clients and for protocol changes and metric reporters for broker. 4. System tests for upgrading from previous versions. Author: Sumit Arrawatia <sumit.arrawatia@gmail.com> Author: Ismael Juma <ismael@juma.me.uk> Reviewers: Jun Rao <junrao@gmail.com>, Ismael Juma <ismael@juma.me.uk> Closes #1830 from arrawatia/kip-78 |
||
|---|---|---|
| .. | ||
| examples/src/main/java/org/apache/kafka/streams/examples | ||
| src | ||