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
