создал топик test, туда записал несколько сообщений, консольным клиентом их вижу. из своего го-клиента туда пишу строки с \n в конце, их тоже вижу.
пытаюсь подключиться в КХ, таким образом
CREATE TABLE testKafka (
message String
) ENGINE = Kafka SETTINGS kafka_broker_list = '192.168.0.4:9092',
kafka_topic_list = 'test',
kafka_group_name = 'group1',
kafka_row_delimiter = '\n', // без него тоже пробовал
kafka_format = 'CSV';
отправляю пару сообщений в кафку, но SELECT * FROM testKafka делает паузу на пол секунды и ничего не возвращает. с выключенной кафкой такая же реакция.
в логах по кафке только такое
StorageKafka (testKafka): Starting reading 1 streams, 65536 block size
Kafka
что я делаю не так?
главное, что непонятно как это расследовать, в логах почти пусто
Хм. А если попробовать вставить не пару сообщений а пару тысяч сообщений?
Обсуждают сегодня