Module: Pigeon::HealthCheck::Kafka

Defined in:
lib/pigeon/health_check/kafka.rb

Overview

Kafka health check functionality

Class Method Summary collapse

Class Method Details

.health ⇒ Hash

Check the health of Kafka connectivity

Returns:

  • (Hash) —

    Health check result



9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
 
# File 'lib/pigeon/health_check/kafka.rb', line 9

def self.health
  # Try to connect to Kafka
  begin
    # Use Karafka producer to check connectivity
    Pigeon.karafka_producer.produce_sync("health_check", topic: "health_check", key: "health_check")

    status = "healthy"
    message = "Kafka connection is healthy"
    details = { connected: true }
  rescue StandardError => e
    status = "critical"
    message = "Failed to connect to Kafka: #{e.message}"
    details = {
      connected: false,
      error_class: e.class.name,
      error_message: e.message
    }
  end

  {
    component: "kafka",
    status: status,
    message: message,
    details: details
  }
end