@BeforeEach
    public void setup(TestInfo testInfo) {
        connectorName = testInfo.getTestMethod().get().getName();
        topic = testInfo.getTestMethod().get().getName();
        connect = defaultConnectCluster();
    }
Integration tests for Kafka Connect's connector offset management REST APIs
connect/runtime/src/test/java/org/apache/kafka/connect/integration/OffsetsApiIntegrationTest.java