[jira] [Created] (KAFKA-3555) Unexpected close of KStreams transformer

["Anna Povzner (JIRA)" <ji...@apache.org>]

Anna Povzner created KAFKA-3555:
-----------------------------------

             Summary: Unexpected close of KStreams transformer 
                 Key: KAFKA-3555
                 URL: https://issues.apache.org/jira/browse/KAFKA-3555
             Project: Kafka
          Issue Type: Bug
          Components: streams
    Affects Versions: 0.10.0.0
            Reporter: Anna Povzner
            Assignee: Guozhang Wang


I consistently get this behavior when running my system test that runs 1-node kafka cluster.

We implemented TransformerSupplier, and the topology is transform().filter().map().filter().aggregate(). I have a log message in my transformer's close() method. On every run of the test, I see that after running 10-20 seconds, transformer's close() is called. Then, in about 20 seconds, I see that transformer is re-initialized and continues running.

I don't see any exceptions happening in KStreams before close() happens.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)