[jira] [Created] (KAFKA-5824) Cannot write to key value store provided by ProcessorTopologyTestDriver

[Dmitry Minkovsky (JIRA)]

Dmitry Minkovsky created KAFKA-5824:
---------------------------------------

             Summary: Cannot write to key value store provided by 
ProcessorTopologyTestDriver
                 Key: KAFKA-5824
                 URL: https://issues.apache.org/jira/browse/KAFKA-5824
             Project: Kafka
          Issue Type: Bug
          Components: streams
    Affects Versions: 0.11.0.0
            Reporter: Dmitry Minkovsky


I am trying to `put()` to a KeyValueStore that I got from 
ProcessorTopologyTestDriver#getKeyValueStore() as part of setup for a test. The 
JavaDoc endorses this use-case:

     * This is often useful in test cases to pre-populate the store before the 
test case instructs the topology to
     * {@link #process(String, byte[], byte[]) process an input message}, 
and/or to check the store afterward.

However, the `put()` results in the following error: 

{{
java.lang.IllegalStateException: This should not happen as offset() should only 
be called while a record is processed

        at 
org.apache.kafka.streams.processor.internals.AbstractProcessorContext.offset(AbstractProcessorContext.java:139)
        at 
org.apache.kafka.streams.state.internals.CachingKeyValueStore.put(CachingKeyValueStore.java:193)
        at 
org.apache.kafka.streams.state.internals.CachingKeyValueStore.put(CachingKeyValueStore.java:188)
        at 
pony.UserEntityTopologySupplierTest.confirm-settings-requests(UserEntityTopologySupplierTest.groovy:81)
}}

This error seems straightforward: I am not doing the `put` within the context 
of stream processing. How do I reconcile this with the fact that I am trying to 
populate the store for a test, which the JavaDoc endorses?

Thank you,
Dmitry



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)