<Error> StorageKafka (user_kafka): [rdk:ERROR] [thrd:xxx.cloud.redpanda.com:]: 1/1 brokers are down

120 Views Asked by At

I am trying to setup the kafka engine and getting multiple errors.

Error which is too frequent
<Error> StorageKafka (user_kafka): [rdk:ERROR] [thrd:xxx.cloud.redpanda.com:]: 1/1 brokers are down

Error which is visible sometimes

2024.01.11 04:00:01.875084 [ 61840 ] {} <Error> StorageKafka (user_kafka): [rdk:ERROR] [thrd:app]: ClickHouse-clickhouse-poc-1.c.x.internal-test-user_kafka#consumer-2: xxx.cloud.redpanda.com:9092/bootstrap: Disconnected while requesting ApiVersion: might be caused by incorrect security.protocol configuration (connecting to a SSL listener?) or broker version is < 0.10 (see api.version.request) (after 0ms in state APIVERSION_QUERY, 4 identical error(s) suppressed)

My table and configurations are like this

// Base Table
CREATE TABLE test.user (name String, id Int32, email String)
    ENGINE = MergeTree()
    ORDER BY id;

// Kafka Engine Table
CREATE TABLE test.user_kafka (name String, id Int32, email String)
    ENGINE = Kafka()
    SETTINGS
        kafka_broker_list = 'seed-27ac08c5.chllqaunch049g9dc0t0.byoc.prd.cloud.redpanda.com:9092',
        kafka_topic_list = 'otlp_spans',
        kafka_group_name = 'user_group',
        kafka_format = 'Protobuf',
        kafka_schema = 'trace:User',
        kafka_num_consumers = 1,
        kafka_skip_broken_messages = 1,
        kafka_max_block_size = 1000000,
        kafka_row_delimiter = '\n'

CREATE MATERIALIZED VIEW test.user_mv TO test.user AS
SELECT name, id, email
FROM test.user_kafka;

Kafka Configuration inside config.xml

<clickhouse>
                <kafka>
                        <sasl_username>user</sasl_username>
                        <sasl_password>password</sasl_password>
                        <security_protocol>SASL_SSL</security_protocol>
                        <sasl_mechanisms>SCRAM-SHA-256</sasl_mechanisms>
                        <debug>all</debug>
                        <enable_ssl_certificate_verification>false</enable_ssl_certificate_verification>
                        <ssl_endpoint_identification_algorithm>none</ssl_endpoint_identification_algorithm>
                </kafka>
        </clickhouse>

Tried multiple configuration but still not able to setup, can someone please help

this is my redpanda/kafka configuration

export REDPANDA_BROKERS="seed-xxx.redpanda.com:9092"

export REDPANDA_SASL_MECHANISM="<SCRAM-SHA-256 or SCRAM-SHA-512>"

export REDPANDA_SASL_USERNAME="<username>"

export REDPANDA_SASL_PASSWORD="<password>"

I have tried every security protocol in the config.xml file of the clickhouse-server but always getting this error. I want to consume the data from redpanda.

0

There are 0 best solutions below