David Blewett

@tzachshabtay I'm not aware of a template, no. However, there are several examples of different functionality in the repo. You could adapt one that illustrates the problem you're seeing (...

@tzachshabtay thanks! I'll take a look at this during my next support rotation (in a few weeks).

> This occurs when Kafka returns an error code that is as-yet unknown to librdkafka/rust-rdkafka. I suspect it's been resolved by the recent librdkafka bump, though is likely to happen...

Good to know. I'm going to keep this open until we come to a consensus on how to handle the enum issue.

@edenhill any thoughts on this? While it might be feasible to wrap calls to these APIs in an async context, it won't be the most efficient and could cause complications...

@arnauorriols the result of `setup()` is passed directly to `routine`, which simplifies the type signature: ```rust pub fn iter_batched(&mut self, mut setup: S, mut routine: R, size: BatchSize) where S:...

Here is a very simple implementation I was experimenting with: https://gist.github.com/davidblewett/7340369 . And using it: https://gist.github.com/davidblewett/7340385 . In my case, I will be also writing a web service to extract...

Closed in favor of https://github.com/fede1024/rust-rdkafka/pull/583 .

@BurntSushi : can you give me an example of doing this in Rust? I can probably figure out how to translate it to Python/cffi. I'm wondering if we'd to add...

@BurntSushi : I was looking at that, but the regex bit did indeed throw me off. I was looking more closely at `OpBuilder`; it appears to aggregate calls across multiple...