Class BrokerTypeTopicClient

java.lang.Object
org.apache.kafka.common.config.BrokerTypeTopicClient

public class BrokerTypeTopicClient extends Object
  • Constructor Details

    • BrokerTypeTopicClient

      public BrokerTypeTopicClient()
  • Method Details

    • clientId

      public static String clientId(String clusterId, int brokerId)
    • isBrokerTypeTopicClient

      public static boolean isBrokerTypeTopicClient(String clientId)