Túlio Ornelas

Results 41 comments of Túlio Ornelas

Can you check the size of the message at offset `484158`? What is the format of the messages, JSON, Avro, etc.? I've seen this issue many times when you configure...

I was looking into this issue and we definitely changed the behavior on 1.14, but it's for the better. Without the changes, you would never be able to stop the...

@crobinson42 try `1.15` but the cause is very likely to be you not connecting the producer, this was always a requirement but somehow worked on `1.12`, give `1.15` a try...

I think this is related to #555; I am currently investigating the issue

Nice, let's spec this change and have a project to track the progress.

@WaleedAshraf this is not a KafkaJS limitation, consumer groups can subscribe to multiple topics, but all consumers within the group have to subscribe to the same topics. The concept of...

Just mapping some of the work required, we would need to support protocols `JoinGroup` v5, `SyncGroup` v3 (potentially up to v5), `OffsetCommit` v4, v5, v6, and v7 (potentially v8), `Heartbeat`...

I am trying to fix this now; I can reproduce the case locally. KafkaJS is doing the right thing, but taking the OS 10 minutes to realize that the connection...

@Nevon I made it work in a simple way, since we have keep alive, the socket was receiving the correct signal. Still, it wasn't propagating it correctly since we would...

> We should only update the lastRequest if the heartbeat actually succeeded. This is already the case @Nevon > If the promise rejects, should we reject all waiting promises as...