Page History

...

GitHub PR: https://github.com/apache/kafka/pull/1830

Released: 0.10.1.0

Please keep the discussion on the mailing list rather than commenting on the wiki (wiki discussions get unwieldy fast).

...

package org.apache.kafka.common;

class ClusterResource {

  private final String clusterId;

  public ClusterResource(String clusterId) {

    this.clusterId = clusterId;

  }

  public String clusterId() {

    return clusterId;

  }

}

package org.apache.kafka.common;

interface ClusterResourceListener {

  void onUpdate(ClusterResource cluster);

}

...