[
https://issues.apache.org/jira/browse/KAFKA-16211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17833809#comment-17833809
]
Dung Ha commented on KAFKA-16211:
---------------------------------
My guess from reading the code is that describeTopics() will send the request
to a specified broker if the config resource is broker
(ConfigResouce.Type.BROKER). In the case that the config resource is topic
(ConfigResouce.Type.TOPIC), then a broker will be assigned using
LeastLoadBrokerOrActiveKController() (in KafkaAdminClient), which in this
situation will assign the "least loaded" broker. I have tested this and,
indeed, each time I use describeConfigs() with the ConfigResource's type being
"TOPIC", a different broker's static configuration may be returned. My question
is: Is it supposed to be the way describeConfigs() should be used with the
configResource's type being ConfigResouce.Type.TOPIC? Or even, are we supposed
to use describeConfig() with configResource's type being
ConfigResouce.Type.TOPIC instead of strictly with ConfigResouce.Type.BROKER?
> Inconsistent config values in CreateTopicsResult and DescribeConfigsResult
> --------------------------------------------------------------------------
>
> Key: KAFKA-16211
> URL: https://issues.apache.org/jira/browse/KAFKA-16211
> Project: Kafka
> Issue Type: Bug
> Components: controller
> Reporter: Gantigmaa Selenge
> Assignee: Dung Ha
> Priority: Minor
>
> When creating a topic in KRaft cluster, a config value returned in
> CreateTopicsResult is different than what you get from describe topic
> configs, if the config was set in broker.properties or controller.properties
> or in both but with different values.
>
> For example, start a broker with `segment.bytes` set to 573741824 in the
> properties file and then create a topic, the CreateTopicsResult contains:
> ConfigEntry(name=segment.bytes, value=1073741824, source=DEFAULT_CONFIG,
> isSensitive=false, isReadOnly=false, synonyms=[], type=INT,
> documentation=null)
> because the controller was started without setting this config.
> However when you describe configurations for the same topic, the config value
> set by the broker is returned:
> Create topic configsConfigEntry(name=segment.bytes, value=573741824,
> source=STATIC_BROKER_CONFIG, isSensitive=false, isReadOnly=false,
> synonyms=[], type=null, documentation=null)
>
> Vice versa, if the controller is started with this config set to a different
> value, the create topic request returns the value set by the controller and
> then when you describe the config for the same topic, you get the value set
> by the broker. This makes it confusing to understand which value being is
> used.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
