akka/alpakka

View on GitHub

Alpakka is a Reactive Enterprise Integration library for Java and Scala, based on Reactive Streams and Akka.

Stars: 1.3k
Forks: 630
Open beginner issues: 0
Indexed issues: 222
Avg merge: 8h 14m
Merged PRs (30d): 5

Dominant language: Scala
License: No license data
Last GitHub push: Sep 11, 2026
Latest indexed: Sep 14, 2026
Contributing guide: Contributing guide
Code of conduct: Code of conduct
Beginner labels: help wanted

Open All

222 open issues indexed

RSocket connector Open

p:new

akka/alpakka#25 · 9 comments · 1 reaction · 0 assignees · Indexed Sep 14, 2026
Caffeine Flow Open

p:new

akka/alpakka#34 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Apple Push Connector Open

p:new

akka/alpakka#61 · 6 comments · 3 reactions · 0 assignees · Indexed Sep 14, 2026
Discuss whether importing ts-reaktive-marshal would be a good fit Open

p:new

akka/alpakka#63 · 7 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Postgres connector Open

p:new

akka/alpakka#67 · 15 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
ZeroMQ connector Open

p:new

akka/alpakka#78 · 2 comments · 3 reactions · 0 assignees · Indexed Sep 14, 2026
Apache IGNITE integration Open

p:new

akka/alpakka#82 · 0 comments · 2 reactions · 0 assignees · Indexed Sep 14, 2026
Add anonymous access to S3 Open

p:aws-s3

akka/alpakka#90 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Implement Amazon's Request-signing Test Suite Open

help wanted p:aws-lambda p:aws-s3 p:aws-sns p:aws-sqs

akka/alpakka#98 · 4 comments · 1 reaction · 0 assignees · Indexed Sep 14, 2026
define Committable Open

akka/alpakka#104 · 14 comments · 1 reaction · 0 assignees · Indexed Sep 14, 2026
jena streamRDF connector Open

p:new

akka/alpakka#159 · 3 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Support for SOAP Open

p:new

akka/alpakka#176 · 7 comments · 8 reactions · 0 assignees · Indexed Sep 14, 2026
Backblaze B2 support Open

p:new

akka/alpakka#198 · 3 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
KairosDB connector Open

p:new

akka/alpakka#224 · 2 comments · 4 reactions · 0 assignees · Indexed Sep 14, 2026
Contraband for data types Open

akka/alpakka#232 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
SQS: Add possibility to define custom failure handler both for Source and Sink Open

p:aws-sqs

akka/alpakka#251 · 5 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Add Chronicle Queue support Open

p:new

akka/alpakka#258 · 9 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Nats Streaming connector Open

p:new

akka/alpakka#260 · 15 comments · 16 reactions · 0 assignees · Indexed Sep 14, 2026
Testkit module proposition Open

akka/alpakka#268 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
NSQ Connector Open

p:new

akka/alpakka#300 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Hazelcast Connector Open

p:new

akka/alpakka#377 · 2 comments · 1 reaction · 0 assignees · Indexed Sep 14, 2026
A Hook to release all JMS Resources when application shutdown. Open

p:jms

akka/alpakka#403 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[FTP] connectionSettings should be passed implicitly Open

p:ftp

akka/alpakka#421 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Neo4j support Open

p:new

akka/alpakka#439 · 1 comment · 4 reactions · 0 assignees · Indexed Sep 14, 2026
JMS: Provide a possibility to read the JMSMessageId after sending in JmsSinkStage Open

p:jms

akka/alpakka#442 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
support for Dynamodb Streams Open

p:dynamodb

akka/alpakka#447 · 1 comment · 5 reactions · 0 assignees · Indexed Sep 14, 2026
Monitoring connectors Open

akka/alpakka#463 · 10 comments · 2 reactions · 0 assignees · Indexed Sep 14, 2026
Add support for Oracle Bare Metal Cloud Storage Open

p:new

akka/alpakka#500 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
STOMP support Open

help wanted p:new

akka/alpakka#514 · 6 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Elasticsearch: No way to specify a source filter or other search options Open

p:elasticsearch

akka/alpakka#591 · 5 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
S3 Connector - Add ability for Client Side encryption Open

p:aws-s3 question

akka/alpakka#676 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Failure: HttpApiSpec Open

p:google-cloud-pub-sub

akka/alpakka#709 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Does the elasticsearch connector support aggregations? Open

p:elasticsearch

akka/alpakka#744 · 4 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
OrientDb: type erasure warnings in OrientDBFlowStage Open

p:orientdb

akka/alpakka#772 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Should Alpakka look to generalise durable queue interfaces? Open

discussion

akka/alpakka#779 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
MqttMessage should pass through additional data Open

p:mqtt

akka/alpakka#801 · 4 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Undocumented MqttConnectionSettings Open

p:mqtt

akka/alpakka#803 · 6 comments · 1 reaction · 0 assignees · Indexed Sep 14, 2026
Push API for AlpAkka Google Cloud Pub Sub Open

p:google-cloud-pub-sub

akka/alpakka#826 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
GooglePubSub.subscribe does not clean up properly on termination Open

p:google-cloud-pub-sub

akka/alpakka#836 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
S3 Connector: Add option to disable chunked encoding Open

p:aws-s3

akka/alpakka#879 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
PostgreSQL: Lightweight Change Data Capture / Event Log Open

p:new

akka/alpakka#889 · 2 comments · 5 reactions · 0 assignees · Indexed Sep 14, 2026
Support FoundationDB Open

p:new

akka/alpakka#903 · 0 comments · 3 reactions · 0 assignees · Indexed Sep 14, 2026
Solr: does not return a more useful response for errors Open

p:solr

akka/alpakka#917 · 2 comments · 1 reaction · 0 assignees · Indexed Sep 14, 2026
Add support for AMPQ 1.0 Open

p:amqp

akka/alpakka#933 · 6 comments · 2 reactions · 0 assignees · Indexed Sep 14, 2026
Stream a Multi-Files Source Open

akka/alpakka#941 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Line ending agnostic line framing Open

p:new

akka/alpakka#968 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
S3 connector fails to download object due to absence of access key Open

p:aws-s3

akka/alpakka#969 · 4 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Kinesis sink/flow constructing payloads greater than 5mb in size Open

p:kinesis

akka/alpakka#983 · 11 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Exposing MQTT connection state Open

p:mqtt

akka/alpakka#985 · 4 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
SFTP ecdsa-sha2-nistp256 Open

p:ftp

akka/alpakka#1010 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026

akka/alpakka

Get new issues in your inbox