spring-cloud-stream-kafka: warum cachiert der KafkaBinderHealthIndicator keine consumer

Question

Was ist der Grund dafür, dass KafkaConsumer s in KafkaBinderHealthIndicator nicht zwischengespeichert wird? Letztere ist eine Bean in KafkaBinderConfiguration autoconfig erstellt, also warum nicht die Verbraucher wiederverwenden?

Wahrscheinlich kein Problem, aber fühlt sich falsch an, wenn jeder Knoten in unserem Stapel 12 Mal pro Minute für /health vom Monitor abgefragt wird.

Answer 1

Es kam nie vor einem Problem, da, sondern schuf hier ein Problem aufgetreten: https://github.com/spring-cloud/spring-cloud-stream-binder-kafka/issues/231

Potenziell könnten wir es von Spring Cloud-Stream für Version 2.0 aussehen.