с определенным заголовком?
Посмотрите в сторону ksqlDB https://habr.com/ru/company/neoflex/blog/593769/
Спасибо, но это, к сожалению, не подходит
Привіт, а що ти маєш на увазі? Бо типу якого б ти консюмера не створив і як би не намагався читати ти прочитаеш усе що відасть тобі кафка по топіку, а наскільки мені відомо на рівні протоколу немає опціїї фільтраціїї на poll, це б вже була не кафка=) Але ти звісно можешь зробити це кодом, ksql тобі пропонуют тому що він може трансформувати один топік в інший, але по суті це kafka stream, а це в свою чергу kafka consumer та kafka producer, тому як би занадто мощно підключати ksql заради однієї невеликої мети. Якщо ти хочешь якось повідовлення розрізняти то то можешь типу створити декілька топіків, типу перший для усього, другий для хедеру наприклад channel:1, а третій для хедеру channel:2. Ну і взагалі можешь побудувати продюсера так що він буде динамічно створювати топіки, але на мою думку до чогось доброго це не приведе. Ти краще запитай яку проблему ти намагаєшся вирішити загалом.
Привет, мне нужно уметь читать сообщения определенной версии схемы. Я могу попробовать сделать это через группы, но думал может есть возможность фильтровать
Можно такие особенные месседжи прибить гвоздями к кастомному partition и в consumer указать assign
Так просто читай всё и пропускай неподходящее, других вариантов всё равно особо нет.
Обсуждают сегодня