thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-09-19 16:20:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge c06514dad6 into b94a7167a8

Browse Source
This commit is contained in:
Dmitry Novikov 2024-09-18 23:54:18 +03:00 committed by GitHub
commit 72fd0f7635
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
docs/en/engines/table-engines/integrations/nats.md
View File

@ -55,7 +55,7 @@ Optional parameters:
- `nats_schema` – 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.
- `nats_num_consumers` – The number of consumers per table. Default: `1`. Specify more consumers if the throughput of one consumer is insufficient.
- `nats_queue_group` – Name for queue group of NATS subscribers. Default is the table name.
- `nats_max_reconnect` – Maximum amount of reconnection attempts per try to connect to NATS. Default: `5`.
- `nats_max_reconnect` – Maximum amount of reconnection attempts per try to connect to NATS. If negative, then it will never give up trying to reconnect. Default: `5`.
- `nats_reconnect_wait` – Amount of time in milliseconds to sleep between each reconnect attempt. Default: `5000`.
- `nats_server_list` - Server list for connection. Can be specified to connect to NATS cluster.
- `nats_skip_broken_messages` - NATS message parser tolerance to schema-incompatible messages per block. Default: `0`. If `nats_skip_broken_messages = N` then the engine skips *N* NATS messages that cannot be parsed (a message equals a row of data).

2
src/Storages/NATS/NATSSettings.h
View File

@ -16,7 +16,7 @@ class ASTStorage;
M(UInt64, nats_num_consumers, 1, "The number of consumer channels per table.", 0) \
M(String, nats_queue_group, "", "Name for queue group of NATS subscribers.", 0) \
M(Bool, nats_secure, false, "Use SSL connection", 0) \
M(UInt64, nats_max_reconnect, 5, "Maximum amount of reconnection attempts.", 0) \
M(Int64, nats_max_reconnect, 5, "Maximum amount of reconnection attempts. If negative, then it will never give up trying to reconnect.", 0) \
M(UInt64, nats_reconnect_wait, 2000, "Amount of time in milliseconds to sleep between each reconnect attempt.", 0) \
M(String, nats_server_list, "", "Server list for connection", 0) \
M(UInt64, nats_skip_broken_messages, 0, "Skip at least this number of broken messages from NATS per block", 0) \