Всем привет, есть вопрос по кафка-стримс. Топология сокращенно такая, что читаю

топик "А" с объектами класса Aclass делаю groupByKey().windowedBy().aggregate().toStream().map() в map преобразую результат аггрегации в Bclass и потом отправляю в топик B.
Проблема в том, что в сообщениях топика B, остается Headers( __TypeId__ = Aclass)
И листенер топика B пытается сериализовать Bclass в Aclass.
Вопрос, что делаю не так?

4 ответов

16 просмотров

А есть ли какие-то причины/сложности, из-за которых в map нельзя поправить header, чтобы в TypeId был Bclass?

Mikhail-Yakunin Автор вопроса
Evgeny Tolbakov
А есть ли какие-то причины/сложности, из-за которы...

Я разобрался, там была проблема в обертке спринга над кафкой. продюсер писал через спринговый JsonSerializer и добавлятл TypedId это (я так понял чисто спринговый подход, чтоб ObjectMapper мог понять что в велью лежит) а в кафка стримс, там упрощенный кастомный Serde без спринга был, и хедер просто передавался дальше. (это дефолтное поведение в стримс, что выглядит не очень логичным) А дальше опять консюмер спринговый со своим JsonDeserializer который смотрел в TypeId и ппадал от несоответствия между значением хедера и что в байтмассиве лежит.

Mikhail-Yakunin Автор вопроса
Evgeny Tolbakov
А есть ли какие-то причины/сложности, из-за которы...

map вроде более высокоуровневая штука и не дает с хедерами работать, для этого Processor API нужно, скорей всего, но глубо не копал. (ну или в сериалайзере это делать)

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

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

Подскажите, а есть vault lite или ченить такое?) А то нужен вольт для похода в вольт, но весит он ~500 мб) как-то многовато для парочки запросов ))
Alexandr Orloff
17
Всем привет, есть небольшая проблема Есть такой скрипт document.addEventListener('DOMContentLoaded', function () { const sliderTabs = document.querySelectorAll('.s...
A da
8
@go1337 @dblackCat Привет. Все ещё дрочусь с fastpanel. Добавил второй домен который должен смотреть в рут того же сайта, но так как это просто домен, а не сайт, я не могу ему...
Ross 🦴
9
До речі, в ево нема можливості чи якого розширення щоб з адмінки з телефона зайти і терміново щось в верстці поправити?
Женя
7
кто-нибудь пользуется тайм-трекерами во время работы? так много разных нагуглил, может есть что-то популярное
Lencore
8
Пацаны. Я разрабатываю софт для инвайтинга на телетон, и столкнулся с такой проблемой, в один из чатов не могу приглашать никого, не дает добавлять, в то же время через официа...
Kernel Panic
11
Скажите, а кому нужен Currency как отдельный плагин вместо полноценного ecommerce в OctoberCMS? Кто-то использует его уже или планирует в будущем? Может я что-то не понимаю?
Igor
13
Розмовами про Рево мені нагадали часи, коли шаблони правилися прямо в адмінці. Хто в курсі, чому відійшли від цієї практики, так блейд не працює? Доволі зручно ж було (інколи)
Женя
3
Всем добрый вечер, Рад оказаться в кругу единомышленников. Начинаю погружаться в мир .net веба. Зовут Ерасыл 🖖 У меня назрел вопрос: Какой процент проектов, прошедшие через в...
Ерасыл
6
Чому? Да тому що без GiT не уявляю нормального проекта а коли код в базі то то так собі
Dmytro Lukianenko
3
Карта сайта