#java #apache-kafka #kafka-consumer-api
#java #апачи-кафка #кафка-потребитель-api
Вопрос:
У меня есть две темы в брокере. Не используя сообщения из одной темы, я хочу объединить обе темы и буду использовать сообщения из второй темы.
Это потому, что у меня есть два процесса, один процесс отправляет сообщения в тему A. И второй процесс после завершения обработки хочет объединить как topicA, так и topicB. Затем другой процесс будет использовать сообщения из объединенной темы.
Как я могу объединить обе темы в API-интерфейсах kafka высокого уровня. Я использую Kafka 0.10.0.1
Комментарии:
1. смогли ли вы решить эту проблему, у меня очень похожий вариант использования.