Я подключаю Alpakka JMS к теме Oracle AQ.Сообщение, отправленное из БД Oracle, имеет тип sql типа...

Я пытаюсь использовать потребительскую библиотеку https://doc.akka

Я пытаюсь создать простого продюсера, который создает тему с некоторыми разделами, предоставленными...

У меня есть следующий класс: case class Alpakka(id:Int,name:String,animal_type:String) Я пытаюсь...

Я написал программу akka, которая использует комбинацию akka stream и alpakka. У меня есть actorRef...

Я вижу, например, исключение следующим образом: org.apache.kafka.common.errors

Ниже код выдает OOO на экземпляре EC2 в течение 15 минут после запуска (конфигурация java xms 1024...

Интересно, является ли источник для коммитирования только опросом новых записей, когда записи...

Я думаю, что эта проблема связана с # 539 , но я не знаю, является ли это ошибкой, или пользователь...

Я пытаюсь реализовать очень простой сервис, связанный с брокером AMQP с помощью Alpakka. Я просто...

У меня есть пространство ключей и таблица cassandra, которые выглядят следующим образом: CREATE...

Мы пытаемся использовать Akka Streams с Alpakka Kafka для потребления потока событий в сервисе.Для...

В другом месте в StackOverflow ( ссылка ) доступ к AWS S3 осуществляется следующим образом:...

У меня есть локальный кластер кафки только одного брокера.У меня есть два потока akka: один поток...

У меня есть Alpakka Elasticsearch Sink, который я храню между запросами.Когда я получаю запрос, я...

Я должен проверить мой код на предмет потребления всех сообщений от kafka-сервера через встроенный...

Я использую эту библиотеку: https://doc.akka.io/docs/alpakka/current/sqs.html для работы с SQS. Я...

Я хотел узнать сообщения об ошибках для моих производителей rabbitmq, используя некоторые функции...

Alpakka предоставляет отличный способ доступа к десяткам различных источников данных

Я новичок в альпакке.Я использовал следующий код в Alpakka, используя соединитель MongoDB для...

У меня возникли проблемы при использовании Alpakka XmlParsing Flow val files: List[String] = ... //...

Мы используем потоки akka с alpakka kafka для получения сообщений из разных тем, используя подписку...

Мы создаем высокопроизводительное приложение для обработки потоков с низкой задержкой.Мы используем...

Я сейчас начну. Я использую ScanamoAlpakka. У меня есть следующее: Map( 'field1 -> value1,...

Я пытаюсь получить данные из БД, используя alpakka Slick .Я настроил базу данных Oracle в свойствах