system.kafka_consumers 시스템 테이블

system.kafka_consumers 는 Kafka 컨슈머에 대한 정보를 담고 있어요. Kafka table engine(네이티브 ClickHouse 통합)에 적용돼요.

출처: 문서

본문

ClickHouse Cloud에서의 조회 — 이 시스템 테이블의 데이터는 ClickHouse Cloud에서 각 노드에 로컬로 저장돼요. 따라서 모든 데이터의 완전한 뷰를 얻으려면 clusterAllReplicas 함수가 필요해요. 자세한 내용은 여기 를 참고하세요.

Description

Kafka 컨슈머에 대한 정보를 포함해요. Kafka table engine(네이티브 ClickHouse 통합)에 적용돼요.

가용성(Availability) system.kafka_consumers 는 Kafka 지원(USE_RDKAFKA)으로 컴파일된 ClickHouse 빌드에만 존재해요. 이 없이 빌드된 경우 테이블이 존재하지 않으며, 이 테이블에 대한 쿼리는 UNKNOWN_TABLE 오류로 실패해요. 빌드에 이 기능이 활성화되어 있는지 확인하려면 다음 쿼리를 사용할 수 있어요:

SELECT value FROM system.build_options WHERE name = 'USE_RDKAFKA';

Columns

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)) — 현재 오프셋이에요.
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) — 컨슈머가 읽은 메시지 수예요.
last_commit_time (DateTime) — 가장 최근 poll의 타임스탬프예요.
num_commits (UInt64) — 컨슈머의 총 커밋 수예요.
last_rebalance_time (DateTime) — 가장 최근 Kafka 리밸런스의 타임스탬프예요.
num_rebalance_revocations (UInt64) — 컨슈머가 파티션을 회수(revoke)당한 횟수예요.
num_rebalance_assignments (UInt64) — 컨슈머가 Kafka 클러스터에 할당된 횟수예요.
is_currently_used (UInt8) — 컨슈머가 사용 중인지 여부를 보여주는 플래그예요.
last_used (DateTime64(6)) — 이 컨슈머가 마지막으로 사용된 시각이에요.
rdkafka_stat (String) — 라이브러리 내부 통계예요. statistics_interval_ms 를 0으로 설정하면 비활성화되고, 기본값은 3000(3초마다 한 번)이에요.
dependencies (Array(Array(String))) — 전이적 데이터베이스 의존성이에요.
missing_dependencies (Array(Array(String))) — 누락된 전이적 데이터베이스 의존성이에요.

Examples

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:          []