Package io.aiven.kafka.connect.common.config

Class CommonConfigFragment

java.lang.Object

io.aiven.kafka.connect.common.config.ConfigFragment

io.aiven.kafka.connect.common.config.CommonConfigFragment

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.kafka.connect.common.config.ConfigFragment

cfg

Constructor Summary

Constructors

Constructor	Description
CommonConfigFragment(org.apache.kafka.common.config.AbstractConfig cfg)	Create a fragment instance from an AbstractConfig.

Method Summary

Modifier and Type	Method	Description
Integer	getMaxTasks()	Get the maximum number of tasks.
Integer	getTaskId()	Get the task Id.
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.kafka.connect.common.config.ConfigFragment

has, logDeprecated, logDeprecated, logDeprecated, validate

Methods inherited from class java.lang.Object

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

Constructor Details

CommonConfigFragment

public CommonConfigFragment(org.apache.kafka.common.config.AbstractConfig cfg)

Create a fragment instance from an AbstractConfig.

Parameters:

cfg - the AbstractConfig 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.