<commit_before># Kafka Health Check 

Health checker for Kafka that operates by inserting a message in a dedicated health check topic and waiting for it to
become available on the consumer side.

## Status
[![Build Status](https://travis-ci.org/andreas-schroeder/kafka-health-check.svg?branch=master)](https://travis-ci.org/andreas-schroeder/kafka-health-check)

## Usage

```
kafka-health-check usage:
  -broker-id uint
    	id of the Kafka broker to health check
  -broker-port uint
    	Kafka broker port (default 9092)
  -server-port uint
    	port to open for http health status queries (default 8000)
  -topic string
    	name of the topic to use - use one per broker, defaults to broker-<id>-health-check
  -zookeeper string
    	ZooKeeper connect string (e.g. node1:2181,node2:2181,.../chroot)
```

## Supported Kafka Versions

Tested with the following Kafka versions:

* 0.9.0.1

## Building

Run `make` to build after running `make deps` to restore the dependencies.

### Prerequisites

* Make to run the [Makefile](Makefile)
* [Go 1.6](https://golang.org/dl/) since it's written in Go
* [Go dep](https://github.com/tools/godep) for dependency management. To install, `go get github.com/tools/godep`<commit_msg>updating readme for govendor migration.<commit_after># Kafka Health Check 

Health checker for Kafka that operates by inserting a message in a dedicated health check topic and waiting for it to
become available on the consumer side.

## Status
[![Build Status](https://travis-ci.org/andreas-schroeder/kafka-health-check.svg?branch=master)](https://travis-ci.org/andreas-schroeder/kafka-health-check)

## Usage

```
kafka-health-check usage:
  -broker-id uint
    	id of the Kafka broker to health check
  -broker-port uint
    	Kafka broker port (default 9092)
  -server-port uint
    	port to open for http health status queries (default 8000)
  -topic string
    	name of the topic to use - use one per broker, defaults to broker-<id>-health-check
  -zookeeper string
    	ZooKeeper connect string (e.g. node1:2181,node2:2181,.../chroot)
```

## Supported Kafka Versions

Tested with the following Kafka versions:

* 0.9.0.1

## Building

Run `make` to build after running `make deps` to restore the dependencies using [govendor](https://github.com/kardianos/govendor).

### Prerequisites

* Make to run the [Makefile](Makefile)
* [Go 1.6](https://golang.org/dl/) since it's written in Go
{'fraction_non_alphanumeric': 0.10820895522388059, 'fraction_numerical': 0.01990049751243781, 'mean_word_length': 3.874747474747475, 'pattern_counts': {'":': 0, '<': 5, '<?xml version=': 0, '>': 5, 'https://': 8, 'lorem ipsum': 0, 'www.': 0, 'xml': 0}, 'pii_count': 2, 'substrings_counts': 0, 'word_list_counts': {'cursed_substrings.json': 0, 'profanity_word_list.json': 0, 'sexual_word_list.json': 0, 'zh_pornsignals.json': 0}}
{'dir': 'git-commits-cleaned', 'id': '3533841', 'n_tokens_mistral': 825, 'n_tokens_neox': 773, 'n_words': 263}