Update for next development version

Tag release

README.md

@@ -12,7 +12,7 @@ Add the following dependency to your `pom.xml`
 <dependency>
     <groupId>me.bvn13.kafka.health</groupId>
     <artifactId>kafka-health-check</artifactId>
-    <version>1.5.0</version>
+    <version>1.5.5</version>
 </dependency>
 ```
 
@@ -66,12 +66,13 @@ Now if you call the actuator endpoint `actuator/health` you should see the follo
 ## Configuration
 
 
-| Property                           | Default          | Description                                                                                                                                                                                                                                                |
-|------------------------------------|------------------|------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|
-| kafka.health.topic                 | `health-checks`  | Topic to subscribe to                                                                                                                                                                                                                                      |
-| kafka.health.sendReceiveTimeout    | 2.5s             | The maximum time, given as [Duration](https://docs.spring.io/spring-boot/docs/2.1.9.RELEASE/reference/html/boot-features-external-config.html#boot-features-external-config-conversion-duration), to wait for sending and receiving the message. |
-| kafka.health.pollTimeout           | 200ms            | The time, given as [Duration](https://docs.spring.io/spring-boot/docs/2.1.9.RELEASE/reference/html/boot-features-external-config.html#boot-features-external-config-conversion-duration), spent fetching the data from the topic                           |
-| kafka.health.cache.maximumSize     | 200              | Specifies the maximum number of entries the cache may contain.                                                                                                                                                                                             |
+| Property                        | Default         | Description                                                                                                                                                                                                                                     |
+|---------------------------------|-----------------|-------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|
+| kafka.health.enabled            | false           | Enabling kafka health check                                                                                                                                                                                                                     |
+| kafka.health.topic              | `health-checks` | Topic to subscribe to                                                                                                                                                                                                                           |
+| kafka.health.sendReceiveTimeout | 2.5s            | The maximum time, given as [Duration](https://docs.spring.io/spring-boot/docs/2.1.9.RELEASE/reference/html/boot-features-external-config.html#boot-features-external-config-conversion-duration), to wait for sending and receiving the message.|
+| kafka.health.pollTimeout        | 200ms           | The time, given as [Duration](https://docs.spring.io/spring-boot/docs/2.1.9.RELEASE/reference/html/boot-features-external-config.html#boot-features-external-config-conversion-duration), spent fetching the data from the topic                |
+| kafka.health.cache.maximumSize  | 200             | Specifies the maximum number of entries the cache may contain.                                                                                                                                                                                  |
 
 
 

changelog.md

@@ -1,9 +1,16 @@
 # KafkaHealthCheck
 
+## Version 1.5.3
+
+* Added SpringBootAutoConfiguration
+
+## Version 1.5.2
+
+* Changed maven group publication: switched into `me.bvn13.kafka.health`
+
 ## Version 1.4.0
 
 * Got rid of `subscriptionTimeout` as a redundant timeout
-* Changed maven group publication: switched into `me.bvn13.kafka.health`
 
 ## Version 1.3.0
 

pom.xml

@@ -6,7 +6,7 @@
 
 	<groupId>me.bvn13.kafka.health</groupId>
 	<artifactId>kafka-health-check</artifactId>
-	<version>1.5.2</version>
+	<version>1.5.6-SNAPSHOT</version>
 	<packaging>jar</packaging>
 
 	<name>Kafka Health Check</name>
@@ -114,7 +114,7 @@
 						<gitFlowConfig>
 							<developmentBranch>develop</developmentBranch>
 						</gitFlowConfig>
-						<incrementVersionAtFinish>false</incrementVersionAtFinish>
+						<incrementVersionAtFinish>true</incrementVersionAtFinish>
 						<versionDigitToIncrement>2</versionDigitToIncrement>
 					</configuration>
 				</plugin>

src/main/java/me/bvn13/kafka/health/KafkaHealthAutoConfiguration.java

@@ -0,0 +1,32 @@
+package me.bvn13.kafka.health;
+
+import org.springframework.boot.actuate.health.AbstractHealthIndicator;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
+import org.springframework.boot.autoconfigure.kafka.KafkaProperties;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+@ConditionalOnClass(AbstractHealthIndicator.class)
+@ConditionalOnProperty(name = "kafka.health.enabled", havingValue = "true")
+public class KafkaHealthAutoConfiguration {
+
+	@Bean
+	@ConditionalOnMissingBean(KafkaHealthProperties.class)
+	@ConfigurationProperties("kafka.health")
+	public KafkaHealthProperties kafkaHealthProperties() {
+		return new KafkaHealthProperties();
+	}
+
+	@Bean
+	@ConditionalOnMissingBean(KafkaConsumingHealthIndicator.class)
+	public KafkaConsumingHealthIndicator kafkaConsumingHealthIndicator(KafkaHealthProperties kafkaHealthProperties,
+			KafkaProperties kafkaProperties) {
+		return new KafkaConsumingHealthIndicator(kafkaHealthProperties, kafkaProperties.buildConsumerProperties(),
+				kafkaProperties.buildProducerProperties());
+	}
+
+}

src/main/resources/META-INF/spring.factories

@@ -0,0 +1 @@
+org.springframework.boot.autoconfigure.EnableAutoConfiguration=me.bvn13.kafka.health.KafkaHealthAutoConfiguration