Package com.bakdata.kafka.admin

Class ConfigClient

java.lang.Object

com.bakdata.kafka.admin.ConfigClient

public class ConfigClient
extends Object

This class offers helpers to interact with Kafka resource configs.

Method Summary

Modifier and Type	Method	Description
void	add(org.apache.kafka.clients.admin.ConfigEntry configEntry)	Add a config for a Kafka resource.
Map<String,String>	describe()	Describes the current configuration of a Kafka resource.

Methods inherited from class java.lang.Object

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

Method Details

describe

public Map<String,String> describe()

Describes the current configuration of a Kafka resource.

Returns:

config of resource

add

public void add(org.apache.kafka.clients.admin.ConfigEntry configEntry)

Add a config for a Kafka resource.

Parameters:

configEntry - the configuration entry to add