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)