Critical Description
Improve the system tests for the mirroring code to add the following testing scenarios -
1. Bounce the mirroring kafka cluster during the test
2. Add new topics to the source kafka cluster while the mirror is copying data for existing topics
3. Bounce the source Kafka cluster during the test
The point of this improvement is to catch any bugs in the consumer rebalancing or the detection of new topics logic. Also, verification code of this part of the system test can report on the % of duplicates/ % data loss in the mirror cluster. Since Kafka guarantees at least once delivery, small percentage of duplicates is ok, but any amount of data loss is a critical bug