confluentinc / confluentinc/confluent-kafka-javascript
Errors are not sent back to the caller
- Dominant language
- TypeScript
- Stars
- 304
- Forks
- 45
- Avg merge
- 11h 47m
- Merged PRs (30d)
- 5
Description
im using the kafkaJs variant and `producer.send` and i was observing logs like this that were not send back to the caller.
```
timestamp: 1717074105728
fac: 'REQTMOUT',
message: '[thrd:sonic-cluster-broker-1.kafka.internal.triplestack.io:9092/1]: sonic-cluster-broker-1.kafka.internal.triplestack.io:9092/1: Timed out 2 in-flight, 0 retry-queued, 0 out-queue, 0 partially-sent requests',
```
Contributor guide
Research direction
Start by reproducing the kafkaJs producer.send call with the reported REQTMOUT timeout log and trace how that failure is handled. Compare the observed logs with what the caller receives; done means the timeout error is propagated back to the caller.
Written by the indexing model from the issue text.
Assessment
- Tech stack
- kafka, typescript
- Domain
- distributed-systems
- Issue type
- Bug
- Difficulty
- 4/5
- Estimated time
- 3-5 days
- Activity status
- Stale
- Clarity
- Needs clarification
- Newbie friendliness
- 35/100