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)
