#spring-boot #spring-kafka
Вопрос:
Я ищу передачу сообщений из нескольких источников в несколько тем назначения. 
Я могу выполнить итерацию, перечислить темы назначения и отправить одну за другой. Но есть ли какой-то простой, отличный от этого подход.
Спасибо!
Комментарии:
1. Интересно, почему ты хочешь сделать что-то подобное?
2. @ray У нас есть требование, так как мы должны сделать некоторое обогащение. Перед отправкой в несколько тем
3. Вы можете создать несколько потребителей и производителей в одном приложении
Ответ №1:
Больше похоже на сценарий потоков Кафки: https://docs.confluent.io/platform/current/streams/index.html.
Увидеть их StreamsBuilder.stream(final Collection<String> topics) и KStream.branch(final Predicate<? super K, ? super V>... predicates) .
Вот хороший пример того, как разбить на несколько тем: https://github.com/nodefluent/kafka-streams/issues/85.
Смотрите также удобный KafkaStreamBrancher API в spring-kafka : https://docs.spring.io/spring-kafka/docs/current/reference/html/#using-kafkastreambrancher