Кафка потопил монгоДБ

#mongodb #apache-kafka

#mongodb #апач-кафка

Вопрос:

Из того, что я видел в примерах выполнения ПРИЕМНИКА для базы данных Mongo, мне нужно определить одну конфигурацию ПРИЕМНИКА для каждой коллекции, которую я хочу сохранить в Mongo. Проблема в том, что у меня есть 61 тема в кафке, и я хотел бы создать 61 коллекцию в MongoDB, но меня беспокоит необходимость создания 61 настроек для раковины. Есть ли какой-нибудь альтернативный способ? В базах данных, таких как MySQL, когда я выполняю ПРИЕМ, все разделы автоматически создают таблицы (61 таблица), и я использую единую конфигурацию ПРИЕМНИКА. Я хотел бы иметь что-то подобное для Монго. Вы не могли бы мне помочь?

Ответ №1:

В файле свойств соединителя приемника вы можете использовать topics.regex опцию для включения в белый список нескольких тем.

вы можете передать свое регулярное выражение следующим образом

 topics.regex = ^[A-Za-z._-] $  

Или если у вас есть такие темы, как

 ABC.Topics1 ABC.Topics2 ABC.Topics3  

вы можете передать регулярное выражение следующим образом

 topics.regex = ^(ABC.)([a-z._-] ) $