Skip to content

Conversation

QuentinRillet
Copy link

@QuentinRillet QuentinRillet commented Apr 29, 2025

Add Kafka Health Check Backend
This pull request introduces a new [KafkaHealthCheck backend to the project. The health check verifies the connectivity and availability of a Kafka broker by:

  • Importing and validating the presence of the kafka-python or kafka-python-ng library.
  • Using KafkaAdminClient to connect to the Kafka broker specified in the KAFKA_URL Django setting.
  • Performing a lightweight ping by listing Kafka topics to ensure the broker is responsive.

Notes:
Requires kafka-python or kafka-python-ng to be installed.
Includes error handling for missing libraries or invalid configurations.
This addition enhances the monitoring capabilities of the project by providing support for Kafka-based systems.

@QuentinRillet QuentinRillet force-pushed the feat_add_kafka_healthcheck branch from ca160e7 to 5f2475f Compare April 29, 2025 11:28
@QuentinRillet QuentinRillet changed the title feat: add kafka healthcheck draft: feat: add kafka healthcheck Apr 29, 2025
@QuentinRillet QuentinRillet marked this pull request as draft April 29, 2025 11:38
@QuentinRillet QuentinRillet force-pushed the feat_add_kafka_healthcheck branch from 5f2475f to aadb1da Compare April 29, 2025 12:02
@QuentinRillet QuentinRillet marked this pull request as ready for review April 29, 2025 12:02
@QuentinRillet QuentinRillet force-pushed the feat_add_kafka_healthcheck branch from aadb1da to 69fb1f5 Compare April 29, 2025 12:45
@QuentinRillet QuentinRillet changed the title draft: feat: add kafka healthcheck feat: add kafka healthcheck Apr 30, 2025
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.

1 participant