kafka_consumers
在 ClickHouse Cloud 中查询
此系统表中的数据本地保存在 ClickHouse Cloud 的每个节点上。 因此,要获得所有数据的完整视图,需要使用 clusterAllReplicas
函数。 有关更多详细信息,请参阅这里。
包含有关 Kafka consumers 的信息。 适用于 Kafka 表引擎(原生 ClickHouse 集成)
列
database
(String) - 带有 Kafka 引擎的表的数据库。table
(String) - 带有 Kafka 引擎的表的名称。consumer_id
(String) - Kafka consumer 标识符。 请注意,一个表可以有多个 consumers。 由kafka_num_consumers
参数指定。assignments.topic
(Array(String)) - Kafka 主题。assignments.partition_id
(Array(Int32)) - Kafka 分区 ID。 请注意,只有一个 consumer 可以分配给一个分区。assignments.current_offset
(Array(Int64)) - 当前偏移量。exceptions.time
, (Array(DateTime)) - 生成最近 10 个异常的时间戳。exceptions.text
, (Array(String)) - 最近 10 个异常的文本。last_poll_time
, (DateTime) - 最近一次轮询的时间戳。num_messages_read
, (UInt64) - consumer 读取的消息数。last_commit_time
, (DateTime) - 最近一次提交的时间戳。num_commits
, (UInt64) - consumer 的提交总数。last_rebalance_time
, (DateTime) - 最近一次 Kafka 重新平衡的时间戳num_rebalance_revocations
, (UInt64) - consumer 被撤销其分区的次数num_rebalance_assignments
, (UInt64) - consumer 被分配到 Kafka 集群的次数is_currently_used
, (UInt8) - consumer 是否正在使用last_used
, (UInt64) - 上次使用此 consumer 的时间,以微秒为单位的 unix 时间rdkafka_stat
(String) - 库内部统计信息。 请参阅 https://github.com/ClickHouse/librdkafka/blob/master/STATISTICS.md 。 将statistics_interval_ms
设置为 0 以禁用,默认值为 3000(每三秒一次)。
示例
SELECT *
FROM system.kafka_consumers
FORMAT Vertical
Row 1:
──────
database: test
table: kafka
consumer_id: ClickHouse-instance-test-kafka-1caddc7f-f917-4bb1-ac55-e28bd103a4a0
assignments.topic: ['system_kafka_cons']
assignments.partition_id: [0]
assignments.current_offset: [18446744073709550615]
exceptions.time: []
exceptions.text: []
last_poll_time: 2006-11-09 18:47:47
num_messages_read: 4
last_commit_time: 2006-11-10 04:39:40
num_commits: 1
last_rebalance_time: 1970-01-01 00:00:00
num_rebalance_revocations: 0
num_rebalance_assignments: 1
is_currently_used: 1
rdkafka_stat: {...}