[CAMEL-17727] camel-kafka: add producer/consumer readiness checks

• Type: New Feature
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 3.16.0
• Component/s: camel-kafka
• Estimated Complexity: Unknown
• Assignee: Claus Ibsen
• Reporter: Luca Burgazzoli
• Created: 01/Mar/22 11:40
• Updated: 04/Mar/22 19:34
• Resolved: 04/Mar/22 19:33

Description

When a kafka broker is not reachable, the kafka client automatically tries to re-connect, as example:

2022-02-24 18:12:32,880 WARN  [org.apa.kaf.cli.NetworkClient] (Camel (camel-1) thread #1 - KafkaConsumer[test]) [Consumer clientId=consumer-c8b8rsv13hohlh07kbv0-1, groupId=c8b8rsv13hohlh07kbv0] Error connecting to node foo.bar:443 (id: 1 rack: us-east-1b): java.net.UnknownHostException: foo.bar:: Name or service not known

It would be nice if we have a consumer/producer readiness checks that can mark the application as not ready when the client is not connected.

Issue Links

• relates to: CAMEL-17749 camel-health - Allow to enabled/disable custom health checks from camel-main configuration
• links to: GitHub Pull Request #82
• links to: GitHub Pull Request #7093