public void setDisconnectFuture(CompletableFuture<String> disconnectFuture) {
        this.disconnectFuture = disconnectFuture;
    }
A mock network client for use testing code
clients/src/test/java/org/apache/kafka/clients/MockClient.java