Я новичок в Kafka Connect. Я планирую использовать источник подключения kafka для чтения данных из таблиц моей MySQL базы данных в одну из тем kafka. Теперь, поскольку моя исходная таблица является хранилищем транзакционных данных, я могу получить новую запись, вставленную в нее, или запись может быть обновлена. Теперь я пытаюсь понять, как достичь параллелизма для чтения данных из этой таблицы, и мой вопрос:
- Могу ли я использовать max.tasks для достижения параллелизма (иметь более одного потока) читать данные и пу sh на кафку топи c? Если да, пожалуйста, объясните.
Спасибо