Skip to main content

Module configs

Module configs 

Source
Expand description

Config reads and changes of any config resource, as Kafka’s Admin.describeConfigs and Admin.incrementalAlterConfigs.

Both calls route each resource as KafkaAdminClient does (nodeFor). A BROKER resource that names a broker id, and every BROKER_LOGGER resource, go to that node in a request of their own (ConstantNodeIdProvider). Every other resource, including the empty-name BROKER resource of the cluster-wide defaults, goes in one request on the client’s connection (LeastLoadedBrokerOrActiveKController). With a controller bootstrap (KIP-919), incrementalAlterConfigs sends a BROKER resource with the others to the active controller too.

Each resource gets a result of its own: its config or change, or the Kafka error of the resource or of the request that carried it.

Structs§

AlterConfigOp
One change of one config, as Kafka’s AlterConfigOp.
Config
The configs of one resource, as Kafka’s Config.
ConfigEntry
One config of a resource, as Kafka’s ConfigEntry.
ConfigSynonym
One value that a config takes from one source, as Kafka’s ConfigEntry.ConfigSynonym.
DescribeConfigsOptions
What AdminClientLike::describe_configs asks for, as Kafka’s DescribeConfigsOptions.
DescribeConfigsOptionsBuilder
Use builder syntax to set the inputs and finish with build().
IncrementalAlterConfigsOptions
What AdminClientLike::incremental_alter_configs asks for, as Kafka’s AlterConfigsOptions.
IncrementalAlterConfigsOptionsBuilder
Use builder syntax to set the inputs and finish with build().

Enums§

AlterConfigOpType
What an AlterConfigOp does, as Kafka’s AlterConfigOp.OpType.
ConfigSource
Where the value of a config comes from, as Kafka’s ConfigEntry.ConfigSource.
ConfigType
The data type of a config, as Kafka’s ConfigEntry.ConfigType.

Type Aliases§

AlterConfigsResults
The result of each resource of an AdminClientLike::incremental_alter_configs call.
DescribeConfigsResults
The result of each resource of a AdminClientLike::describe_configs call.