Antony Stubbs

Hi, yes it's supposed to be when the processing is going faster than records can be queued up for processing - which is usually an indication of something going wrong....

How often has this happened? Are you able to reproduce it? Was throughput going slow when this happened? It's a relatively arbitrary max for the loading factor - but usually...

So when this happens - no messages are getting processed? That's not what I expected 🤔 > flag ah - if this flag is set, your function returns immediately, without...

Which version are you running? Are you not getting any failed processing logs? Can you show your processing code?

yes, sure we can do that - please email me directly, or contact me on community slack.

relates to: #53

What version did you use?

> However, is there any such limitation of parallel consumer wherein the maxConcurrency, if greater than number of unique keys in the topic, would cause any inconsistency issues while processing...

Hi @pdeole , Current threw a spanner in the works! I'm just finished working on a couple other things for PC, and will look more closely at this, this week....

When you say: > No lag seen on the PC but **computation end results** are lesser than expected to that of regular kafka consumer. What exactly do you mean by...