Привет Подскажите кто сталкивался с такой пробоемой Kafka таблиц.(партиций в топике

Question

Привет Подскажите кто сталкивался с такой пробоемой Kafka таблиц.(партиций в топике

6)

CREATE TABLE rc.et_kafka(`raw_msg` String)
ENGINE = Kafka
SETTINGS
kafka_broker_list = 'et-kafka-0:9094,et-kafka-1:9094,et-kafka-2:9094',
kafka_topic_list = 'et-rc',
kafka_group_name = 'et-rc-kafka-to-ch-test',
kafka_format = 'JSONAsString',
kafka_row_delimiter = '\n',
kafka_num_consumers = 1;

все работало, но потом сменилось имя брокера c et-kafka-0 на et-kafka-5

сделал drop + create table с такими же параметрами но в брокерах заменили et-kafka-0 на et-kafka-5
в еррор логах начали падать ошибки вида

2023.08.10 08:49:44.560611 [ 982 ] {bbd1cc43-6acd-4782-a248-a42dd7e930fb} <Error> StorageKafka (et_kafka): [rdk:ERROR] [thrd:app]: ClickHouse-ip-172-11-3-158.eu-central-1.compute.internal-rc-et_kafka#consumer-5: GroupCoordinator: et-kafka-0:9094: Failed to resolve 'et-kafka-0:9094': Name or service not known (after 1ms in state CONNECT)

и после некой задержки появляется много сообщений
<Warning> StorageKafka (et_kafka): Can't get assignment. Will keep trying.

версия КХ 22.12.3.5, рестарт КХ не помогает, тк сервер. девелоперский то обновили до последней 23.7.3.14 и проблема осталась

есть предположение что где-то внутри КХ в сис. таблицах сохранился старый брокер, но где?

UPD: еще делали SYSTEM DROP MARK CACHE