Можно ли напрямую построить конвейер, используя Logstash в качестве источника и Cassandra в качестве пункта назначения. Если нет, то как лучше всего это сделать?

Я использую конвейер Streamsets для потоковой передачи данных из браузеров. Поэтому для этого я создал конвейер с источником HTTP-сервера для отправки данных из браузеров Javascript и попытался записать этот URL-адрес с помощью клиента REST, и он...

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

Я использую внешний javascript внутри оценщика javascript в наборах потоков. Но когда я пытаюсь загрузить внешний код, я получаю следующую ошибку. Как мне это решить. Спасибо ОШИБКА SafeScheduledExecutorService — неперехваченный бросок из...

Я использую StreamSets в качестве инструмента для загрузки записей из базы данных Oracle в темы Kafka. Теперь я хочу использовать его через сам StreamSets, а также хотел подсчитать количество записей в темах Kafka. Как мне это сделать....

У меня есть конвейер StreamSets, где я читаю из удаленной базы данных SQL Server, используя компонент JDBC в качестве источника, и помещаю данные в Hive и озеро данных Kudu. Я столкнулся с некоторыми проблемами с типом двоичных столбцов, поскольку...

У нас есть требование использовать переменную связывания оракула для выполнения любых запросов к базе данных оракула, благодаря чему он будет выполнять мягкий синтаксический анализ, а не жесткий синтаксический анализ для повышения производительности....

Нам нужно добавить поле «doc_creationtime» в формате даты или строки «yyyy-mm-ddTHH:mm:ss.SSSZ» в каждый документ, вставленный в коллекцию MongoDb с использованием конвейера. Значение даты не должно рассчитываться поэтапно. Он должен быть извлечен...

Я пытаюсь загрузить данные из облачного хранилища Google в локальную файловую систему, используя следующее: Свойства My Origin (Google Cloud Storage): Общий префикс = /Target_Files/2019_12_02_Part1/ Шаблон префикса =...

Я использую StreamSets для создания конвейера для передачи данных из таблицы, которая находится в базе данных sqlserver, в таблицу в базе данных postgres. JDBC Query Consumer --> Timestamp --> JDBC Producer Конвейер проходит проверки и...

У меня есть контейнер StreamSets в файле docker compose и jar, которые созданы в соответствии с руководством - https://github.com/streamsets/tutorials/blob/master/tutorial-processor/readme.md...