Interface StreamsGroupManager

public interface StreamsGroupManager

A service to manage Kafka Streams Groups.

Method Summary

Modifier and Type	Method	Description
CompletableFuture<Optional<StreamsGroup>>	getStreamsGroup(String clusterId, String streamsGroupId)	Returns the Kafka StreamsGroup with the given streamsGroupId.
CompletableFuture<List<StreamsGroup>>	listStreamsGroups(String clusterId)	Returns the list of Kafka Streams Groups belonging to the Cluster with the given clusterId.

Method Details

listStreamsGroups

CompletableFuture<List<StreamsGroup>> listStreamsGroups(String clusterId)

Returns the list of Kafka Streams Groups belonging to the Cluster with the given clusterId.

getStreamsGroup

CompletableFuture<Optional<StreamsGroup>> getStreamsGroup(String clusterId,
 String streamsGroupId)

Returns the Kafka StreamsGroup with the given streamsGroupId.