Module io.aiven.commons.kafka.config

Package io.aiven.commons.kafka.config.fragment

Class CommonConfigFragment

java.lang.Object

io.aiven.commons.kafka.config.fragment.ConfigFragment

io.aiven.commons.kafka.config.fragment.CommonConfigFragment

All Implemented Interfaces:

FragmentDataAccess

public class CommonConfigFragment
extends ConfigFragment

The common configuration fragment.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	CommonConfigFragment.Setter	Setter to programmatically set values in the configuraiotn.

Field Summary

Fields inherited from class io.aiven.commons.kafka.config.fragment.ConfigFragment

dataAccess

Constructor Summary

Constructors

Constructor	Description
CommonConfigFragment(FragmentDataAccess dataAccess)	Create a fragment instance from an AbstractConfig.

Method Summary

Modifier and Type	Method	Description
ConverterType	getKeyConverter()	the converter used for the key portion of the kafka event
Integer	getMaxTasks()	Get the maximum number of tasks.
Integer	getTaskId()	Get the task Id.
ConverterType	getValueConverter()	the converter used for the value portion of the kafka event
static CommonConfigFragment.Setter	setter(Map<String,String> data)	Gets a setter for this fragment.
static org.apache.kafka.common.config.ConfigDef	update(org.apache.kafka.common.config.ConfigDef configDef)	Update the ConfigDef with the values from the fragment.

Methods inherited from class io.aiven.commons.kafka.config.fragment.ConfigFragment

getBoolean, getClass, getConfiguredInstance, getInt, getList, getLong, getPassword, getString, has, logDeprecated, logDeprecated, logDeprecated, registerIssue, validate, validate, validationMessage, values

Methods inherited from class java.lang.Object

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

Constructor Details

CommonConfigFragment

public CommonConfigFragment(FragmentDataAccess dataAccess)

Create a fragment instance from an AbstractConfig.

Parameters:

dataAccess - the FragmentDataAccess to retrieve data from.

Method Details

setter

public static CommonConfigFragment.Setter setter(Map<String,String> data)

Gets a setter for this fragment.

Parameters:

data - the data to modify.

Returns:

The setter.

update

public static org.apache.kafka.common.config.ConfigDef update(org.apache.kafka.common.config.ConfigDef configDef)

Update the ConfigDef with the values from the fragment.

Parameters:

configDef - the configuraiton def to update.

Returns:

the updated configuration def.

getTaskId

public Integer getTaskId()

Get the task Id.

Returns:

the task Id.

getMaxTasks

public Integer getMaxTasks()

Get the maximum number of tasks.

Returns:

the maximum number of tasks.

getKeyConverter

public ConverterType getKeyConverter()

the converter used for the key portion of the kafka event

Returns:

the converter used for the key portion of the kafka event

getValueConverter

public ConverterType getValueConverter()

the converter used for the value portion of the kafka event

Returns:

the converter used for the value portion of the kafka event