Package io.confluent.license.kafka

Interface BrokerDetector

public interface BrokerDetector
Interface for detecting Kafka broker type.

  • Method Details

    • create

      static BrokerDetector create()
      Creates a new instance of the BrokerDetector.
      Returns:
      a new BrokerDetector instance

    • determineBrokerType

      BrokerType determineBrokerType(Properties consumerProperties) throws BrokerDetectionException
      Detects the type of broker based on the provided configuration.
      Parameters:
      consumerProperties - Kafka consumer configuration Properties for connecting to the Kafka cluster
      Returns:
      the detected broker type
      Throws:
      BrokerDetectionException - if there's an error during detection

    • determineBrokerType

      BrokerType determineBrokerType(Map<String,Object> consumerProperties) throws BrokerDetectionException
      Detects the type of broker based on the provided configuration.
      Parameters:
      consumerProperties - Kafka consumer configuration Map for connecting to the Kafka cluster
      Returns:
      the detected broker type
      Throws:
      BrokerDetectionException - if there's an error during detection