The reason is explained in the description of the #46 PR.

As a side note, the tests might look flaky (work sometimes and fails other times), but the actual reason is that I introduced thresholds on custom Kafka metrics and also added checks to verify produced and consumed messages. So, this behavior is expected. I am going to fix the test later in #48.