Clickhouse заходит в кафку по порту отличному от указанного в настройках

Рейтинг: 1Ответов: 0Опубликовано: 24.07.2023

В конфиге не указан порт, а только креды на подключение. В таблице clickhous'а указан порт, который нужен для доступа к топику kafka, я там выставил порт 9093.

/etc/clickhouse-server/config.xml

<kafka>
            <debug>all</debug>
            <sasl_username>kafkauser</sasl_username>
            <sasl_password>Kafkapassword</sasl_password>
            <security_protocol>SASL_PLAINTEXT</security_protocol>
            <sasl_mechanisms>PLAIN</sasl_mechanisms>
</kafka>

А после создания таблицы ничего не происходит, данные не идут. В логах кликхауса написано, что тянуть нечего, но в топике есть данные, а в ошибках кликхаус при этом пишет, что на 9092 время на соединение истекло и брокер падает

CREATE TABLE test_kafka.tasks_queue
(

    `data` String
)
ENGINE = Kafka
SETTINGS kafka_broker_list = '10.10.10.22:9093',
 kafka_group_name = 'test',
 kafka_num_consumers = '1',
 kafka_format = 'JSONEachRow',
 kafka_topic_list = 'test2';

При этом в логах кликхаус пишет, что тянуть нечего, а в теме есть данные, а в ошибках клика, при этом, пишет, что на 9092 время на соединении все плохо и брокер падает, но в таблице указан порт 9093

tail -f /var/log/clickhouse-server/clickhouse-server.err.log

2023.07.20 11:36:27.064262 [ 1281 ] {} <Error> StorageKafka (github_queue): [rdk:FAIL] [thrd:sasl_plaintext://10.10.10.22:9092/bootstrap]: sasl_plaintext://10.10.10.22:9092/bootstrap: Connect to ipv4#10.10.10.22:9092 failed: Connection refused (after 0ms in state CONNECT, 31 identical error(s) suppressed)

Конфиг кафки

advertised.listeners=PLAINTEXT://10.10.10.22:9092,SASL_PLAINTEXT://10.10.10.22:9093

Я не понимаю, почему соединение идет на 9092, если порт явно указан для SASL

listeners=PLAINTEXT://10.10.10.22:9092,SASL_PLAINTEXT://10.10.10.22:9093

Ответы

Ответов пока нет.