Sean Glover

``` --> [akka.stream.alpakka.ftp.StrictHostCheckingSftpSourceSpec: FtpIOSource should retrieve a bigger file (~2 MB) from path and offset as a stream of bytes] Start of log messages of test that [Failed(java.lang.AssertionError: assertion failed:...

``` [error] org.parboiled.errors.ParserRuntimeException: Error while parsing action 'Root/Sequence/ZeroOrMore/Sequence/Block/FirstOf/Sequence/FirstOf/Table/Sequence/Optional/Sequence/NodeSequence/Sequence/TableRow/Sequence/OneOrMore/Sequence/TableCell/NodeSequence/Sequence/OneOrMore/Sequence/Inline/Inline_Action1' at input position (line 4, pos 47): [error] This library combines the convenience of Akka Streams with KCL checkpoint management, failover, load-balancing,...

``` [error] Test docs.javadsl.CassandraSourceTest.createSession failed: java.util.concurrent.TimeoutException: null, took 10.01 sec [error] at java.util.concurrent.CompletableFuture.timedGet(CompletableFuture.java:1784) [error] at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1928) [error] at scala.concurrent.java8.FuturesConvertersImpl$CF.super$get(FutureConvertersImpl.scala:84) [error] at scala.concurrent.java8.FuturesConvertersImpl$CF.$anonfun$get$2(FutureConvertersImpl.scala:84) [error] at scala.concurrent.BlockContext$DefaultBlockContext$.blockOn(BlockContext.scala:57) [error] at scala.concurrent.package$.blocking(package.scala:146) [error] at...

Updated hbase:1.4 image causing connection failures

5

An update to the `HarkiSekhon/hbase:1.4` image broke our Alpakka hbase connector integration test some time after March 8th ([last successful hbase integration test build](https://travis-ci.com/github/akka/alpakka/jobs/293391851)). An earlier cached version of the...

Promise based transaction draining logic

7

The draining control for Transactional sources will occasionally get into a situation where the consumer source can no longer be signalled by the producer that a transaction is aborted, in...

Support producer only Kafka transactions

2

### Short description Support producer only Kafka transactions in `Transactional.sink|flow`. ### Details Alpakka Kafka currently only supports a consume, transform, produce workflow for Kafka Transactions. In some cases it may...

Failed: A consume-transform-produce cycle must rebalance safely using transactional partitioned flow, timeout

2

From an unrelated PR build https://travis-ci.org/github/akka/alpakka-kafka/jobs/696759321#L465 ``` Failed(java.lang.Error: Timeout while waiting for desired consumer group state. Tried [100] times, slept [100 milliseconds] in between.) ```

### Short description As discussed in #1285 ``` var batch = CommittableOffsetBatch.empty batch = batch.updated(makeCommittableOffset(1)) batch = batch.updated(makeCommittableOffset(3)) batch = batch.updated(makeCommittableOffset(4)) batch = batch.updated(makeCommittableOffset(2)) // should generate warning that this...

Document adding a buffer before transactional producer

3

### Short description Document adding a buffering stage before the transactional producer so that some amount of messages can still be processed by user business logic while a commit is...

### Short description As part of the effort to remove embedded-kafka (#1114) I came across a test that uses Kafka core library types to parse messages found in `__consumer_offsets` to...