Parameterized tests in Java allow us to avoid duplication when writing multiple tests. I have found them to be very useful while writing system tests for client libraries, that need to provide very similar behaviour depending while slightly different user input is provided. Parameterized tests are very expressive, we could…

This article is deprecated as MM2 provides this feature as of Kafka 2.7 (KIP-545). KafkaMirrorMaker2 provides us with a tool to replicate messages from source to target cluster, as well as consumer group offsets. When it comes to consumer group offsets, KMM2 periodically translated offsets to checkpoints topic (named ${prefix}.checkpoints.internal). By…

From a (very) high level point-of-view, both products solve the same problem — getting our message bytes from producer to consumer, what allows our architectures to avoid coupling. Let’s take a look at are the similarities and differences provided by these two solutions. RabbitMQ server allows us to send and…

Envoy 1.13 provides Kafka broker-level filter, that allows us to collect the request/response metric for a given broker. The filter decodes the received requests/responses, and updates the correct metrics — this way we can find out how many requests were received by given broker, how many responses were sent, and…