Milind L
Milind L
This is correct, at the moment, pause() can't be called from within the rebalance callback. The current logic for when we receive partition assignments from the broker is: call user...
We discussed this within the team, we'll be exposing assign/unassign and their incremental variants to allow for this use case, so you'll be able to pause within the rebalance cb....
Alright, I merged a PR which allows doing this, something like so: ```js rebalance_cb: function (err, assignment, assignmentFns) { if (err.code === ErrorCodes.ERR__ASSIGN_PARTITIONS) { /* Assign first so we can...
Closing with release 0.1.17-devel - now, the feature in the above comment can be used.
Yep, that makes sense, I'll throw an error and add it to the migration guide, because we definitely don't want to trip people up without warning.
I made the change to remedy this, it'll be present in the next release.
Closing with release 0.1.17-devel
Hey Achim, thanks for the feedback. At this moment, there is no timeline for including these particular AdminAPI within librdkafka. I'll discuss this with the team internally and see if...
Hey @dermasmid , you should be getting a thrown error if you are awaiting producer.send, or a promise rejection if you are using "catch" on the promise returned by producer.send....
Ah, okay, there is one more possibility. For any produce requests, there are two timeouts, the `socket.timeout.ms`, and the `delivery.timeout.ms`. The first one is on a per-protocol-message basis. If a...