Можем ли мы запустить встроенный брокер Kafka, как ActiveMQ? - PullRequest
Новая
       52

Можем ли мы запустить встроенный брокер Kafka, как ActiveMQ?

0 голосов
/ 16 мая 2018

Когда я говорю, что это встроено, я имею в виду следующую тему: https://stackoverflow.com/a/28858630/5375223

Позвольте мне дать некоторый контекст, в нашем проекте мы в настоящее время используем ActiveMQ в качестве брокера обмена сообщениями, и теперь мы планируем перейти на Kafka. Пожалуйста, смотрите прикрепленное изображение.

enter image description here

Как и на приведенной выше диаграмме, производитель отправляет данные встроенному брокеру, а затем встроенный брокер отправляет данные внешнему брокеру, который подключен через конфигурацию URL-адреса сети, как показано ниже. Таким образом, если внешний посредник недоступен, все сообщения будут храниться во встроенном посреднике, пока он не станет доступным. 

<networkConnectors>
    <networkConnector name="localhost" uri="static://somehost:1234" staticBridge="true">
        <staticallyIncludedDestinations>
            <queue physicalName="someQueueName"/>
        </staticallyIncludedDestinations>
    </networkConnector>
</networkConnectors>

Итак, есть ли что-нибудь подобное с Кафкой? вместо прямого подключения к брокеру, работающему вне приложения

1 Ответ

0 голосов
/ 16 мая 2018

Spring для Apache Kafka предоставляет встроенный брокер, но он в основном предназначен для тестирования.

Нет ничего встроенного в kafka для "пересылки" записей от одного брокера (встроенного или иного) вдругой;вам понадобится код для этого.

Какова цель сделать это в любом случае?Почему бы просто не отправить напрямую внешнему брокеру?

Независимо от этого, Kafka предназначен для использования с несколькими узлами и несколькими экземплярами Zookeeper для обеспечения отказоустойчивости и предотвращения потери данных, поэтому использование одного локального экземпляра, скорее всего, уменьшит или устранитчто.

...