3 years ago

This is a two-part series to help you get started with Rust and Kafka. In this post we will cover the Kafka Consumer API.

The only difference is that you will have to cast the output to the right type (which in this case is BaseConsumer)

We will: We will skip the pre_rebalance method and focus on post_rebalance in this example:Rebalance is an enum.

We will then use this in our consumer loop and commit only when this functions returns successfully.