Я пытаюсь подключить структурированную потоковую передачу Spark к kafka, и она выдает следующую ошибку: Исключение в потоке «основной» java.lang.ClassNotFoundException: не удалось найти источник данных: kafka. Пожалуйста, найдите пакеты в ......

Я прохожу через kafka connect, и я пытаюсь понять концепции. Допустим, у меня есть кластер kafka (узлы k1, k2 и k3), и он запущен, теперь я хочу запустить рабочих kafka connect на разных узлах, скажем, c1 и c2 в распределенном режиме. Несколько...

Я следую этому руководству: https://docs.confluent.io/4.0.0/installation/docker/docs/tutorials/connect-avro-jdbc.html и поместите здесь свой код: https://github.com/lexsteens/kafka-connect-tutorial У меня проблема при регистрации коннектора...

Контекст Мы используем Kafka для обработки больших сообщений, очень редко до 10 МБ, но в основном в диапазоне 500 КБ. Обработка сообщения может занять до 30 секунд, но иногда и минуту. Проблема Обработка данных с меньшим количеством...

Я просматривал эту статью , которая объясняет, как гарантировать, что сообщение обрабатывается ровно один раз, выполнив следующие действия: Чтение (тема, раздел, смещение) из базы данных при запуске / перезапуске Прочитать сообщение из...