def _list_consumer_groups_send_request(self, broker_id):
        """Send a ListGroupsRequest to a broker.

        Arguments:
            broker_id (int): The broker's node_id.

        Returns:
            A message future
        """
        version = self._client.api_version(ListGroupsRequest, max_version=2)
        if version <= 2:
            request = ListGroupsRequest[version]()
        else:
            raise NotImplementedError(
                "Support for ListGroupsRequest_v{} has not yet been added to KafkaAdminClient."
                .format(version))
        return self._send_request_to_node(broker_id, request)
Send a ListGroupsRequest to a broker.

        Arguments:
            broker_id (int): The broker's node_id.

        Returns:
            A message future
        
kafka/admin/client.py