Где я должен написать свой адаптер / соединитель Kafka для чтения данных из темы?
Я разрабатываю приложение, в котором у меня есть несколько потребителей (проект, который будет принимать сообщение и обрабатывать его, а после обработки отправлять обратно в тему, из которой оно получено).
В проекте Getway, который имеет два метода REST - метод Post, этот метод Post создаст сообщение для одного из потребителей, а этот конкретный потребитель обработает и отправит обратно в Getway.
Теперь у меня есть метод Get, который будет использовать сообщение, отправленное потребителем.
но я хочу удалить этот вызов Get, и я хочу, чтобы все это делалось в одном вызове Post, где я могу создать сообщение для потребителя, и после обработки потребителем я хочу прочитать его
как этого добиться? я должен использовать опрос?
Если это так, то где я должен написать опрос, и есть ли способ обработать это на основе события, как когда-то сообщение, отправленное Getway, читает ответ на какое-то событие.
В моем проекте мы использовали шаблон весенней кафки.