clolov opened a new pull request, #14161:
URL: https://github.com/apache/kafka/pull/14161
# TODO
I need to find where the unit/integration tests for this behaviour are in
order to add the manual test to them
### Summary
The purpose of this change is to not allow a broker to start up with Tiered
Storage disabled (`remote.log.storage.system.enable=false`) while there are
still topics which have `remote.storage.enable` set.
### Testing
```
[2023-08-07 18:01:30,654] ERROR Exiting Kafka due to fatal exception during
startup. (kafka.Kafka$)
org.apache.kafka.common.config.ConfigException: You have to delete all
topics with the property remote.storage.enable (i.e. mrfreeze) before disabling
tiered storage cluster-wide
at
kafka.server.TopicConfigHandler.processConfigChanges(ConfigHandler.scala:71)
at
kafka.server.ZkConfigManager.$anonfun$startup$4(ZkConfigManager.scala:175)
at
kafka.server.ZkConfigManager.$anonfun$startup$4$adapted(ZkConfigManager.scala:174)
at scala.collection.immutable.Map$Map4.foreach(Map.scala:569)
at
kafka.server.ZkConfigManager.$anonfun$startup$1(ZkConfigManager.scala:174)
at
kafka.server.ZkConfigManager.$anonfun$startup$1$adapted(ZkConfigManager.scala:165)
at scala.collection.immutable.HashMap.foreach(HashMap.scala:1115)
at kafka.server.ZkConfigManager.startup(ZkConfigManager.scala:165)
at kafka.server.KafkaServer.startup(KafkaServer.scala:571)
at kafka.Kafka$.main(Kafka.scala:113)
at kafka.Kafka.main(Kafka.scala)
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
