Skip to content

Conversation

@betterclever
Copy link
Contributor

This PR optimizes Kafka consumers to prevent blocking backend startup and reduces rebalance delays during restarts.

Changes:

  • Implemented non-blocking Kafka connection (background init).
  • Reduced Kafka sessionTimeout to 6s and heartbeatInterval to 2s to speed up group rebalancing.
  • Enabled NestJS shutdown hooks in main.ts to ensure consumers leave their groups gracefully.
  • Added explicit logging for Kafka disconnects.
  • Fixed a typo in workflows.service.ts.

@chatgpt-codex-connector
Copy link

You have reached your Codex usage limits for code reviews. You can see your limits in the Codex usage dashboard.

…artup delay

Signed-off-by: betterclever <paliwal.pranjal83@gmail.com>
@betterclever betterclever force-pushed the fix/kafka-startup-delay branch from 08dfe53 to 2ea4abf Compare January 20, 2026 08:33
@betterclever betterclever merged commit dc4fca7 into main Jan 20, 2026
3 checks passed
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants