Tommy Brunn

You cannot have different consumers in the same consumer group be subscribed to different topics. If they are subscribing to different topics, they should not be in the same consumer...

This is how Kafka consumer groups work.

So I looked into this a bit more, to try to understand how they have achieved this, and I think I understand now how they've done this in the Java...

Took a stab this morning just to see if this might be an easy thing to implement, and it's _almost_ easy. Thought I'd jot down what I learned before I...

The problem is that there is no way you can deduce that just from events, because "working as expected" is a business metric, not a technical one. Yes, you can...

Pushed a branch where I removed the `topic: string` argument from `consumer.subscribe`, which is replaced by `topics: string[]` but I'm waffling back and forth on whether or not it's a...

Can you reproduce this in 2.0.1? If yes, please share the raw buffer. The easiest way to get it is probably to put a breakpoint here: https://github.com/tulios/kafkajs/blob/master/src/protocol/requests/fetch/v11/response.js#L48 and then copy...

What's the property of the corresponding Java client that governs this? I can't find any reference to it in the docs, nor could I find anything for librdkafka.

`socket.connection.setup.timeout.ms` would not be equivalent to `connectionTimeout`, since `socket.connection.setup.timeout.ms` includes the SASL authentication as well. In KafkaJS, `connectionTimeout` is just the socket connection timeout - nothing to do with authentication....

I actually already bumped it to a static 10s, and forgot to reference this issue. My reasoning is in https://github.com/tulios/kafkajs/pull/1340, but essentially if we set it to 30s now it'll...