Kafka Sink Connector - Разделите темы между задачами

Я пытаюсь создать собственный коннектор раковины MongoDb для Apache Kafka. Мои конфиги Sink Connector следующие:

    name=mongodb-connect-sink
    connector.class=MongodbSinkConnector
    tasks.max=2
    uri=mongodb://localhost:27017
    databases.collections=Collection1,Collection2
    topics=Topic1,Topic2

И в разъеме taskConfig() метод, я разделяю коллекции и темы и устанавливаю 1 коллекцию и 1 тему на задачу. Но это, кажется, становится переоцененным, и все указанные темы назначаются для всех задач. Есть ли способ предотвратить это, кроме как зарегистрировать их как отдельные разъемы?

Источник

0 ответов

Другие вопросы по тегам