Assaf O

Regarding the timeout issue @kzay reported above, like: _KafkaJSLockTimeout: Timeout while acquiring lock (2162 waiting locks): "updating target topics"_ It looks like this specific lock timeout error is coming from...

@tulios , need to fix few tests that check the amount of calls to 'refreshMetadata' which is now reduced. Does this change make sense?

@t-d-d , if 'addMultipleTargetTopics' will be removed, yes, there is no need for this PR, but I see that #667 is in code review for months.

@t-d-d , I don't see any progress with #667

Both 'decode' and 'toObject' return the field as an empty array. So the root cause might be on the 'decode' implementation. I'm using 'toObjcet' without setting the 'bytes' option (I...

Any reason that there isn't an official image with updated spark version for over a year now? Is the spark operator properly maintained?