kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Hamza HACHANI <hamza.hach...@supcom.tn>
Subject windowing with the processor api
Date Wed, 02 Nov 2016 08:19:20 GMT
Hi,

I would like to know if somebody has an idea how to define the size of the window in the processor
api.

I've been blocked for 6 days looking for a solution.

using :

Stores.create(...).withStringKeys().withStringValues().persistent().windowed(...).build()

I was able to define the retention time but not the the size of the window.

Please help me if possible.

Thanks,

Hamza

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