Size: a a a
СЛ
СЛ
ENGINE = ReplicatedMergeTree('/clickhouse/tables/{shard}/{database}/{table}/{uuid}', '{replica}')S
S
ENGINE = ReplicatedMergeTree('/clickhouse/tables/{shard}/{database}/{table}/{uuid}', '{replica}')СЛ
S
СЛ
S
S
СЛ
СЛ
S
S
СЛ
S
E
--kafka.xml в config.d/
<?xml version="1.0"?>
<yandex>
<kafka>
<sasl_mechanism>PLAIN</sasl_mechanism>
<security_protocol>SASL_PLAINTEXT</security_protocol>
<sasl_username>user</sasl_username>
<sasl_password>pass</sasl_password>
</kafka>
<kafka_topic_my-topic>
<sasl_mechanism>PLAIN</sasl_mechanism>
<security_protocol>SASL_PLAINTEXT</security_protocol>
<sasl_username>user2</sasl_username>
<sasl_password>pass2</sasl_password>
</kafka_topic_my-topic>
</yandex>kafka_topic_list = 'my-topic')<kafka_topic_my-first-topic> - не работает. Ему ‘-’ не нравится?D
E
--kafka.xml в config.d/
<?xml version="1.0"?>
<yandex>
<kafka>
<sasl_mechanism>PLAIN</sasl_mechanism>
<security_protocol>SASL_PLAINTEXT</security_protocol>
<sasl_username>user</sasl_username>
<sasl_password>pass</sasl_password>
</kafka>
<kafka_topic_my-topic>
<sasl_mechanism>PLAIN</sasl_mechanism>
<security_protocol>SASL_PLAINTEXT</security_protocol>
<sasl_username>user2</sasl_username>
<sasl_password>pass2</sasl_password>
</kafka_topic_my-topic>
</yandex>kafka_topic_list = 'my-topic')<kafka_topic_my-first-topic> - не работает. Ему ‘-’ не нравится?2021.01.26 13:24:13.250765 [ 86107 ] {dc25d001-a117-429b-a4c4-650c53843394} <Error> StorageKafka (my-topic): Consumer error: Broker: Group authorization failed
2021.01.26 13:24:13.250815 [ 86107 ] {dc25d001-a117-429b-a4c4-650c53843394} <Error> StorageKafka (my-topic): There were 1 messages with an error
2021.01.26 13:24:13.250847 [ 86107 ] {dc25d001-a117-429b-a4c4-650c53843394} <Error> StorageKafka (my-topic): Only errors left
2021.01.26 13:24:41.924235 [ 86123 ] {cb82ab86-6c37-4f4b-85e1-d076d50b19e7} <Warning> StorageKafka (my-topic): Can't get assignment. It can be caused by some issue with consumer group (not enough partitions?). Will keep trying.F
replaceOne(replaceOne(replaceOne(s, 'AA', 'FOO'), ...), ...)
K
replaceOne(replaceOne(replaceOne(s, 'AA', 'FOO'), ...), ...)