Curated articles, resources, tips and trends from the DevOps World.
Summary: This is a summary of an article originally published by the source. Read the full original article here →
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.
Made with pure grit © 2024 Jetpack Labs Inc. All rights reserved. www.jetpacklabs.com