Я построил конвейер в наборах потоков для чтения данных из моего sql и изменения захвата данных. Когда я начал выполнение конвейера, я получаю следующую ошибку.
Состояние конвейера: START_ERROR: java.lang.NoClassDefFoundError: org/apache/kafka/common/KafkaException