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

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

6 ответов

27 просмотров

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

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

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

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

А если изначально бот работал так : есть сайт онлайн школы. У каждого ученика свой кабинет. Где он авторизуется по своим данным. И уже в кабинете, на самом сайте делает оплату...
Денис 💡 Фрилансер
13
что это и почему оно? executor.start_polling(bot, skip_updates=True, on_startup=on_startup, File "/usr/local/lib/python3.10/dist-packages/aiogram/utils/executor.py", line 4...
𐌍𐌄 ᕓ𐌄𐌓𐌌Ꝋ𐌓𐌄
2
Напомните пожалуйста, v1.1 работает на PHP 8.2?
Ross
7
А что насчет FluentValidation? тоже ведь есть альтернатива у МС.
devman
13
Ребят, всем привет) Кто юзал/юзает Postgres? Я на MySQL сделал простенький сайт для диплома, но я внезапно обнаружил условие что надо было на Postgres) Проблема в том, что я н...
Dororo Steeeve
4
Спасибо. Начну с клиент-сервер. Там разберусь И еще вопрос - можно ли как то джобы отправлять на определенные клиенты? Например есть vdi и linux машина. Можно ли задачу оправ...
Sergey Ivanov
4
Читаю сейчас [нет, уже больше не читаю!] курсовую о Булгакове, написанную, похоже, с помощью ChatGPT. Это удивительный психоделический опыт. Текст в основном написан в стиле б...
✨ Uni [🌊 В отпуске]
1
Всем привет! подскажите, кто-то использовал vault + гео-распределенный etcd-кластер (мемберы в разных цодах)? какие есть подводные камни? и стоит ли вообще такое делать?
Василиса Васильева
4
Тут кто-то шарит в мед оборудовании?
Benz
10
Всем привет. Я только начал изучать nomad и есть несколько вопросов. Я хочу развернуть 1 сервер и 1 клиент чтобы потыкаться и пощупать как работает это. А можно ли развернуть...
Sergey Ivanov
2
Карта сайта