private ListOffsetsResponse listOffsetsResult(TopicPartition tp1, Long offset1) {
        return listOffsetsResult(null, Collections.singletonMap(tp1, offset1));
    }
TopicAdmin can be used to read the end offsets, but the admin client API used to do this was
added to the broker in 0.11.0.0. This means that if Connect talks to older brokers,
the admin client cannot be used to read end offsets, and will throw an UnsupportedVersionException.
connect/runtime/src/test/java/org/apache/kafka/connect/util/TopicAdminTest.java