feat(kafka): add client consumer config for rebalancing timeout

[overbit]

Close: #6062

PR Details

🤖 Generated by Copilot at 938f2c0

Summary

🆕🕑🔄

Added a new rebalanceTimeout option to the NestJS Kafka module configuration, based on the consumer session timeout from the KafkaEnv class. This option controls how long a consumer group waits for members to join in a rebalance.

KafkaEnv knows
consumer rebalance timeout
twice the session time

Walkthrough

• Add rebalanceTimeout property to KafkaConfig interface to configure the maximum time for consumer group rebalancing (link)
• Implement getConsumerRebalanceTimeout method in KafkaEnv class to return twice the consumer session timeout (link)
• Use getConsumerRebalanceTimeout method to set the rebalanceTimeout property in createNestjsKafkaConfig function, which creates the options for the NestJS Kafka module in libs/util/nestjs/kafka/src/createNestjsKafkaConfig.ts (link, link)

PR Checklist

• Tests for the changes have been added
• npm test doesn't throw any error

IMPORTANT: Please review the CONTRIBUTING.md file for detailed contributing guidelines.

[nx-cloud]

☁️ Nx Cloud Report

CI is running/has finished running commands for commit 938f2c0. As they complete they will appear below. Click to see the status, the terminal output, and the build insights.

📂 See all runs for this branch

---

✅ Successfully ran 5 targets

• nx e2e amplication-server --prod
• nx affected --target=test --parallel=3 --coverage --coverageReporters=text-summary
• nx affected --target=postbuild --parallel=3
• nx affected --target=build --parallel=3
• nx affected --target=lint --parallel=3

---

Sent with 💌 from NxCloud.