alpakka

alpakka copied to clipboard

### Versions used Alpakka version: 3.0.4 Akka version: 2.6.19 ### Expected Behavior I am trying to set JMS_IBM_MQMD_AccountingToken property for an MQ Message which is required to be a byte...

haroldpirum

SQS: Long polling on empty queue makes other pollers wait

2

### Version AkkaHttpVersion = "10.2.9" AlpakkaVersion = "3.0.4" ### Scenario Create two SQS pollers, one per queue. Config: ``` SqsSourceSettings settings = SqsSourceSettings.create() .withWaitTime(Duration.ofSeconds(10)) .withMaxBatchSize(10) ``` Queue A has 10,000...

logicaleap

New connector for Typesense

LukBed

Google pubSub Grpc. Impl PublishWithContext and make subscriber and publisher accessible

1

### Short description ## Publish with context https://github.com/akka/alpakka/blob/d27748d1c1f29ae3b9e93f20d769109bd90bc60a/google-cloud-pub-sub-grpc/src/main/scala/akka/stream/alpakka/googlecloud/pubsub/grpc/scaladsl/GooglePubSub.scala#L28 publish method is not enough when you need to propagate context. FlowWithContext variant also needed. ## Subscriber and publisher accessibillity When you...

bc-tayvs

### Short description Pravega writer support transaction. ### Details First iteration could be to allow short live transactional stream.

cheleb

### Short description Current (experimental) implementation of KVP table writer are not safe (race) ### Details Condittion insert/update with retry allow to support concurrent writes.

cheleb

Hello, I am trying to bring up REST API server on UDS with alpakka as documented in https://doc.akka.io/docs/alpakka/current/unix-domain-socket.html# Here is the sample code . ``` val serverSideFlow = Flow[ByteString] .buffer(1,...

scheruku-in

Use of GzipCodec get a null Compressor in CompressedDataWriter

2

### Versions used Akka version: 2.6.14 Alpakka version: 3.0.4 ### Expected Behavior One should be able to use any compression codec from `org.apache.hadoop.io.compress` in a HdfsFlow. ### Actual Behavior When...

SnipyJulmy

Scala 3 build artifacts

10

What are the plans for providing Scala 3 build artifacts? Would be greatly appreciated to allow easier Scala 3 upgrades for Akka projects without getting into dependency versioning problems.

AndreasPresthammer

Impl PublishWithContext and make subscriber and publisher accessible

1

Made subscriber and publisher package private. In case when you need custom approach or just client [Issue](https://github.com/akka/alpakka/issues/2881)

bc-tayvs