их не видит (из доки SELECT * FROM queue LIMIT 5;).
В логах CH:
2018.03.07 20:08:15.894921 [ 3 ] <Trace> StorageKafka (queue): Committing 0 messages
Если к кафке подключиться, например, kafkacat, то сообщения видны.
Куда копать?
+ таже ботва, не разбирался, но плюсую
Только вчера сам пробовал. Похоже, что оффсет сдвигается после запроса. Если сделать select из Kafka engine, показывает только новые сообщения. Если после завешения запроса напродюсить сообщений - вычитает их при следующем селекте. BTW, @milovidov_an, можно ли предусмотреть вычитывание данных из топика при указании новой consumer group с первых, а не с новых, как сейчас ?
Обсуждают сегодня