@Test
    public void testClientInstanceId() {
        try (AdminClientUnitTestEnv env = mockClientEnv()) {
            Uuid expected = Uuid.randomUuid();

            GetTelemetrySubscriptionsResponseData responseData =
                new GetTelemetrySubscriptionsResponseData().setClientInstanceId(expected).setErrorCode(Errors.NONE.code());

            env.kafkaClient().prepareResponse(
                request -> request instanceof GetTelemetrySubscriptionsRequest,
                new GetTelemetrySubscriptionsResponse(responseData));

            Uuid result = env.adminClient().clientInstanceId(Duration.ofSeconds(1));
            assertEquals(expected, result);
        }
    }
Test that if the client can send to a node, but doesn't receive a response, it will
disconnect and try a different node.
clients/src/test/java/org/apache/kafka/clients/admin/KafkaAdminClientTest.java