public static void assertEqualsExceptClientId(Map<String, Object> expected, Map<String, Object> actual) {
        Map<String, Object> expectedWithoutClientId = new HashMap<>(expected);
        expectedWithoutClientId.remove("client.id");
        Map<String, Object> actualWithoutClientId = new HashMap<>(actual);
        actualWithoutClientId.remove("client.id");
        assertEquals(expectedWithoutClientId, actualWithoutClientId);
    }
Assemble a collection of records evenly distributed across some partitions of the specified topic
@param topicName Destination topic
@param numRecords count of records to produce to each partition
@param numPartitions number of partitions within the topic to write records to.
@return A batch of records that can be sent to a producer.
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/TestUtils.java