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 J. Sax <matth...@confluent.io> wrote: > 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, 杰 杨 wrote: > > Hi all: > > When I find kafka stream api.I use it to consumer one topic and filter > data and transform to another topic . > > I foud that the progress will be done in a few minutes later? > > > > 发送自 Windows 10 版邮件<https://go.microsoft.com/fwlink/?LinkId=550986>应用 > > > > -- -- Guozhang
