Interface RmStreamsTopologyClient

All Known Implementing Classes:
RmStreamsTopologyClientImpl
public interface RmStreamsTopologyClient
Client interface for managing StreamsTopology resources in the resource manager.

Each Kafka Streams group is represented by a single StreamsTopology resource, identified by metadata.name and scoped to the tenant's logical Kafka cluster (org, environment, LKC). Callers are responsible for building the resource body (including any read-modify-write needed for updates); this client is a thin pass-through to the generic RmClient.

  • Method Summary

    Modifier and Type
    Method
    Description
    CompletableFuture<io.confluent.rm.kafka.v1.StreamsTopology>
    createStreamsTopology(io.confluent.rm.kafka.v1.StreamsTopology topology)
    Creates a new StreamsTopology resource.
    CompletableFuture<Optional<io.confluent.rm.kafka.v1.StreamsTopology>>
    deleteStreamsTopology(io.confluent.resourcemanager.api.model.identifier.ObjectIdentifier<io.confluent.rm.kafka.v1.StreamsTopology> id)
    Deletes the StreamsTopology resource for a streams group.
    CompletableFuture<Optional<io.confluent.rm.kafka.v1.StreamsTopology>>
    getStreamsTopology(io.confluent.resourcemanager.api.model.identifier.ObjectIdentifier<io.confluent.rm.kafka.v1.StreamsTopology> id)
    Retrieves the StreamsTopology resource for a streams group.
    CompletableFuture<Optional<io.confluent.rm.kafka.v1.StreamsTopology>>
    updateStreamsTopology(io.confluent.rm.kafka.v1.StreamsTopology topology)
    Updates an existing StreamsTopology resource.

  • Method Details

    • createStreamsTopology

      CompletableFuture<io.confluent.rm.kafka.v1.StreamsTopology> createStreamsTopology(io.confluent.rm.kafka.v1.StreamsTopology topology)
      Creates a new StreamsTopology resource.
      Parameters:
      topology - The StreamsTopology resource to create.
      Returns:
      A CompletableFuture that completes with the created StreamsTopology.

    • getStreamsTopology

      CompletableFuture<Optional<io.confluent.rm.kafka.v1.StreamsTopology>> getStreamsTopology(io.confluent.resourcemanager.api.model.identifier.ObjectIdentifier<io.confluent.rm.kafka.v1.StreamsTopology> id)
      Retrieves the StreamsTopology resource for a streams group.
      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

      CompletableFuture<Optional<io.confluent.rm.kafka.v1.StreamsTopology>> updateStreamsTopology(io.confluent.rm.kafka.v1.StreamsTopology topology)
      Updates an existing StreamsTopology resource.
      Parameters:
      topology - The StreamsTopology resource to update.
      Returns:
      A CompletableFuture that completes with an Optional containing the updated StreamsTopology.

    • deleteStreamsTopology

      CompletableFuture<Optional<io.confluent.rm.kafka.v1.StreamsTopology>> deleteStreamsTopology(io.confluent.resourcemanager.api.model.identifier.ObjectIdentifier<io.confluent.rm.kafka.v1.StreamsTopology> id)
      Deletes the StreamsTopology resource for a streams group.
      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.