Описание тега alpakka
Alpakka - это собирательное название для различных коннекторов Akka Streams, шаблонов интеграции и преобразований данных.
1
ответ
Alpakka UDP: Как я могу ответить на полученные дейтаграммы через уже связанный сокет?
Я использую Alpakkas UDP.bindFlow для пересылки входящих UDP-дейтаграмм брокеру Kafka. Устаревшее приложение, которое отправляет эти дейтаграммы, требует UDP-ответ от того же порта, на который было отправлено сообщение. Я изо всех сил пытаюсь смодел…
13 сен '18 в 11:28
1
ответ
Получение сбоя обратного вызова для производителя в rabbitmq, когда обратное давление срабатывает
Я хотел выяснить сообщения о сбоях для моих производителей rabbitmq, используя некоторые функции обратного вызова api. Я настроил rabbitmq с помощью [{rabbit, [{vm_memory_high_watermark, 0.001}]}]. и попытался отправить много сообщений, но все сообщ…
25 янв '19 в 04:14
1
ответ
Alpakka MongoDB - укажите тип в MongoSource
В настоящее время я играю с Akka Streams и разъемом Alpakka MongoDB. Можно ли указать тип для MongoSource? val codecRegistry = fromRegistries(fromProviders(classOf[TodoMongo]), DEFAULT_CODEC_REGISTRY) private val todoCollection: MongoCollection[Todo…
10 мар '18 в 12:25
0
ответов
Как использовать Source.queue с Alpakka
Я пытаюсь создать производителя в очередь JMS, которую можно использовать более одного раза; т.е. я не хочу создавать соединение с очередью каждый раз, когда отправляю сообщение. Мне нужен актер с открытым соединением, и каждый раз, когда приходит с…
03 апр '18 в 16:37
2
ответа
Изменить материализованное значение в источнике, используя содержимое потока
Alpakka предоставляет отличный способ доступа к десяткам различных источников данных. Файловые источники, такие как HDFS и FTP, поставляются в виде Source[ByteString, Future[IOResult], Однако HTTP-запросы через Akka HTTP доставляются в виде потоков …
21 янв '19 в 13:10
0
ответов
Получение SQLTransientConnectionException при подключении Oracle с помощью скользкого через Alpakka
Я пытаюсь получить данные из БД, используя alpakka Slick. Я настроил базу данных Oracle в свойствах. При загрузке сессии из SlickSession я получаю исключение ниже 19:44:17.194 [main] DEBUG com.zaxxer.hikari.HikariConfig - slick-oracle.db - configura…
05 дек '18 в 14:31
1
ответ
Может ли alpakka-xml обрабатывать несколько XML-файлов?
У меня проблемы с использованием Alpakka XmlParsing Flow val files: List[String] = ... // file paths locally on disk // simple source emitting the contents of 2 XML files val documentSource = FileIO.fromPath(Paths.get(files.head)) .concat(FileIO.fro…
20 дек '18 в 21:48
2
ответа
Как протестировать Kafka Consumer с Embedded-Kafka-lib, именно с 'withRunningKafka'?
Я должен проверить мой код на предмет потребления всех сообщений от kafka-сервера через встроенный метод withRunningKafka, как показано здесь: https://github.com/manub/scalatest-embedded-kafka Я пытался отправить сообщение в тему через созданного вс…
31 янв '19 в 05:50
1
ответ
Несовместимое ограничение равенства при использовании Akka Kafka Streams
Я пытаюсь использовать Akka Kafka Streams, следуя документации Akka Kafka Streams. Вот код, который у меня есть: ConsumerSettings<byte[], ETLProcessMessage> consumerSettings = ConsumerSettings .create(actorSystem, new ByteArrayDeserializer(), …
10 июн '18 в 09:33
0
ответов
Создать очередь AMQP в обмен на Alpakka
Я хочу создать очередь в существующем обмене для чтения. Другое приложение публикует сообщения для этого обмена и распределяет их по всем очередям участников. Я хочу, чтобы мое новое приложение стало дополнительным подписчиком этих сообщений. Следую…
23 июн '17 в 07:43
1
ответ
FileTailSource выдает исключение нулевого указателя
Я написал следующий код Alpakka val fs = FileSystems.getDefault val resource = getClass.getResource("countrycapital.csv") val source = FileTailSource.lines(Paths.get(resource.toURI), maxLineSize = 8092, pollingInterval = 10000 seconds) У меня есть ф…
01 окт '17 в 00:42
0
ответов
Каков размер выборки по умолчанию при потоковой передаче запросов в Slick?
Я использую Oracle с Slick, интересно, какой размер выборки по умолчанию? это установлено ojdbc? Слик установил свою собственную? это настраивается?
18 сен '18 в 18:02
0
ответов
Назовите или дайте подсказку именования для временных очередей Кролика через Alpakka
Я могу создать временную очередь на обмен: val queueSettings = TemporaryQueueSourceSettings( AmqpUriConnectionProvider(amqpUri), exchange ) val source = AmqpSource.atMostOnceSource(queueSettings, bufferSize = 10) Очередь создается со случайным имене…
29 мар '18 в 02:26
0
ответов
Scala alpaakka s3 соединяется с результатом множественной загрузки DO Spaces 403
Я пытаюсь настроить загрузку файла akka-http в Digital Ocean Spaces. И у меня проблема с многочастной загрузкой. Я использую alpaakka для потоковой передачи файла непосредственно на s3. Однако я получаю 403 ошибку SignatureDoesNotMatch при загрузке.…
29 янв '18 в 13:25
1
ответ
Alpakka S3Client выбрасывает OptionVal$.contains NoSuchMethodError
Я пытаюсь использовать разъем Alpakka S3 Когда я создаю экземпляр S3Client, я получаю исключение Exception in thread "main" java.lang.NoSuchMethodError: akka.util.OptionVal$.contains$extension(Ljava/lang/Object;Ljava/lang/Object;) Это происходит в o…
29 май '18 в 11:42
0
ответов
Медленный коннектор Akka Alpakka S3 при использовании JsonFraming
Я работаю с разъемом Alpakka S3, чтобы загрузить файл json, проанализировать его, выполнить некоторую обработку, а затем загрузить его обратно на S3 с помощью приемника Alpakka S3. В изоляции Source а также Sink Этапы прочитают и впоследствии запишу…
13 мар '18 в 21:19
1
ответ
Alpakka Kafka Невозможно определить пакет
// #atLeastOnceBatch Consumer.Control control = Consumer.committableSource(consumerSettings, Subscriptions.topics("topic1")) .mapAsync(1, msg -> business(msg.record().key(), msg.record().value()) .thenApply(done -> msg.committableOffset()) ) .…
21 июн '18 в 15:03
2
ответа
Акка Раковина никогда не закрывается
Я загружаю один файл на SFTP-сервер, используя Alpakka, но как только файл загружен, и я получил ответ об успешном завершении, мойка остается открытой, как я могу слить ее? Я начал с этого: val sink = Sftp.toPath(path, settings, false) val source = …
26 окт '18 в 09:28
1
ответ
Почему приложение Akka Streams не завершается нормально?
Я написал это простое приложение, используя библиотеку Alpakka Cassandra package com.abhi import akka.actor.ActorSystem import akka.stream.{ActorMaterializer, ClosedShape} import akka.stream.alpakka.cassandra.scaladsl.CassandraSource import akka.str…
12 сен '17 в 04:05
1
ответ
Проблемы загрузки / выгрузки файлов в akka-http/akka-streams
Я пытаюсь использовать akka-streams, akka-http и библиотеку alpakka для загрузки / выгрузки файлов в Amazon S3. Я вижу две проблемы, которые могут быть связаны... Я могу загружать только очень маленькие файлы, самый большой из которых 8 КБ. Я не мог…
19 сен '17 в 19:56