Hello,
I have run into an issue trying to upgrade a Kafka cluster from 0.8.2.1 to
0.10.2.0. The issue manifests itself in high GC time on the Kafka broker
after it starts accepting new requests.
Upon further inspection and digging through stack traces, it appears that
the Kafka 10 broker is uncom
Hi Marco,
Could you share a bit of your code, or at a minimum provide some info on:
- is userActivitiesStream and geoDataStream a KStream of KTable?
- what is the length of "timewindow"?
Thanks
Eno
> On 16 Apr 2017, at 19:44, Marco Abitabile wrote:
>
> Hi All!
>
> I need a little hint to unde
Hi All!
I need a little hint to understand how join works, in regards of stream
synchronization.
This mail is a bit long, I need to explain the issue I'm facing.
*TL-TR: *
it seems that join synchonization between stream is not respected as
explained here: https://cwiki.apache.org/confluence/dis
Hi All!
I need a little hint to understand how join works, in regards of stream
synchronization.
This mail is a bit long, I need to explain the issue I'm facing.
*TL-TR: *
it seems that join synchonization between stream is not respected as
explained here:
https://cwiki.apache.org/confluence/dis
