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

У меня есть проект Quarkus с реактивным обменом сообщениями Smallrye на основе Kafka. Поскольку я хочу работать со сложным pojo, мне нужен специальный де- / сериализатор. Я хотел бы сделать эти два класса bean-компонентов CDI, чтобы я мог внедрять...

Я хотел бы распространить состояние JTA (= транзакцию) между транзакционной конечной точкой REST, которая отправляет сообщение на коннектор реактивного обмена сообщениями. @Inject @Channel("test") Emitter<String> emitter; @POST...