Alpakka - это собирательное название для различных коннекторов Akka Streams, шаблонов интеграции и преобразований данных.

Alpakka - это инициатива сообщества, которая предоставляет соединители, шаблоны интеграции и преобразования данных, созданные с помощью Akka Streams. Этот инструментарий предназначен для «современной альтернативы Apache Camel» (отсюда и его название, которое является гомофоном слова «альпака», родственника верблюда, и впервые было использовано в качестве кодового имени для старый акка-верблюжий модуль).

Из вступительного сообщения в блоге :

В Akka Streams уже есть много полезного для интеграции. Определение конвейеров обработки - это то, что представляет собой DSL Akka Streams, и это именно то, что вам нужно для работы с потоковыми данными, которые не могут поместиться в памяти в целом. Он эффективно обрабатывает обратное давление без блокировки, предотвращая ошибки нехватки памяти, что является типичной проблемой при использовании неограниченной буферизации с производителями, которые работают быстрее, чем потребители.

Разъемы :

  • AMQP
  • Apache Geode
  • AWS DynamoDB
  • AWS Kinesis
  • AWS Lambda
  • AWS S3
  • AWS SNS
  • AWS SQS
  • Очередь хранилища Azure
  • [ 1119] Cassandra
  • Elasticsearch
  • Файл
  • FTP
  • Google Cloud Pub / Sub
  • HBase
  • IronMq [ 1125]
  • JMS
  • MongoDB
  • MQTT
  • Отправленные сервером события (SSE)
  • Slick (JDBC)
  • Spring Сеть

Шаблоны интеграции :

  • Разветвитель

Преобразования данных :

  • Строки анализа
  • JSON
  • Сжатие / распаковка
  • Разделенные запятыми значения (CSV) [ 1136]
  • RecordIO Framing
  • Расширяемый язык разметки (XML)

Дополнительные ссылки :