Skip to content

Apply consumer config customizers to the Kafka health indicator - #3315

Open
2748109647 wants to merge 1 commit into
spring-cloud:mainfrom
2748109647:codex/2895-health-indicator-customizers
Open

2748109647 wants to merge 1 commit into
spring-cloud:mainfrom
2748109647:codex/2895-health-indicator-customizers

Conversation

@2748109647

Copy link
Copy Markdown

Resolves #2895.

The Kafka binder health indicator creates a separate consumer factory from the merged binder consumer properties. It does not currently apply the configured ConsumerConfigCustomizer beans, so settings applied to the binder's normal consumers (including SSL bundle setup) are missing from health checks.

Apply ordered consumer config customizers to the health indicator consumer and document the synthetic binding and destination names used for that consumer.

Validation:

  • ./mvnw -pl binders/kafka-binder/spring-cloud-stream-binder-kafka -am -Dtest=KafkaBinderPropertiesTest,KafkaBinderHealthIndicatorTest -Dsurefire.failIfNoSpecifiedTests=false test -P spring — passed (14 tests).

Resolves spring-cloud#2895

Signed-off-by: Alpha <2748109647@qq.com>

This branch has not been deployed

No deployments
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

Explore support for Spring Boot SslBundles support in Kafka binder

1 participant