yr.datasystem.stream_client.Consumer.close

stream_client.Consumer.close()

关闭消费者。一旦关闭后，消费者不可再用。

异常：

• RuntimeError - 关闭消费者失败。