system.kafka_consumers

在 ClickHouse Cloud 中查询

该系统表中的数据在 ClickHouse Cloud 的每个节点上本地保存。因此，要获得所有数据的完整视图，需要使用 clusterAllReplicas 函数。有关更多详细信息，请参见 here。

包含有关 Kafka 消费者的信息。 适用于 Kafka table engine (原生 ClickHouse 集成)

列：

• database (String) - 使用 Kafka 引擎的表所在的数据库。
• table (String) - 使用 Kafka 引擎的表名。
• consumer_id (String) - Kafka 消费者标识符。注意，一个表可以有多个消费者。由 kafka_num_consumers 参数指定。
• assignments.topic (Array(String)) - Kafka 主题。
• assignments.partition_id (Array(Int32)) - Kafka 分区 ID。注意，只有一个消费者可以被分配到一个分区。
• assignments.current_offset (Array(Int64)) - 当前偏移量。
• exceptions.time (Array(DateTime)) - 最近 10 个异常生成的时间戳。
• exceptions.text (Array(String)) - 最近 10 个异常的文本。
• last_poll_time (DateTime) - 最近一次轮询的时间戳。
• num_messages_read (UInt64) - 消费者读取的消息数量。
• last_commit_time (DateTime) - 最近一次提交的时间戳。
• num_commits (UInt64) - 消费者的提交总数。
• last_rebalance_time (DateTime) - 最近一次 Kafka 重新平衡的时间戳。
• num_rebalance_revocations (UInt64) - 消费者被撤销分区的次数。
• num_rebalance_assignments (UInt64) - 消费者被分配到 Kafka 集群的次数。
• is_currently_used (UInt8) - 消费者是否在使用中。
• last_used (UInt64) - 此消费者最后一次使用的时间，单位为微秒的 Unix 时间。
• rdkafka_stat (String) - 库内部统计信息。请参阅 https://github.com/ClickHouse/librdkafka/blob/master/STATISTICS.md 。设置 statistics_interval_ms 为 0 可禁用，默认值为 3000（每三秒一次）。

示例：