nicktelford opened a new pull request, #14852: URL: https://github.com/apache/kafka/pull/14852
When opening RocksDB, we were checking for an error in `RocksDBTimestampedStore` to detect if the `keyValueWithTimestamp` CF is missing. The `openRocksDB` method now supports any number of column families, not just the extra one used by `RocksDBTimestampedStore`. We now check for the existing column families _before_ opening the database, which allows us to create any missing column families. Supporting automatic creation of any number of missing column families is a pre-requisite for KIP-892: Transactional StateStores. -- 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: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org