Как использовать Apache Pulsar для обработки заказанных партий

Question

Рассмотрим следующий пример:

• В мире существуют десятки тысяч магазинов, в которых должны регистрироваться внутренние процессы

• Для каждогорасположение магазина порядок внутренних задач процесса должен быть сохранен

• Глобального списка магазинов нет.Задачи процесса могут летать из одного местоположения, без предварительного знания об этом месте

• Запись задач процесса имеет решающее значение, ни одна задача не должна быть пропущена (аварийное переключение)

Насколько я понимаю, для того, чтобы сохранить порядок процессов в каждом местоположении, мне нужно создать тему для каждого местоположения магазина, например:

persistent: // public / default / store-san-francisco

И для каждой темы мне нужно создать эксклюзивного потребителя с отказоустойчивостью.

Проблема в том, что, поскольку я заранее не знаю местоположения, каков наилучший способ созданияспециальный потребитель для каждого неизвестного местоположения?

Answer 1

Новичок в Pulsar, но я понимаю, что Брокер автоматически создаст тему, если она не существует.Кроме того, поскольку вы можете перечислять темы из утилиты администратора консоли, я бы предположил, что вы также можете сделать это программно, сохранить текущий список тем / потребителей и создать новую, если появится новая тема.