I should also mention that system/integration tests of the new functionality was a requirement for releasing it. For example, here's one of the tests https://gi

I should also mention that system/integration tests of the new functionality was a requirement for releasing it. For example, here's one of the tests https://github.com/apache/kafka/blob/trunk/tests/kafkatest/tests/core/transactions_test.py https://github.com/apache/kafka/blob/trunk/tests/kafkatest/t...