Repository navigation
confluentinc#71: Health-checks #126
Description
Mirror of confluentinc/parallel-consumer#71
Opened by JorgenRingen, 2021-01-20 · 3 comments upstream · last upstream activity 2022-11-01
Summarised, not copied. Discussion belongs here - the Confluent-hosted repository is no
longer maintained and may be archived.
Summary
Kafka Streams exposes KafkaStreams#state, which the reporter uses for health checks: healthy while created/rebalancing/running, otherwise restart the app. In PC they had to approximate it with isClosedOrFailed() == false, and ask whether a purpose-built health-check abstraction belongs on the ParallelConsumer interface.
Fork status
Not started. There is no health-check API in the codebase - no HealthCheck type, no
isHealthy(). The approximation in the report, isClosedOrFailed(), is still the only option.
Adjacent: PC exposes Micrometer metrics (see #125), so a liveness signal can be built from those
today, but that is not the purpose-built abstraction this issue asks for.
Unmerged work
confluentinc/parallel-consumer#464 - Feature: Health check and metrics.
Closed unmerged, but not rejected: around 40 of the 53 open PRs were closed on a single day, 2023-06-15, when the maintainer left Confluent. That was an administrative sweep, not a review outcome. The fork's src/docs/development/upstream-pr-analysis.adoc catalogues them as revival candidates.
Ranked A1 - the top revival candidate in the fork's analysis. So this is not a blank sheet: there is an implementation to start from, and it pairs with the metrics work that later shipped separately (#125).
Activity
astubbs commentedon Aug 6, 2026
This is the half that did not land.
confluentinc#464was written to close both this issue and astubbs#125 (confluentinc#27, Micrometer metrics) - its body references both. But#464was superseded, and the PR that finally merged, confluentinc#613, shipped metrics only.So metrics arrived in 0.5.2.6 and #125 is closed; health-checks did not, and there is no health-check surface anywhere in
src/maintoday. This issue is the genuinely remaining work of the original pair.Full map of the four things called "metrics" here: astubbs#125.
[-]upstream #71: Health-checks[/-][+]confluentinc#71: Health-checks[/+]astubbs commentedon Aug 7, 2026
PR inbound
fix(test) #126: await the terminal state, not just the recorded cause
docs(api) #126: record the deprecation version in Javadoc
docs: index every TODO/FIXME/XXX marker, triage into the existing ref…