Franz Busch
Franz Busch
I am curious to where this slow down come from. Is it from how we are polling Kafka or just the fact that every `next` call on the iterator has...
I do understand the necessity to improve performance and it is something we haven't focused on yet. I agree that the first step would be to setup a benchmarking target...
Thanks for reporting this. @axelandersson what OS are you trying to build this library on?
Ah you updated the `librdkafka` version. If you don't do `git submodule update --remote` then it should build fine. @felixschlegel we gotta check why it fails on the latest `librdkafka`...
> @FranzBusch anything we can do to help out here? Would appreciate a PR for it. I think the solution should be as easy as doing something like this `#define...
@felixschlegel Can you check this?
Can we ever recover from a partition EOF error? Like does this happen during rebalance or is this really a terminal state
Ah right, it is just when we hit the end of the partition and then we can still continue once more messages have been produced. So finishing the sequence is...
The second part should already be possible. Why can't you write `catch let error as KafkaError where error.code == .onePossibleRdKafkaError`? The errors codes are defined as `static let`s and the...
I think we should definitely take those properties of the rd kafka errors into consideration but I don't think we should expose the rd kafka error in a nicer way....