Class KafkaProfile

java.lang.Object
com.azure.resourcemanager.hdinsight.containers.models.KafkaProfile
All Implemented Interfaces:
com.azure.json.JsonSerializable<KafkaProfile>
public final class KafkaProfile extends Object implements com.azure.json.JsonSerializable<KafkaProfile>
The Kafka cluster profile.

  • Constructor Details

    • KafkaProfile

      public KafkaProfile()
      Creates an instance of KafkaProfile class.

  • Method Details

    • enableKRaft

      public Boolean enableKRaft()
      Get the enableKRaft property: Expose Kafka cluster in KRaft mode.
      Returns:
      the enableKRaft value.

    • withEnableKRaft

      public KafkaProfile withEnableKRaft(Boolean enableKRaft)
      Set the enableKRaft property: Expose Kafka cluster in KRaft mode.
      Parameters:
      enableKRaft - the enableKRaft value to set.
      Returns:
      the KafkaProfile object itself.

    • enablePublicEndpoints

      public Boolean enablePublicEndpoints()
      Get the enablePublicEndpoints property: Expose worker nodes as public endpoints.
      Returns:
      the enablePublicEndpoints value.

    • withEnablePublicEndpoints

      public KafkaProfile withEnablePublicEndpoints(Boolean enablePublicEndpoints)
      Set the enablePublicEndpoints property: Expose worker nodes as public endpoints.
      Parameters:
      enablePublicEndpoints - the enablePublicEndpoints value to set.
      Returns:
      the KafkaProfile object itself.

    • remoteStorageUri

      public String remoteStorageUri()
      Get the remoteStorageUri property: Fully qualified path of Azure Storage container used for Tiered Storage.
      Returns:
      the remoteStorageUri value.

    • withRemoteStorageUri

      public KafkaProfile withRemoteStorageUri(String remoteStorageUri)
      Set the remoteStorageUri property: Fully qualified path of Azure Storage container used for Tiered Storage.
      Parameters:
      remoteStorageUri - the remoteStorageUri value to set.
      Returns:
      the KafkaProfile object itself.

    • diskStorage

      public DiskStorageProfile diskStorage()
      Get the diskStorage property: Kafka disk storage profile.
      Returns:
      the diskStorage value.

    • withDiskStorage

      public KafkaProfile withDiskStorage(DiskStorageProfile diskStorage)
      Set the diskStorage property: Kafka disk storage profile.
      Parameters:
      diskStorage - the diskStorage value to set.
      Returns:
      the KafkaProfile object itself.

    • connectivityEndpoints

      public KafkaConnectivityEndpoints connectivityEndpoints()
      Get the connectivityEndpoints property: Kafka bootstrap server and brokers related connectivity endpoints.
      Returns:
      the connectivityEndpoints value.

    • validate

      public void validate()
      Validates the instance.
      Throws:
      IllegalArgumentException - thrown if the instance is not valid.

    • toJson

      public com.azure.json.JsonWriter toJson(com.azure.json.JsonWriter jsonWriter) throws IOException
      Specified by:
      toJson in interface com.azure.json.JsonSerializable<KafkaProfile>
      Throws:
      IOException

    • fromJson

      public static KafkaProfile fromJson(com.azure.json.JsonReader jsonReader) throws IOException
      Reads an instance of KafkaProfile from the JsonReader.
      Parameters:
      jsonReader - The JsonReader being read.
      Returns:
      An instance of KafkaProfile if the JsonReader was pointing to an instance of it, or null if it was pointing to JSON null.
      Throws:
      IllegalStateException - If the deserialized JSON object was missing any required properties.
      IOException - If an error occurs while reading the KafkaProfile.