def _delete_consumer_groups_send_request(self, group_ids, group_coordinator_id):
        """Send a DeleteGroupsRequest to the specified broker (the group coordinator).

        Arguments:
            group_ids ([str]): A list of consumer group IDs to be deleted.
            group_coordinator_id (int): The node_id of the broker coordinating these groups.

        Returns:
            A future representing the in-flight DeleteGroupsRequest.
        """
        version = self._client.api_version(DeleteGroupsRequest, max_version=1)
        if version <= 1:
            request = DeleteGroupsRequest[version](group_ids)
        else:
            raise NotImplementedError(
                "Support for DeleteGroupsRequest_v{} has not yet been added to KafkaAdminClient."
                    .format(version))
        return self._send_request_to_node(group_coordinator_id, request)
Send a DeleteGroupsRequest to the specified broker (the group coordinator).

        Arguments:
            group_ids ([str]): A list of consumer group IDs to be deleted.
            group_coordinator_id (int): The node_id of the broker coordinating these groups.

        Returns:
            A future representing the in-flight DeleteGroupsRequest.
        
kafka/admin/client.py