system.kafka_consumers

Tabela de sistema que contém informações sobre consumidores do Kafka.

Consultas no ClickHouse Cloud

Os dados nesta tabela de sistema são mantidos localmente em cada nó do ClickHouse Cloud. Portanto, para obter uma visão completa de todos os dados, é necessário usar a função clusterAllReplicas. Consulte aqui para mais detalhes.

​

Descrição

Contém informações sobre os consumidores do Kafka. Aplica-se ao motor de tabela Kafka (integração nativa do ClickHouse)

​

Colunas

• database (String) — Banco de dados da tabela com Kafka Engine.
• table (String) — Nome da tabela com Kafka Engine.
• consumer_id (String) — Identificador do consumidor do Kafka. Observe que uma tabela pode ter vários consumidores. Especificado pelo parâmetro kafka_num_consumers.
• assignments.topic (Array(String)) — Tópico do Kafka.
• assignments.partition_id (Array(Int32)) — ID da partição do Kafka. Observe que apenas um consumidor pode ser atribuído a uma partição.
• assignments.current_offset (Array(Int64)) — Offset atual.
• assignments.intent_size (Array(Nullable(Int64))) — Número de mensagens enviadas, mas ainda não confirmadas, no novo StorageKafka.
• exceptions.time (Array(DateTime)) — Timestamp de quando as 10 exceções mais recentes foram geradas.
• exceptions.text (Array(String)) — Texto das 10 exceções mais recentes.
• last_poll_time (DateTime) — Timestamp do poll mais recente.
• num_messages_read (UInt64) — Número de mensagens lidas pelo consumidor.
• last_commit_time (DateTime) — Timestamp do poll mais recente.
• num_commits (UInt64) — Número total de commits do consumidor.
• last_rebalance_time (DateTime) — Timestamp do rebalanceamento mais recente do Kafka.
• num_rebalance_revocations (UInt64) — Número de vezes em que as partições do consumidor foram revogadas.
• num_rebalance_assignments (UInt64) — Número de vezes em que o consumidor foi atribuído ao cluster Kafka.
• is_currently_used (UInt8) — Indicador que mostra se o consumidor está em uso.
• last_used (DateTime64(6)) — Última vez em que este consumidor esteve em uso.
• rdkafka_stat (String) — Estatística interna da biblioteca. Defina statistics_interval_ms como 0 para desabilitar; o padrão é 3000 (uma vez a cada três segundos).
• dependencies (Array(Array(String))) — Dependências transitivas do banco de dados.
• missing_dependencies (Array(Array(String))) — Dependências transitivas ausentes do banco de dados.

Exemplo:

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