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

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

6 ответов

28 просмотров

Посмотрите в сторону 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
Привет, мне нужно уметь читать сообщения определен...

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

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

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

'frakturBold' => ['𝖆', '𝖇', '𝖈', '𝖉', '𝖊', '𝖋', '𝖌', '𝖍', '𝖎', '𝖏', '𝖐', '𝖑', '𝖒', '𝖓', '𝖔', '𝖕', '𝖖', '𝖗', '𝖘', '𝖙', '𝖚', '𝖛', '𝖜', '𝖝', '𝖞', '𝖟', '𝕬', '𝕭', '𝕮', '𝕯'...
Roma
4
Есть полностью собранная база "шрифтов" - подобных символов?
Shen
9
Короче получается только кнопки не поменять А кнопки вроде тоже слетают при редактировании не?
inc.
10
Дорогие друзья, есть тут те, Кто рад поучаствовать в работе и в команде над игровой платформой? Мы делаем игровую и уникальную платформу. Стек платформы Go и React. Нам ...
Александр Цивин :)
2
Тг будет банить бота который принимает донаты без stars? Бот буквально на 10-20 человек
Vexylon
6
Век живи, век учись и продолжай удивляться Carbon Оказывается, в Carbon дату можно задавать даже текстом 😲 <?php use Carbon\Carbon; $october_date = new Carbon("last sunday o...
Igor
3
Кто сколько за бота берёт? (Я покупать не хочу)
Ivan Aleksandrovich
10
а у тя шо за бот?
Андрей
6
Приветы. Если бот доступен только пользователям из России и Беларуси, старсы для него неизбежны? Как Apple планируется собирать платежи с покупок в сторе на территориях, где у...
Prokhor Chulkov
8
Qq, возможно сталкивался кто Повесил на бота обработку апдейтов типа chat_member, при этом апдейты доходят только когда с ботом что-то делают, на саб/ансаб юзеров ему насрать...
𐌍𐌄 ᕓ𐌄𐌓𐌌Ꝋ𐌓𐌄
13
Карта сайта