Hi all, I have a question about using classes that are are public but the class is contained in the internals packages Generally, would it be supported if I wrote Kafka code referencing these classes?
This question comes from an attempt to add a CacheListener to a TimestampedKeyValueStore. The line of code looks like this: cachingEnabled = ((WrappedStateStore) this.store).setFlushListener(new AggregateCacheFlushListener<>(context), false); To gain access to the setFlushListener the code needs to cast the underlying state store object to a org.apache.kafka.streams.state.internals.WrappedStateStore object. Kind regards, John Brackin