Versions Compared

Old Version 12

changes.mady.by.user Chris Egerton

Saved on

compared with

New Version 13

changes.mady.by.user Chris Egerton

Saved on

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.
Comment: Change ConnectClusterDetails from class to interface

...

A new ConnectClusterDetails class  interface will be added as well, that contains immutable information about the Connect cluster:

Code Block
languagejava
titleConnectClusterDetails - new interface
package org.apache.kafka.connect.health;

public classinterface ConnectClusterDetails {

  private final String kafkaClusterId;

  public ConnectClusterDetails(String kafkaClusterId) {
    this.kafkaClusterId = kafkaClusterId;
  }

  /**
   * Get the cluster ID of the Kafka cluster backing this Connect cluster.
   * @return the cluster ID of the Kafka cluster backing this connect cluster
   **/
  public String kafkaClusterId() {
    return kafkaClusterId;
  }
}

This class interface will only provide the ID of the backing Kafka cluster for now, but may be expanded in the future to include the mode of the Connect worker (standalone, distributed, perhaps embedded(?)), the group ID of a distributed cluster, or other information.

...