- This library is primarily documented through examples in its[API documentation](https://docs.rs/kafka/).

- Documentation about Kafka itself can be found at[its project home page](http://kafka.apache.org/).

Thank you to our sponsors, this helps me to spend more time on this project and also helps with infrastructure

<table>

<tr>

<td>

<imgwidth="1000"height="0">

<imgsrc="https://raw.githubusercontent.com/upstash/sponsorship/master/kafka.png"alt="Upstash"width="260"align="right">

</a>

<h3>Upstash: Serverless Kafka</h3>

<ul>

</ul>

[Start for free in 30 seconds!](https://upstash.com/?utm_source=kafka-rust)

</td>

</tr>

</table>

This crate works with Cargo and is on

version:'2'

services:

zookeeper:

image:wurstmeister/zookeeper:3.4.6

set -e

stop_docker() {

docker-compose down

dockercompose down

}

start_docker() {

docker-compose pull

docker-compose build kafka

docker-compose up -d zookeeper kafka

dockercompose pull

dockercompose build kafka

dockercompose up -d zookeeper kafka

./do_until_success"docker-compose logs kafka | grep 'Created topic\"kafka-rust-test\"'"

./do_until_success"docker-compose logs kafka | grep 'Created topic\"kafka-rust-test2\"'"

./do_until_success"dockercompose logs kafka | grep 'Created topic\"kafka-rust-test\"'"

./do_until_success"dockercompose logs kafka | grep 'Created topic\"kafka-rust-test2\"'"

}

setup() {