Comments (6)
thynson
commented on July 20, 2024
Is this feature implemented or not?
from kafkajs.
Nevon
commented on July 20, 2024
Not to my knowledge.
from kafkajs.
tulios
commented on July 20, 2024
No, currently it drops the uncommitted offsets.
from kafkajs.
SathishKumarRamasamy
commented on July 20, 2024
@tulios : Is this issue valid for eachMessage implementation with default values of autoCommitInterval and autoCommitThreshold as well?
from kafkajs.
mark-b-ab
commented on July 20, 2024
According to Kafka Protocol it should submit uncommitted offsets before rejoining. This way it will not double process uncommitted offsets.
from kafkajs.
dardanos
commented on July 20, 2024
I was scared about this issue but found that this is already fixed in master.
See
https://github.com/tulios/kafkajs/blob/master/src/consumer/runner.js#L207-L216
from kafkajs.
Related Issues (20)
- Bumping "ip" dev dependency to latest (prevent false-positives from vulnerability scanners) HOT 1
- How to consume messages from multiple topics HOT 1
- Increate KafkaJS producer default retry
- Question: Is there a way to get the status of all consumers inside a consumer group? HOT 1
- Kafka producer.send(timeout: 1) other than 1ms- no other number seems to be working
- [readme] Community Slack invitation link is broken HOT 1
- maxBytesPerPartition not working as stated in the documentation HOT 1
- Has this project been abandoned? HOT 1
- RoundRobin Assignor doesn't acknowledge Member subscribed topics in assignment
- Is it possible to consume a topic with multiple schemas ? HOT 1
- Kafka upgrade 2.7 -> 3.6 HOT 4
- When the KafkaJS Consumer pulls messages from Kafka HOT 1
- [Question] How do I subscribe to future topics using a pattern?
- Producer failover and promise reject when a broker is disconnected
- Problems when concurrently consume from the same topic to the same consumer group id.
- Consumer can process only messages from one topic at a time HOT 3
- 消费者端无法连接到kafka，连接地址被固定
- Provide function on producer that returns partition for message key of topic
- KafkaJSRequestTimeoutError during consumption leading to partition backlog
- more than one runner with one consumer.
Recommend Projects
-
React
A declarative, efficient, and flexible JavaScript library for building user interfaces.
-
Vue.js
🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
-
Typescript
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
-
TensorFlow
An Open Source Machine Learning Framework for Everyone
-
Django
The Web framework for perfectionists with deadlines.
-
Laravel
A PHP framework for web artisans
-
D3
Bring data to life with SVG, Canvas and HTML. 📊📈🎉
-
Recommend Topics
-
javascript
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
-
web
Some thing interesting about web. New door for the world.
-
server
A server is a program made to process requests and deliver data to clients.
-
Machine learning
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
-
Visualization
Some thing interesting about visualization, use data art
-
Game
Some thing interesting about game, make everyone happy.
Recommend Org
-
Facebook
We are working to build community through open source technology. NB: members must have two-factor auth.
-
Microsoft
Open source projects and samples from Microsoft.
-
Google
Google ❤️ Open Source for everyone.
-
Alibaba
Alibaba Open Source for everyone
-
D3
Data-Driven Documents codes.
-
Tencent
China tencent open source team.
from kafkajs.