DC
KirillReal
Добрый день, а если я хочу потоково читать из двух кафок с разными топиками, можно это как-то сделать?
я пробывал вот так, вбить адреса кафок и задать названия топиков:
create table test_kafka (
) ENGINE = Kafka('kafka-1:9092’, ’kafka-2:9092’ , ‘topic_1, topic_2', 'group1', 'JSONEachRow’);
но так не работает 🙁
Кажется, потому что в kafka-1 нет topic_2 и в kafka-2 нет topic_1
Делаю такой вывод, так как по отдельности все работает:
create table test_kafka (
) ENGINE = Kafka('kafka-1:9092’, ‘topic_1', 'group1', 'JSONEachRow’);
create table test_kafka (
) ENGINE = Kafka(‘kafka-2:9092’, ‘topic_2', 'group1', 'JSONEachRow’);
я пробывал вот так, вбить адреса кафок и задать названия топиков:
create table test_kafka (
id UInt64) ENGINE = Kafka('kafka-1:9092’, ’kafka-2:9092’ , ‘topic_1, topic_2', 'group1', 'JSONEachRow’);
но так не работает 🙁
Кажется, потому что в kafka-1 нет topic_2 и в kafka-2 нет topic_1
Делаю такой вывод, так как по отдельности все работает:
create table test_kafka (
id UInt64) ENGINE = Kafka('kafka-1:9092’, ‘topic_1', 'group1', 'JSONEachRow’);
create table test_kafka (
id UInt64) ENGINE = Kafka(‘kafka-2:9092’, ‘topic_2', 'group1', 'JSONEachRow’);
можно записывать результат в одну таблицу , читать конечно через 2 ENGINE = Kafka(
