diff --git a/docs/en/table_engines/kafka.md b/docs/en/table_engines/kafka.md index 02e4de01dd7ed2f441b6d58d984248fd02bc5fa5..55d2027309d34574669f3ce1581c99599916f19c 100644 --- a/docs/en/table_engines/kafka.md +++ b/docs/en/table_engines/kafka.md @@ -17,13 +17,13 @@ Parameters: - `broker_list` – A comma-separated list of brokers (`localhost:9092`). - `topic_list` – A list of Kafka topics (`my_topic`). - `group_name` – A group of Kafka consumers (`group1`). Reading margins are tracked for each group separately. If you don't want messages to be duplicated in the cluster, use the same group name everywhere. -- `--format` – Message format. Uses the same notation as the SQL ` FORMAT` function, such as ` JSONEachRow`. +- `format` – Message format. Uses the same notation as the SQL ` FORMAT` function, such as ` JSONEachRow`. For more information, see the section "Formats". - `schema` – An optional parameter that must be used if the format requires a schema definition. For example, [Cap'n Proto](https://capnproto.org/) requires the path to the schema file and the name of the root ` schema.capnp:Message` object. Example: ```sql -CREATE TABLE queue ( + CREATE TABLE queue ( timestamp UInt64, level String, message String @@ -47,7 +47,7 @@ When the `MATERIALIZED VIEW` joins the engine, it starts collecting data in the Example: ```sql -CREATE TABLE queue ( + CREATE TABLE queue ( timestamp UInt64, level String, message String @@ -63,7 +63,7 @@ CREATE TABLE queue ( AS SELECT toDate(toDateTime(timestamp)) AS day, level, count() as total FROM queue GROUP BY day, level; -SELECT level, sum(total) FROM daily GROUP BY level; + SELECT level, sum(total) FROM daily GROUP BY level; ``` To improve performance, received messages are grouped into blocks the size of [max_block_size](../operations/settings/settings.md#settings-settings-max_insert_block_size). If the block wasn't formed within [ stream_flush_interval_ms](../operations/settings/settings.md#settings-settings_stream_flush_interval_ms) milliseconds, the data will be flushed to the table regardless of the completeness of the block. @@ -71,9 +71,9 @@ To improve performance, received messages are grouped into blocks the size of [m To stop receiving topic data or to change the conversion logic, detach the materialized view: ``` -DETACH TABLE consumer; -ATTACH MATERIALIZED VIEW consumer; + DETACH TABLE consumer; + ATTACH MATERIALIZED VIEW consumer; ``` -If you want to change the target table by using ` ALTER`materialized view, we recommend disabling the material view to avoid discrepancies between the target table and the data from the view. +If you want to change the target table by using `ALTER` materialized view, we recommend disabling the material view to avoid discrepancies between the target table and the data from the view. diff --git a/docs/ru/table_engines/kafka.md b/docs/ru/table_engines/kafka.md index aa8ab29b3f004a8dec10f10358dd0ae9390a00cd..127820a8ef20d92d4bdca053a4105d78d28e8704 100644 --- a/docs/ru/table_engines/kafka.md +++ b/docs/ru/table_engines/kafka.md @@ -13,10 +13,11 @@ Kafka(broker_list, topic_list, group_name, format[, schema]) ``` Параметры: + - `broker_list` - Перечень брокеров, разделенный запятыми (`localhost:9092`). - `topic_list` - Перечень необходимых топиков Kafka (`my_topic`). - `group_name` - Группа потребителя Kafka (`group1`). Отступы для чтения отслеживаются для каждой группы отдельно. Если необходимо, чтобы сообщения не повторялись на кластере, используйте везде одно имя группы. -- `format` - Формат сообщений. Имеет те же обозначения, что выдает SQL-выражение `FORMAT`, например, `JSONEachRow`. +- `format` - Формат сообщений. Имеет те же обозначения, что выдает SQL-выражение `FORMAT`, например, `JSONEachRow`. Подробнее смотрите в разделе "Форматы". - `schema` - Опциональный параметр, необходимый, если используется формат, требующий определения схемы. Например, [Cap'n Proto](https://capnproto.org/) требует путь к файлу со схемой и название корневого объекта `schema.capnp:Message`. Пример: @@ -62,7 +63,7 @@ Kafka(broker_list, topic_list, group_name, format[, schema]) AS SELECT toDate(toDateTime(timestamp)) AS day, level, count() as total FROM queue GROUP BY day, level; -SELECT level, sum(total) FROM daily GROUP BY level; + SELECT level, sum(total) FROM daily GROUP BY level; ``` Для улучшения производительности полученные сообщения группируются в блоки размера [max_insert_block_size](../operations/settings/settings.md#settings-settings-max_insert_block_size). Если блок не удалось сформировать за [stream_flush_interval_ms](../operations/settings/settings.md#settings-settings_stream_flush_interval_ms) миллисекунд, то данные будут сброшены в таблицу независимо от полноты блока. @@ -70,8 +71,8 @@ SELECT level, sum(total) FROM daily GROUP BY level; Чтобы остановить получение данных топика или изменить логику преобразования, отсоедините материализованное представление: ``` -DETACH TABLE consumer; -ATTACH MATERIALIZED VIEW consumer; + DETACH TABLE consumer; + ATTACH MATERIALIZED VIEW consumer; ``` Если необходимо изменить целевую таблицу с помощью `ALTER`, то материализованное представление рекомендуется отключить, чтобы избежать несостыковки между целевой таблицей и данными от представления. \ No newline at end of file