THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block |
---|
public interface StateStoreContext { ... /** * Return the metadata of the current topic/partition/offset if available. * This metadata in a StateStore is defined as the metadata of the last record * that hasis currently been processed completely by the StreamTask that holds the store. * <p> * Note that the metadata is not defined during all store interactions, for * example, while the StreamTask is running a punctuation. */ Optional<RecordMetadata> recordMetadata(); ... } |
...