Hi Garrett,
I've encountered a similar challenge in a project I'm working on (it's
still work in progress, so please take my suggestions with a grain of salt).
Yes, I believe KTable.groupBy lets you accomplish what you are aiming
for with something like the following (same snippet attached as
Hi all,
I am relatively new to kafka and my initial attempts at consuming messages are
failing. My topic has 3 partitions and I am setting "auto.offset.reset" to
"earliest". The call to poll hangs. Here's my code:
**
Upgrading to 0.10.2.1 seems to have fixed the issue.
Until now, we were looking at random 1 hour data to analyse the issue. Over
the weekend, we have written a simple test that will continuously check for
inconsistencies in real time and report if there is any issue.
No issues have been reported
