Кафка соединяется с монго оплогом

Question

Я хочу завершить монлогный оплог и транслировать его через Kafka. Но есть много баз данных и коллекций, и я просто хочу получить данные об обновлении для одной из них.Если вы хотите отфильтровать нужные записи операций из всех записей операций в журнале операций, это может повлиять на производительность.Поэтому я хотел бы попросить лучшего решения.Пожалуйста, дайте мне несколько предложений.

Answer 1

Не ясно, какой инструмент вы используете, но Debezium поддерживает их для применения фильтрации

• database.whitelist
• collection.whitelist

ТакжеНепонятно, что «повлияет на производительность», поскольку вы уже читаете полный журнал операций, но выполнение фильтра (то есть удаление всех записей, не соответствующих условию) не должно иметь значительного влияния, поскольку проверки логических / регулярных выражений обычно заканчиваются очень быстро.