Моя топология читает сообщения от kafka, но наша исходная система производит вывод через JMS. Я создал приложение-адаптер для чтения данных из очереди и помещения их в Kafka.
Теперь я подумываю об использовании другой топологии с JMSSpout для чтения сообщений из очереди и с KafkaBolt для публикации sh сообщений в Kafka. И моя текущая топология может забрать данные из Кафки. Кто-то может задать вопрос: почему мне нужно помещать сообщения в kafka, почему моя вторая топология не может просто начать получать сообщения из очереди. Ответ - мне нужно иметь сообщения на kafka, чтобы я мог воспроизвести их для другой итерации, если мне нужно.
Теперь мой вопрос здесь - Как настроить эту комбинацию JMSSpout и KafkaBolt, которая охватывает следующий сценарий ios -
- Топология повторно подключается к очереди и Kafka, в случае, если один из этих 2 go down
- Либо JMS выходит из строя, либо kafka, я не должен терять сообщения