[
https://issues.apache.org/jira/browse/KAFKA-15374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin McCabe resolved KAFKA-15374.
----------------------------------
Assignee: David Arthur
Resolution: Fixed
> ZK migration fails on configs for default broker resource
> ---------------------------------------------------------
>
> Key: KAFKA-15374
> URL: https://issues.apache.org/jira/browse/KAFKA-15374
> Project: Kafka
> Issue Type: Bug
> Affects Versions: 3.5.1
> Reporter: David Arthur
> Assignee: David Arthur
> Priority: Critical
> Fix For: 3.6.0, 3.5.2
>
>
> This error was seen while performing a ZK to KRaft migration on a cluster
> with configs for the default broker resource
>
> {code:java}
> java.lang.NumberFormatException: For input string: ""
> at
> java.base/java.lang.NumberFormatException.forInputString(NumberFormatException.java:67)
> at java.base/java.lang.Integer.parseInt(Integer.java:678)
> at java.base/java.lang.Integer.valueOf(Integer.java:999)
> at
> kafka.zk.ZkMigrationClient.$anonfun$migrateBrokerConfigs$2(ZkMigrationClient.scala:371)
> at
> kafka.zk.migration.ZkConfigMigrationClient.$anonfun$iterateBrokerConfigs$1(ZkConfigMigrationClient.scala:174)
> at
> kafka.zk.migration.ZkConfigMigrationClient.$anonfun$iterateBrokerConfigs$1$adapted(ZkConfigMigrationClient.scala:156)
> at
> scala.collection.immutable.BitmapIndexedMapNode.foreach(HashMap.scala:1076)
> at scala.collection.immutable.HashMap.foreach(HashMap.scala:1083)
> at
> kafka.zk.migration.ZkConfigMigrationClient.iterateBrokerConfigs(ZkConfigMigrationClient.scala:156)
> at
> kafka.zk.ZkMigrationClient.migrateBrokerConfigs(ZkMigrationClient.scala:370)
> at
> kafka.zk.ZkMigrationClient.cleanAndMigrateAllMetadata(ZkMigrationClient.scala:530)
> at
> org.apache.kafka.metadata.migration.KRaftMigrationDriver$MigrateMetadataEvent.run(KRaftMigrationDriver.java:618)
> at
> org.apache.kafka.queue.KafkaEventQueue$EventContext.run(KafkaEventQueue.java:127)
> at
> org.apache.kafka.queue.KafkaEventQueue$EventHandler.handleEvents(KafkaEventQueue.java:210)
> at
> org.apache.kafka.queue.KafkaEventQueue$EventHandler.run(KafkaEventQueue.java:181)
> at java.base/java.lang.Thread.run(Thread.java:833)
> at org.apache.kafka.common.utils.KafkaThread.run(KafkaThread.java:64)
> {code}
>
> This is due to not considering the default resource type when we collect the
> broker IDs in ZkMigrationClient#migrateBrokerConfigs.
>
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
