Где я должен написать свой адаптер / соединитель Kafka для чтения данных из темы? - PullRequest
0 голосов
/ 13 ноября 2018

Я занимаюсь разработкой приложения, в котором у меня есть несколько Потребителей (проект, который будет обрабатывать сообщение и обрабатывать его, а после обработки отправлять обратно в тему, из которой оно получено)

Проект Getway, в котором есть два метода REST - метод Post, этот метод Post создает сообщение для одного из потребителей, и этот конкретный потребитель обрабатывает и отправляет обратно в Getway

Теперь у меня есть метод Get, который будет использовать сообщение, отправленное потребителем.

но я хочу удалить этот вызов Get, и я хочу, чтобы все это было сделано за один вызов Post, где я могу создать сообщение для потребителя, и после обработки потребителем я хочу прочитать его

как этого добиться? я должен использовать опрос?

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

В моем проекте мы использовали шаблон весенней кафки.

...