confluentinc / confluentinc/confluent-kafka-javascript
How is sessionTimeout being used?
- Dominant language
- TypeScript
- Stars
- 304
- Forks
- 45
- Avg merge
- 11h 47m
- Merged PRs (30d)
- 5
Description
In the [docs for consumers](https://github.com/confluentinc/confluent-kafka-javascript/blob/master/MIGRATION.md#consumer), you have the rebalanceTimeout config:

>The maximum allowed time for each member to join the group once a rebalance has begun. Note, that setting this value also changes the max poll interval. Message processing in eachMessage/eachBatch must not take more than this time.
To me this implies that setting this, overrides/is used in place of the sessionTimeout, especially given the docs make no mention of this property.
However, [the KafkaJS ConsumerConfig type has a sessionTimeout value](https://github.com/confluentinc/confluent-kafka-javascript/blob/1beb3431b085bdeaa5d5becf5460e5c6f913ad7a/types/kafkajs.d.ts#L217) and it [appears to be using the value when creating the config for rdkafka](https://github.com/confluentinc/confluent-kafka-javascript/blob/1beb3431b085bdeaa5d5becf5460e5c6f913ad7a/lib/kafkajs/_consumer.js#L519).
I'm just wondering what is the correct usage for this?
Contributor guide
Assessment
This issue has not been assessed yet.