[jira] [Created] (KAFKA-6967) TopologyTestDriver does not allow pre-populating state stores that have change logging

["James Cheng (JIRA)" <ji...@apache.org>]

James Cheng created KAFKA-6967:
----------------------------------

             Summary: TopologyTestDriver does not allow pre-populating state stores that have change logging
                 Key: KAFKA-6967
                 URL: https://issues.apache.org/jira/browse/KAFKA-6967
             Project: Kafka
          Issue Type: Bug
            Reporter: James Cheng


TopologyTestDriver does not allow pre-populating a state store that has logging enabled. If you try to do it, you will get the following error message:

 
{code:java}
java.lang.IllegalStateException: This should not happen as timestamp() should only be called while a record is processed
	at org.apache.kafka.streams.processor.internals.AbstractProcessorContext.timestamp(AbstractProcessorContext.java:153)
	at org.apache.kafka.streams.state.internals.StoreChangeLogger.logChange(StoreChangeLogger.java:59)
	at org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueBytesStore.put(ChangeLoggingKeyValueBytesStore.java:69)
	at org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueBytesStore.put(ChangeLoggingKeyValueBytesStore.java:29)
	at org.apache.kafka.streams.state.internals.InnerMeteredKeyValueStore.put(InnerMeteredKeyValueStore.java:198)
	at org.apache.kafka.streams.state.internals.MeteredKeyValueBytesStore.put(MeteredKeyValueBytesStore.java:117)
{code}

Also see:
https://github.com/apache/kafka/blob/trunk/streams/test-utils/src/test/java/org/apache/kafka/streams/TopologyTestDriverTest.java#L723-L740



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)