Package com.bakdata.kafka.admin

Class ConsumerGroupsClient

java.lang.Object

com.bakdata.kafka.admin.ConsumerGroupsClient

public final class ConsumerGroupsClient
extends Object

This class offers helpers to interact with Kafka consumer groups.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
final class	ConsumerGroupsClient.ConsumerGroupClient	A client for a specific consumer group.

Method Summary

Modifier and Type	Method	Description
ConsumerGroupsClient.ConsumerGroupClient	group(String groupName)	Create a client for a specific consumer group.
Collection<org.apache.kafka.clients.admin.ConsumerGroupListing>	list()	List consumer groups.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

list

public Collection<org.apache.kafka.clients.admin.ConsumerGroupListing> list()

List consumer groups.

Returns:

consumer groups

group

public ConsumerGroupsClient.ConsumerGroupClient group(String groupName)

Create a client for a specific consumer group.

Parameters:

groupName - consumer group name

Returns:

a consumer group client for the specified group