Package com.bakdata.kafka.admin

Class AdminClientX

java.lang.Object

com.bakdata.kafka.admin.AdminClientX

All Implemented Interfaces:

AutoCloseable

public final class AdminClientX
extends Object
implements AutoCloseable

Provide methods for common operations when performing administrative actions on a Kafka cluster

Method Summary

Modifier and Type	Method	Description
org.apache.kafka.clients.admin.Admin	admin()	Get the underlying Admin client.
void	close()
ConsumerGroupsClient	consumerGroups()	Create a ConsumerGroupsClient to perform consumer group-related administrative actions
static AdminClientX	create(@NonNull Map<String,Object> properties)	Create a new admin client with default timeout
static AdminClientX	create(@NonNull Map<String,Object> properties, @NonNull Duration timeout)	Create a new admin client
Optional<io.confluent.kafka.schemaregistry.client.SchemaRegistryClient>	schemaRegistry()	Create a SchemaRegistryClient if schema registry is configured.
TopicsClient	topics()	Create a TopicsClient to perform topic-related administrative actions.

Methods inherited from class java.lang.Object

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

Method Details

create

public static AdminClientX create(@NonNull
 @NonNull Map<String,Object> properties)

Create a new admin client with default timeout

Parameters:

properties - Kafka configuration

Returns:

admin client

create

public static AdminClientX create(@NonNull
 @NonNull Map<String,Object> properties,
 @NonNull
 @NonNull Duration timeout)

Create a new admin client

Parameters:

properties - Kafka configuration

timeout - timeout when performing admin operations

Returns:

admin client

admin

public org.apache.kafka.clients.admin.Admin admin()

Get the underlying Admin client.

Returns:

admin client

schemaRegistry

public Optional<io.confluent.kafka.schemaregistry.client.SchemaRegistryClient> schemaRegistry()

Create a SchemaRegistryClient if schema registry is configured.

Returns:

schema registry client

topics

public TopicsClient topics()

Create a TopicsClient to perform topic-related administrative actions.

Returns:

topic client

consumerGroups

public ConsumerGroupsClient consumerGroups()

Create a ConsumerGroupsClient to perform consumer group-related administrative actions

Returns:

consumer group client

close

public void close()

Specified by:

close in interface AutoCloseable