본문으로 바로가기
본문으로 바로가기

system.kafka_consumers

ClickHouse Cloud에서 쿼리하기

이 시스템 테이블의 데이터는 ClickHouse Cloud의 각 노드에 로컬로 저장됩니다. 따라서 전체 데이터를 조회하려면 clusterAllReplicas 함수를 사용해야 합니다. 자세한 내용은 여기를 참고하십시오.

Kafka 컨슈머에 대한 정보를 포함합니다. Kafka 테이블 엔진 (ClickHouse 네이티브 통합)에 적용됩니다.

컬럼:

  • database (String) — Kafka Engine 테이블이 속한 데이터베이스.
  • table (String) — Kafka Engine 테이블 이름.
  • consumer_id (String) — Kafka consumer 식별자. 하나의 테이블에 여러 consumer가 있을 수 있습니다. kafka_num_consumers 파라미터로 지정합니다.
  • assignments.topic (Array(String)) — Kafka 토픽.
  • assignments.partition_id (Array(Int32)) — Kafka 파티션 ID. 하나의 파티션에는 오직 하나의 consumer만 할당될 수 있습니다.
  • assignments.current_offset (Array(Int64)) — 현재 오프셋.
  • assignments.intent_size (Array(Nullable(Int64))) — 새 StorageKafka 엔진에서 푸시되었으나 아직 커밋되지 않은 메시지 수.
  • exceptions.time (Array(DateTime)) — 가장 최근 예외 10개의 생성 시각 타임스탬프.
  • exceptions.text (Array(String)) — 가장 최근 예외 10개의 텍스트.
  • last_poll_time (DateTime) — 가장 최근 poll의 타임스탬프.
  • num_messages_read (UInt64) — consumer가 읽은 메시지 수.
  • last_commit_time (DateTime) — 가장 최근 poll의 타임스탬프.
  • 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 (DateTime64(6)) — 이 consumer가 마지막으로 사용된 시각.
  • rdkafka_stat (String) — 라이브러리 내부 통계. 비활성화하려면 statistics_interval_ms를 0으로 설정하며, 기본값은 3000(3초에 한 번)입니다.
  • dependencies (Array(Array(String))) — 전이적(transitive) 데이터베이스 종속성.
  • missing_dependencies (Array(Array(String))) — 누락된 전이적(transitive) 데이터베이스 종속성.

예제:

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:                  {...}
dependencies:                  [['test.mv2','test.target2'],['test.mv1','test.target1']]
missing_dependencies:          []