собссно есть компонент. в хибере в энтитилистенере вставлен кафка продьюссер. просто в конструкторе инициализируется.
оттуда и шлет в топик все изменения сущностей.
продьюссер не инжектится в энтитилистенер а прям там через нью создается.

вопрос - как это тестировать. я поднял контекст хибера. прикрутил н2. ну оно и работает - создает реальный продьюссер (я максимум в тестах могу подкрутить конфиг продьюссера) и продьюссер фигачит реально объекты в топик.

как мне замокать в таком конфиге продьюссера (это в идеале) и сдернуть с него объект который в него попадает.

если бы это был простой юнит тест там понятно привинтить каптор и поехали. но здесь то реальный контекст поднимается.

рассматривал вариант с тестконтейнером. но во-первых, контора против тестконтейнеров. во-вторых, мне же придется консамеры еще поднимать и вылавливать объекты. а это прям много кода.

и что тут делать? как внутри энтитилистенера поймать объект который уходит в продьюссер и замокать продьюссер?

мне все же нужен контекст хибера, чтоб проверить как отрабатывает именно взаимодействие с ним.

короче сделал продюсер синглтоном, и просто подсовываю мок-продьюсер в него а потом запускаю контекст.
но только кажется такая штука сломается если продьюсить в несколько потоков начнут.
но с другой стороны, энтитилистенер один на всё приложение поднимается.

спасибо за наводку про спи и абстрактивент.

на данный момент сделал проще. я сделал продюссер синглтон (как кафка кстати рекомендует) ну и добавил два метода - где создается инстанс с настоящим кафкапродьюсером либо если параметр передается то инстанс создается с мок-кафка-продьюсером.

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

меня постапдейт интересует. или посткриейт.

полазал ща по сорцам хибера. тебя не смущает что это оно и есть просто в фантике?

можно делать инжекты через CDI апи. в кварке точно, думаю в его прародителе аналогично. в спринге опять же.

я пока смотрю ивент.спи но пока не понимаю как мне это поможет. мне его точно так же надо будет промокивать где то как то.

мне нравится этот форум. задаешь один вопрос тебе отвечают на совсем другой который ты и не задавал. еще и хамят.

спросил как тестируют кафку мне отвечают про сессии в хибере. спасибо тебе мой хамоватый друг.

в спринге вообще инжект делается через стандартную аннотацию компонент над листенером. ну это так для справки и к теме вопроса не относится.

тему с триггерами в оракле и логингом обновлений я тут предлагал с полгода назад - обосрали точно так же. но ща вроде ок ))

чот тут все какие то агрессоры сплошные. ну я там Стаса еще понимаю а этот то канадец че такой агрессивный. может укусил кто. я тут вроде со всем максимально уважительно общаюсь. по крайней мере стараюсь да. вроде был форум-форумом а ща какое то собрание истеричных тёлок и говноплевателей.

я посмотрел пару вариантов вдовесок как инжектить - через ивентлистенеррегистри просто туда складывать заинжекченные бины, и уже отлавливать непосредственно ивенты хибера, а не конкретной сущности, либо то что агрессивный товарищ сказал - но его вариант мне как то не очень. слишком много кода выходит и что то у меня смутные подозрения.

а вообще спринг без проблем дает называть компонентом энтитилистенер. может это и неправильно и "для мартышек".

касательно потерь - у кого теряет тот пусть и думает почему. интернеты про это знают мало что а значит это чьи то личные проблемы кривых косых рук ног когда сделали говно а потом не знают почему говно. или какие то совсем граничные кейсы.

что то типа того:

автор
EventListenerRegistry registry = ((SessionFactoryImpl) sessionFactory).getServiceRegistry().getService(EventListenerRegistry.class);
registry.appendListeners(EventType.PERSIST, new PersistEventListener() {
@Override
public void onPersist(PersistEvent persistEvent) throws HibernateException { //NOPMD
вытряхиваем сущности из ивента.
}

@Override
public void onPersist(PersistEvent persistEvent, Map map) throws HibernateException { //NOPMD

}
});

ну и второе

ивент пост-что-угодно это не то что будет после того как транзакция закрыта? я хз как там на других континентах, но у меня этот ивент не отрабатывает в случае ролбэка.

чуть выше я код показал. кроме того чел сказал типа не дойдет. я задал вполне разумно вопрос в постперсисте тоже не дойдет? чел меня просто отчленососил на ровном месте вообще без агрессии с моей стороны. что то там про мартышек рассказал про то что это вне инфры и тп (хотя это не так). это норм? мне кажется это типичный пример русского форума с агрессивными форумчанами класса "му**к".

я так потихоньку начинаю понимать бесполезность этого форума.

ответы на мои вопросы были просты до безобразия - юзай готовый прекрасный кафкамок продьюсер из коробки и юзай спай чтоб его заинжектить. всё.
всякие советы как в хибере перехватывать события - это советы хоть и полезные (хотя смотря как их подать) но не совсем по тематике.

Хочешь чтобы тебя забанили?
Меня поражает толерантность чела, когда жрет со своим соседом из одной кастрюли и поносит соседа.
НЕ ОБОБЩАЙ.
смтри: тебя не возмущает что некий агрессивный гражданин тут помоями брызгается причем совершенно немотивированно, но ты возбудился на то что я назвал вещи своими именами. мне совершенно параллельно забанят меня тут или нет. с недавних пор технической ценности этот форум больше не представляет. благодаря таким вот гражданам. тут обсуждать нечего.

все обсуждения скатываются во взаимные оскорбления.

ну что тестировать. я ж не про кафку говорил. а про свой код.
банально - как он себя поведет если кафка недоступна? скипнет мессадж и дальше поедет или упадет?
или как у тебя формируется сам документ что ты шлешь - все ли поля на месте? или поиграться с разными ошибками что может продьюссер возвращать? это ближе к первой части.

я про эти тесты.

или банально сработал ли у тебя в хибере ивент слушающий изменения сущности АДРЕС, когда ты обновил сущность ЮЗЕР присвоив ей вместо АДРЕС1 АДРЕС2. будет ли ивент на обновление? ведь ты юзера же обновляешь с точки зрения кода? а под капотом меняется ФК у АДРЕСа.

насчет спринга - так я его не юзаю уже года 3 :) с чего весь спич и начался что в энтитилистенере нельзя заинжектить бины.
зато при определенном конфиге (где ты уже ивентлистенеры в регистри сам подкладываешь) можно вполне законно это делать без всяких ухищрений.

в любом случае, задачку я сделал, тесты написал. всё работает и не кашляет.

я всё жду когда же ты мне писать то перестанешь ) там проблема где была там и осталась. мессаджи терялись при ребалансе. ты вообще там утверждал что офсеты прыгать не могут. а они могут и это вообще поведение на 143% конвенционное это к слову о технических компетенциях. если вкратце, там я задачу решил просто количеством консамеров равным количеству партиций. что там в ее глубинах происходит - ушло задачами к тем кто заявляет что специалист по кафкам. ) а это как ты понимаешь не я. и, к сожалению, не ты. а следуя вашим советам я потратил неделю выпиливая вертикс чтоб проверить ваши убеждения что после этого точно "терять не будет".

спасибо. мне пока понравилась тема с кафка-мок консамирами и продюссерами. прям то что надо. там есть и методы для симуляции ошибок и методы для вытаскивания очереди сообщений и т.п.

да. пообсуждать тему как там хибер что сохраняет и как правильно это делать - можно отдельно.