Apache Pekko Connectors Documentation
The Apache Pekko Connectors project is an open source initiative to implement stream-aware and reactive integration pipelines for Java and Scala. It is built on top of Apache Pekko 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. Apache Pekko 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 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 Queue
- Couchbase
- Elasticsearch
- File
- 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
- JMS
- MongoDB
- MQTT
- MQTT Streaming
- Opensearch
- OrientDB
- Pravega
- Server-sent Events (SSE)
- Slick (JDBC)
- Spring Web
- TCP
- UDP
- Unix Domain Socket
1.0.2