confluentinc / confluentinc/confluent-kafka-javascript

How is sessionTimeout being used?

Open
#283 3 comments 0 reactions 0 assignees View on GitHub
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:
![Image](https://github.com/user-attachments/assets/4dd8f164-3516-4f1c-a465-180350eb365c)

>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

Open the contributing guide

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.