thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-23 08:02:02 +00:00
Code Issues Packages Projects Releases Wiki Activity

system_kafka_consumers: tiny doc changes

Browse Source
This commit is contained in:
Ilya Golshtein 2023-07-01 21:51:28 +00:00
parent 1f03e320ee
commit 3f205f4997
3 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
docs/en/engines/table-engines/integrations/kafka.md
View File

@ -260,3 +260,4 @@ The number of rows in one Kafka message depends on whether the format is row-bas
- [Virtual columns](../../../engines/table-engines/index.md#table_engines-virtual_columns) - [Virtual columns](../../../engines/table-engines/index.md#table_engines-virtual_columns)
- [background_message_broker_schedule_pool_size](../../../operations/server-configuration-parameters/settings.md#background_message_broker_schedule_pool_size) - [background_message_broker_schedule_pool_size](../../../operations/server-configuration-parameters/settings.md#background_message_broker_schedule_pool_size)
- [system.kafka_consumers](../../../operations/system-tables/kafka-consumers.md)

1
docs/en/operations/system-tables/kafka_consumers.md
View File

@ -24,6 +24,7 @@ Columns:
- `num_rebalance_revocations`, (UInt64) - number of times the consumer was revoked its partitions - `num_rebalance_revocations`, (UInt64) - number of times the consumer was revoked its partitions
- `num_rebalance_assignments`, (UInt64) - number of times the consumer was assigned to Kafka cluster - `num_rebalance_assignments`, (UInt64) - number of times the consumer was assigned to Kafka cluster
- `is_currently_used`, (UInt8) - consumer is in use - `is_currently_used`, (UInt8) - consumer is in use
- `rdkafka_stat` (String) - library internal statistic. See https://github.com/ClickHouse/librdkafka/blob/master/STATISTICS.md . Set `statistics_interval_ms` to disable.
Example: Example:

1
src/Storages/System/StorageSystemKafkaConsumers.cpp
View File

@ -46,7 +46,6 @@ NamesAndTypesList StorageSystemKafkaConsumers::getNamesAndTypes()
{"num_rebalance_assignments", std::make_shared<DataTypeUInt64>()}, {"num_rebalance_assignments", std::make_shared<DataTypeUInt64>()},
{"is_currently_used", std::make_shared<DataTypeUInt8>()}, {"is_currently_used", std::make_shared<DataTypeUInt8>()},
{"rdkafka_stat", std::make_shared<DataTypeString>()}, {"rdkafka_stat", std::make_shared<DataTypeString>()},
// {"json", std::make_shared<DataTypeObject>("json", false)}}
}; };
return names_and_types; return names_and_types;
} }