Multi-broker list

Support broker failover, you can now specify multiple brokers in the configuration using YAML array syntax.

The new mechanism will cycle through the next broker in the list if it’s sees connection failure on the current one. The failed broker is added to the end of the queue to be re-tried if all other brokers can’t be reached as well.

Please note this is not the same as bootstrap.servers as it is can’t do dynamic discovery of new brokers; this is as stated earlier a limitation of the required Kafka API used for this system.

Maven central version: 0.0.3

https://oss.sonatype.org/service/local/repositories/comsrotya-1058/content/com/srotya/monitoring/kafka-lag-monitor/0.0.3/kafka-lag-monitor-0.0.3.jar

<dependency>
  <groupId>com.srotya.monitoring</groupId>
  <artifactId>kafka-lag-monitor</artifactId>
  <version>0.0.3</version>
</dependency>