Hello Jie,
Could you provide some more details in your "transformation" logic? For
example did you use any state stores? Note that if caching is enabled (by
default it is), then you may not see outputs until the cache is flushed
during commit.
Guozhang
On Wed, Aug 23, 2017 at 12:31 PM, Matthias
Not sure what your question is...
Maybe you refer to commit interval that is 30 seconds by default. It
could be, that you don't see any writes to the output topic before that.
But it's a wild guess.
You can try to set a shorter commit interval via StreamsConfig.
-Matthias
On 8/22/17 8:09 PM, 杰
