Всем привет. Подскажите, можно ли в Кафке вычитывать сообщения только

с определенным заголовком?

6 ответов

47 просмотров

Посмотрите в сторону ksqlDB https://habr.com/ru/company/neoflex/blog/593769/

Jack-S Автор вопроса
Svyatoslav
Посмотрите в сторону ksqlDB https://habr.com/ru/co...

Спасибо, но это, к сожалению, не подходит

Привіт, а що ти маєш на увазі? Бо типу якого б ти консюмера не створив і як би не намагався читати ти прочитаеш усе що відасть тобі кафка по топіку, а наскільки мені відомо на рівні протоколу немає опціїї фільтраціїї на poll, це б вже була не кафка=) Але ти звісно можешь зробити це кодом, ksql тобі пропонуют тому що він може трансформувати один топік в інший, але по суті це kafka stream, а це в свою чергу kafka consumer та kafka producer, тому як би занадто мощно підключати ksql заради однієї невеликої мети. Якщо ти хочешь якось повідовлення розрізняти то то можешь типу створити декілька топіків, типу перший для усього, другий для хедеру наприклад channel:1, а третій для хедеру channel:2. Ну і взагалі можешь побудувати продюсера так що він буде динамічно створювати топіки, але на мою думку до чогось доброго це не приведе. Ти краще запитай яку проблему ти намагаєшся вирішити загалом.

Jack-S Автор вопроса
XDmytro
Привіт, а що ти маєш на увазі? Бо типу якого б ти ...

Привет, мне нужно уметь читать сообщения определенной версии схемы. Я могу попробовать сделать это через группы, но думал может есть возможность фильтровать

Можно такие особенные месседжи прибить гвоздями к кастомному partition и в consumer указать assign

Jack S
Привет, мне нужно уметь читать сообщения определен...

Так просто читай всё и пропускай неподходящее, других вариантов всё равно особо нет.

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

Обсуждают сегодня

Добрый вечер, Пока не совсем понимаю как наладить общение между телеграм ботом и ПО для работы с сим боксом. По самому боту так понял: - Нужен некий баланс, который можно поп...
Magic
6
Объясните, пожалуйста, почему компилятор ругается на использование в условии неинициализированной переменной: int x; Task.Run(async () => { x = await somefunc(); }).Wait...
Александр
5
Всем привет. Ребята, подскажите, пожалуйста. у ботов есть ограничение на отправку сообщений - 30 сообщений в секунду, эти ограничения накладываются на все сообщения? или на со...
Artem Stormageddon
4
Блин, ребята, сори за тупые вопросы. А можно ли как-то открыть вебапку по нажатию на кнопку в меню(которое появляется слева, команды)?
Artem Stormageddon
3
Коллеги, может знает кто, можно ли цвет бейджа счётчика в BackendMenu менять без бубнов?
Alex Blaze
3
а плаксы из-под питона умеют только в комфортных условиях что-то выдавить из себя?)
Lencore
9
Но, может, есть уже проверенная? Наши требования такие: 1. Сообщения должны приходить из Инста в CRM оду 2. Должна быть возможность подключить несколько экаунтов Инстаграм. Р...
Alexander Sharoiko MSE / Александр Шаройко
13
Привет!) Кто как юзает переменные в строках?) Чисто ради интереса Вот так: echo "У меня {$bananasAmount} бананов"; Или вот так: echo "У меня ${bananasAmount} бананов";
Виталий
3
разработчик ботов скидывает портфолио, боты которые он уже создал. А вот как узнать что это именно он их создал?
Gosudar
4
Это может быть все-таки не флудвейт? у меня ботфазер принимает изменения и отображает даже что они изменились, на видео видно что он прислал якобы уже измененное описание, н...
OVERLINK
13
Карта сайта