Hi,
I'm attempting a migration from 2.7 to 3.5.0 and the way it's recommended
in the documentation.
1. Freeze the following settings
inter.broker.protocol.version=2.7-IV2
log.message.format.version=2.7-IV2
2. Upgrade kafka version to 3.5.0
3. Change inter.broker.protocol.version to 3.5
4. Change
Hi:
I am using RocksDbSessionBytesStoreSupplier in my kafka streaming application
for an aggregation like this:
var materialized =
Materialized.>as(
new
RocksDbSessionBytesStoreSupplier(env.getProperty("messages.cdc.pft.topic",
"NASHCM.PAYROLL.