From 1fbb6f250ebad89a24301644b738fa0b1ca7eb87 Mon Sep 17 00:00:00 2001
From: Soby Chacko <schacko@pivotal.io>
Date: Tue, 19 Jan 2021 11:01:36 -0500
Subject: [PATCH] Make health indicator beans public

Currently, the health indicator beans for both binders are not
customizable due to package visibility issues. Making them public.

Resolves https://github.com/spring-cloud/spring-cloud-stream-binder-kafka/issues/1015
---
 .../KafkaStreamsBinderHealthIndicatorConfiguration.java       | 4 ++--
 .../kafka/config/KafkaBinderHealthIndicatorConfiguration.java | 4 ++--
 2 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsBinderHealthIndicatorConfiguration.java b/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsBinderHealthIndicatorConfiguration.java
index 62d77a241..9a00526d9 100644
--- a/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsBinderHealthIndicatorConfiguration.java
+++ b/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsBinderHealthIndicatorConfiguration.java
@@ -33,10 +33,10 @@ import org.springframework.context.annotation.Configuration;
 @Configuration
 @ConditionalOnClass(name = "org.springframework.boot.actuate.health.HealthIndicator")
 @ConditionalOnEnabledHealthIndicator("binders")
-class KafkaStreamsBinderHealthIndicatorConfiguration {
+public class KafkaStreamsBinderHealthIndicatorConfiguration {
 
 	@Bean
-	KafkaStreamsBinderHealthIndicator kafkaStreamsBinderHealthIndicator(
+	public KafkaStreamsBinderHealthIndicator kafkaStreamsBinderHealthIndicator(
 			ObjectProvider<KafkaStreamsRegistry> kafkaStreamsRegistry,
 			@Qualifier("binderConfigurationProperties")KafkaStreamsBinderConfigurationProperties kafkaStreamsBinderConfigurationProperties,
 			KafkaProperties kafkaProperties, KafkaStreamsBindingInformationCatalogue kafkaStreamsBindingInformationCatalogue) {
diff --git a/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/config/KafkaBinderHealthIndicatorConfiguration.java b/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/config/KafkaBinderHealthIndicatorConfiguration.java
index c991c6caa..dd2dc5702 100644
--- a/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/config/KafkaBinderHealthIndicatorConfiguration.java
+++ b/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/config/KafkaBinderHealthIndicatorConfiguration.java
@@ -43,10 +43,10 @@ import org.springframework.util.ObjectUtils;
 @Configuration
 @ConditionalOnClass(name = "org.springframework.boot.actuate.health.HealthIndicator")
 @ConditionalOnEnabledHealthIndicator("binders")
-class KafkaBinderHealthIndicatorConfiguration {
+public class KafkaBinderHealthIndicatorConfiguration {
 
 	@Bean
-	KafkaBinderHealthIndicator kafkaBinderHealthIndicator(
+	public KafkaBinderHealthIndicator kafkaBinderHealthIndicator(
 			KafkaMessageChannelBinder kafkaMessageChannelBinder,
 			KafkaBinderConfigurationProperties configurationProperties) {
 		Map<String, Object> props = new HashMap<>();