checkfleet

Apache Kafka check

kafka — Apache Kafka

Controller present, broker count, under-replicated partitions, and consumer-group lag.

checkfleet check kafka --config checkfleet.yml

Kafka cluster health via franz-go/kadm (admin metadata only).

  • Metadata unreachable → ERROR; no controller → BAD; fewer than expect_brokers → WARN.
  • Any under-replicated partition (ISR < replicas) → BAD.
  • Per consumer group in groups: total lag past lag_warn/lag_crit → WARN/BAD.

Findings: cluster, partitions, group/<name>. Optional TLS and SASL (plain/scram); the SASL password comes from sasl_password_env, never config. The Kafka I/O is behind an interface, so the finding logic is unit-tested with a fake — no real broker in tests.

See Configuration → checks.kafka.

See the full module reference for every check, or configuration for the config keys.