Alpakka Documentation
The Alpakka project is an initiative to implement stream-aware and reactive integration pipelines for Java and Scala. It is built on top of Akka Streams, and has been designed from the ground up to understand streaming natively and provide a DSL for reactive and stream-oriented programming, with built-in support for backpressure. Akka Streams is a Reactive Streams and JDK 9+ java.util.concurrent.Flow-compliant implementation and therefore fully interoperable with other implementations.
- Overview
- Data Transformations
- AMQP
- Apache Camel
- Apache Cassandra
- Apache Geode
- Apache Kafka
- Apache Kudu
- Apache Solr
- Avro Parquet
- AWS EventBridge
- AWS DynamoDB
- AWS Kinesis and Firehose
- AWS Lambda
- AWS S3
- AWS SNS
- AWS SQS
- Azure Storage
- Azure Storage Queue
- Couchbase
- Elasticsearch
- Eventuate
- File
- FS2
- FTP
- Google Common
- Google Cloud BigQuery
- Google Cloud BigQuery Storage
- Google Cloud Pub/Sub
- Google Cloud Pub/Sub gRPC
- Google Cloud Storage
- Artifacts
- Configuration
- Store a file in Google Cloud Storage
- Download a file from Google Cloud Storage
- Access object metadata without downloading object from Google Cloud Storage
- List bucket contents
- Rewrite (multi part)
- Apply Google Cloud Storage settings to a part of the stream
- Bucket management
- Running the example code
- Google FCM
- gRPC
- Hadoop Distributed File System - HDFS
- HBase
- Huawei Push Kit
- HTTP
- IBM Bluemix Cloud Object Storage
- InfluxDB
- IronMQ
- Jakarta Messaging (JMS)
- JMS
- MongoDB
- MQTT
- MQTT Streaming
- Opensearch
- Pulsar
- Pravega
- Server-sent Events (SSE)
- Slick (JDBC)
- Spring Web
- TCP
- UDP
- Unix Domain Socket