@Matthias J. Sax / All
Have added below line :
> .suppress(Suppressed.untilWindowCloses(Suppressed.BufferConfig.unbounded()))
>
>
Here is the output : (for uuid (*2cbef750-325b-4a2f-ac39-b2c23fa0313f)*,
expecting single output but that is not the case here. Which 1 is the final
output from those
Thanks for reporting this.
Are you interested in submitting a PR to fix it?
Guozhang
On Wed, May 18, 2022 at 7:26 AM Владимир Савостин
wrote:
> In section https://kafka.apache.org/quickstart#quickstart_kafkaconnect
> you should change plugin path from lib/connect-file-3.2.0.ja to
> libs/connec
Emitting intermediate result is by-design.
If you don't want to get intermediate result, you can add `suppress()`
after the aggregation and configure it to only "emit on window close".
-Matthias
On 5/17/22 3:20 AM, Shankar Mane wrote:
Hi All,
Our use case is to use sliding window. (for e.g.
Hi
Good evening from India😃
I am using Kafka(confluent Platform) since long time.
Its actually a message broker in simple term which can persist data on disk
for short time in days or weeks.
It acts like a buffer in between message producer and message consumer.
Kafka reduces loading of consumers b
Subject: What does Apache Kafka do?
Good day from Singapore,
I notice my company/organization is using Apache Kafka. What does it do?
Just being curious.
Regards,
Mr. Turritopsis Dohrnii Teo En Ming
Targeted Individual in Singapore
18 May 2022 Wed
In section https://kafka.apache.org/quickstart#quickstart_kafkaconnect
you should change plugin path from lib/connect-file-3.2.0.ja to
libs/connect-file-3.2.0.ja
Have a nice day!
