Я создал образец приложения весенней облачной шины с Kafka.Все работает хорошо, когда я вызываю / actator / bus-refresh, события публикуются в теме kafka, и то же самое может быть прослушано другим слушателем приложения.
Проблема в том, что я публикую событие вручную, используя -> context.publishEvent (myEvent), прослушиватель в том же приложении срабатывает, и событие может быть десериализовано, но события не публикуются в kafka.Я пытался опубликовать событие как с пользовательским событием, так и с RefreshRemoteApplicationEvent. Ничего не получалось.
@ RemoteApplicationEventScan помечен для основного класса приложения.