Rdkafka (не лара конечно, сорян) кто может объяснить поведение? если подписались на

Question

Rdkafka (не лара конечно, сорян) кто может объяснить поведение? если подписались на

топик, запросили метадату
$rdKafkaConsumer->subscribe(['topic_name']);
$rdKafkaConsumer->getMetadata(true, null, 1000):
$rdKafkaConsumer->consume(1000);

ловим Subscribed topic not available: topic_name: Broker: Unknown topic or partition для первого сообщения (если проигнорировать - остальные сообщения прилетают норм)

а если сначала получить метадату а потом подписываться то все ок...
$rdKafkaConsumer->getMetadata(true, null, 1000):
$rdKafkaConsumer->subscribe(['topic_name']);
$rdKafkaConsumer->consume(1000);

то ли я чего то не понимаю, то ли баг идти репортить...

#backend #laravel #php #programming #russian

0

04.06.2023

3 ответов

19 просмотров

Алексей Автор вопроса

Anton Rusakov
Я разок тоже подключал кафку, но через питон и тож...

та не, метадата мне нужна для проверки наличия нужных топиков и кастомного управления офсетами в каждом партишене. если на 100% уверен что топики на месте а для офсетов стоит автокомит - то и не нужна она тебе...

0

04.06.2023

Anton Rusakov

Алексей
та не, метадата мне нужна для проверки наличия нуж...

Дадада, это все так и работает. Я к тому что именно такое же явление и в другом языке замечал.

0

04.06.2023

Anton Rusakov · Accepted Answer

Anton Rusakov

Я разок тоже подключал кафку, но через питон и тоже заметил что как только у тебя сабскрайбер подключается - он должен читануть метадату и тогда всё ок дальше работать начинает. Но утверждать что так и надо не буду :).

0

04.06.2023

170 похожих чатов

Rdkafka (не лара конечно, сорян) кто может объяснить поведение? если подписались на

3 ответов

Похожие вопросы