Class RmGroupConfigClientImpl

java.lang.Object
io.confluent.rm.kafka.v1.RmGroupConfigClientImpl
All Implemented Interfaces:
RmGroupConfigClient
public class RmGroupConfigClientImpl extends Object implements RmGroupConfigClient
Implementation of RmGroupConfigClient using RmClient. Manages the single GroupConfig resource per Group that contains all group configs. Follows the same pattern as RmTopicClientImpl - LKC ID is embedded in the ObjectIdentifier scope.

  • Constructor Details

    • RmGroupConfigClientImpl

      public RmGroupConfigClientImpl(RmClient client)

  • Method Details

    • getGroupConfig

      public CompletableFuture<Optional<io.confluent.rm.kafka.v1.GroupConfig>> getGroupConfig(io.confluent.resourcemanager.api.model.identifier.ObjectIdentifier<io.confluent.rm.kafka.v1.GroupConfig> id)
      Description copied from interface: RmGroupConfigClient
      Retrieves the GroupConfig resource for an Group.
      Specified by:
      getGroupConfig in interface RmGroupConfigClient
      Parameters:
      id - The ObjectIdentifier with LKC scope attributes (org, environment, logical-kafka-cluster).
      Returns:
      A CompletableFuture that completes with an Optional containing the GroupConfig, or empty if the resource is not found.

    • updateDynamicConfigs

      public CompletableFuture<Optional<io.confluent.rm.kafka.v1.GroupConfig>> updateDynamicConfigs(io.confluent.rm.kafka.v1.GroupConfig config, io.confluent.rm.kafka.v1.GroupDynamicConfigs dynamicConfigs)
      Description copied from interface: RmGroupConfigClient
      Updates the Dynamic Configuration for existing Group resource.
      Specified by:
      updateDynamicConfigs in interface RmGroupConfigClient
      Parameters:
      config - The GroupConfig resource to update.
      Returns:
      A CompletableFuture that completes with the updated GroupConfig.

    • createGroupConfig

      public CompletableFuture<io.confluent.rm.kafka.v1.GroupConfig> createGroupConfig(io.confluent.rm.kafka.v1.GroupConfig config)
      Description copied from interface: RmGroupConfigClient
      Creates a new GroupConfig resource for an Group.
      Specified by:
      createGroupConfig in interface RmGroupConfigClient
      Parameters:
      config - The GroupConfig resource to create.
      Returns:
      A CompletableFuture that completes with the created GroupConfig.

    • deleteGroupConfig

      public CompletableFuture<Optional<io.confluent.rm.kafka.v1.GroupConfig>> deleteGroupConfig(io.confluent.resourcemanager.api.model.identifier.ObjectIdentifier<io.confluent.rm.kafka.v1.GroupConfig> id)
      Description copied from interface: RmGroupConfigClient
      Deletes the GroupConfig resource for a Group.
      Specified by:
      deleteGroupConfig in interface RmGroupConfigClient
      Parameters:
      id - The ObjectIdentifier with LKC scope attributes.
      Returns:
      A CompletableFuture that completes with an Optional containing the deleted GroupConfig, or empty if the resource was not found.

    • GroupConfigWatch

      public RmWatcher<io.confluent.rm.kafka.v1.GroupConfig> GroupConfigWatch()
      Description copied from interface: RmGroupConfigClient
      Creates a watcher to monitor changes to GroupConfig resources.
      Specified by:
      GroupConfigWatch in interface RmGroupConfigClient
      Returns:
      A Watcher instance for GroupConfig create, update, and delete events