kafkajs

kafkajs copied to clipboard

alee101

Microservice Stopped Consuming Silently

6

**Describe the bug** We noticed that one of our microservices had stopped consuming events silently for about a day. This was fixed by manually restarting the service but we need...

Blutude

KafkaJS claims a broker does not host a topic-partition, even though it does

42

**Describe the bug** I receive lots of error messages like the following: ``` { "level": "ERROR", "timestamp": "2020-07-15T16:48:34.740Z", "logger": "kafkajs", "message": "[Connection] Response Metadata(key: 3, version: 5)", "broker": "aws_msk_host_1:9092", "clientId":...

mgirard772

Calling consumer.run followed immediately by consumer.stop will cause the process to hang

4

**Describe the bug** Calling `consumer.run` and then immediately following that call with `consumer.stop` will cause the Node process to hang. Example code: **To Reproduce** ```js const consumer = kafka.consumer({ groupId:...

boblauer

@Nevon even with this fix https://github.com/tulios/kafkajs/pull/1402 problem exist. When we have no `nodeIds` `const fetchers = nodeIds.map(nodeId =>` map get ignored. And we still get infinite loop Fixes #1384

pravin-raha

arrayString is wrong.

8

I use `Array` as a value. But The uint8Array is treated as string. ```js function arrayString(val) { var result = '{' for (var i = 0; i < val.length; i++)...

yjhmelody

Rebalancing strategy: COOPERATIVE

7

**Is your feature request related to a problem? Please describe.** When in this scenario: Broker has a topic with 2 partitions, we have two application instances which has same group...

chengB12

Consumer#unsubscribe() "missing"

6

**Is your feature request related to a problem? Please describe.** There doesn't seem to be a way to unsubscribe from a topic in a consumer. **Describe the solution you'd like**...

ankon

**Describe the bug** In my application I am using kafkajs. The issue I am facing that when I start my docker I see none of the topics getting subscribe from...

ppb1984

Producer is disconnected automatically while transaction.

1

const { Kafka } = require('kafkajs'); const client = new Kafka({ clientId: "transactional_client", brokers: ["localhost:9092", "localhost:9093", "localhost:9094"], retry: { initialRetryTime: 100, retries: 8 } }); const producer = client.producer({ transactionalId:...

Anshshah-1609