protected final void warmUpConsumer(Map<String, Object> consumerProps) {
        final String topic = "test-topic-1";
        warmUpConsumer("primary", primary.kafka(), consumerProps, topic);
        warmUpConsumer("backup", backup.kafka(), consumerProps, topic);
    }
Produce a batch of records with the specified producer
@param producer Producer to use to send records
@param records Records to send in one parallel batch
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/integration/MirrorConnectorsIntegrationBaseTest.java