kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Mahendra Kariya <mahendra.kar...@go-jek.com>
Subject Re: Debugging Kafka Streams Windowing
Date Thu, 04 May 2017 17:29:31 GMT
Hi Matthias,

Please find the answers below.

I would recommend to double check the following:
>  - can you confirm that the filter does not remove all data for those
> time periods?

Filter does not remove all data. There is a lot of data coming in even
after the filter stage.

>  - I would also check input for your AggregatorFunction() -- does it
> receive everything?

Yes. Aggregate function seems to be receiving everything.

>  - same for .mapValues()

I am not sure how to check this.

  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message