datasystem.stream_client.StreamClient.query_global_consumer_num

datasystem.stream_client.StreamClient.query_global_consumer_num#

datasystem.stream_client.StreamClient.query_global_consumer_num(stream_name)#
指定流的名称,查询流的消费者数量。
参数:
  • stream_name (str) - 指定流的名称。

返回:

global_consumer_num(int): 消费者的数量

异常:
  • TypeError - 输入参数存在非法值。

  • RuntimeError - 查询消费者数量失败。