Chia-Ping Tsai created KAFKA-20129:
--------------------------------------
Summary: Server error caused by appending/subtracting a
non-existent config key
Key: KAFKA-20129
URL: https://issues.apache.org/jira/browse/KAFKA-20129
Project: Kafka
Issue Type: Bug
Reporter: Chia-Ping Tsai
Assignee: Chia-Ping Tsai
{code:java}
def listType(configName: String, configKeys: Map[String, ConfigKey]):
Boolean = {
val configKey = configKeys(configName) // <-- root cause
if (configKey == null)
throw new InvalidConfigurationException(s"Unknown config name:
$configName")
configKey.`type` == ConfigDef.Type.LIST
}
{code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)