Closed k-wall closed 4 months ago
com.ozangunalp.kafka.server.Storage#formatStorageFromConfig
hardcodes MINIMUM_BOOTSTRAP_VERSION
which is currently IBP_3_3_IV0
. IBP_3_5_IV2
is the minimum needed for KRaft/SCRAM support.
One approach would be to make the storage format version configurable from the command line. It could accept a MetadataVersion
version string, or the words latest
or minimum
. It would default to minimum
to maintain current behaviour.
WDYAT?
@robobario @ozangunalp ?
We should test that the native image still works as expected with this being a dynamic config.
Otherwise we can cut a release with the current version and update the storage format for future releases.
I'll put up a PR someone soon.
For my use-case, I want to configure the Cluster to use SCRAM-SHA username and password. This works with Zookeeper based clusters (SCRAM user db is held in Zookeeper), but fails on KRaft (SCRAM user db is held in broker storage) . This reason is the storage format hardcoded by kafka-native is too old.