Class RmStreamsTopologyClientImpl

java.lang.Object
io.confluent.rm.kafka.v1.RmStreamsTopologyClientImpl
All Implemented Interfaces:
RmStreamsTopologyClient
public class RmStreamsTopologyClientImpl extends Object implements RmStreamsTopologyClient
Implementation of RmStreamsTopologyClient using RmClient.

  • Constructor Details

    • RmStreamsTopologyClientImpl

      public RmStreamsTopologyClientImpl(RmClient client)

  • Method Details

    • createStreamsTopology

      public CompletableFuture<io.confluent.rm.kafka.v1.StreamsTopology> createStreamsTopology(io.confluent.rm.kafka.v1.StreamsTopology topology)
      Description copied from interface: RmStreamsTopologyClient
      Creates a new StreamsTopology resource.
      Specified by:
      createStreamsTopology in interface RmStreamsTopologyClient
      Parameters:
      topology - The StreamsTopology resource to create.
      Returns:
      A CompletableFuture that completes with the created StreamsTopology.

    • getStreamsTopology

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

    • updateStreamsTopology

      public CompletableFuture<Optional<io.confluent.rm.kafka.v1.StreamsTopology>> updateStreamsTopology(io.confluent.rm.kafka.v1.StreamsTopology topology)
      Description copied from interface: RmStreamsTopologyClient
      Updates an existing StreamsTopology resource.
      Specified by:
      updateStreamsTopology in interface RmStreamsTopologyClient
      Parameters:
      topology - The StreamsTopology resource to update.
      Returns:
      A CompletableFuture that completes with an Optional containing the updated StreamsTopology.

    • deleteStreamsTopology

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