private static Stream<Arguments> testErrorInInitializeSource() {
        return Stream.of(
                Arguments.of(10, new RuntimeException()),
                Arguments.of(0, new RuntimeException()),
                Arguments.of(10, new KafkaException()),
                Arguments.of(0, new KafkaException())
        );
    }
Supplies the {@link Arguments} to {@link #testErrorInInitialize(int, RuntimeException)}.
clients/src/test/java/org/apache/kafka/clients/consumer/internals/FetchCollectorTest.java