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

вопрос - как это тестировать. я поднял контекст хибера. прикрутил н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

}
});

ну и второе

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