Sean Glover

Failed: A consume-transform-produce cycle must complete partitioned source with a sub source failure and rebalance of partitions to second instance, timeout

2

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

``` [info] - should support `withOffsetContext` *** FAILED *** (25 seconds, 102 milliseconds) [info] A timeout occurred waiting for a future to complete. Queried 101 times, sleeping 150 milliseconds between...

Several test failures ``` [info]

Failed: CommittingWithMockSpec, should support commit batching with metadata

2

``` --> [akka.kafka.internal.CommittingWithMockSpec: should support commit batching with metadata] Start of log messages of test that [Failed(java.util.NoSuchElementException: key not found: topic2-1)] ``` https://travis-ci.org/github/akka/alpakka-kafka/jobs/718648277#L629

Log the number of outstanding commit requests

1

### Short description Each poll, log how many accumulated commit requests are outstanding to help come up with a new default value for `ProducerSettings.parallelism` used in Producer flows and sinks....

``` [info] TransactionsFailureRetryExample [info] - should work *** FAILED *** (25 seconds, 70 milliseconds) [info] A timeout occurred waiting for a future to complete. Queried 101 times, sleeping 150 milliseconds...

Timeout in `CommittingSpec` test `must ignore commits to partitions that got revoked` ``` [info] CommittingSpec: [info] Committing [info] - must ensure uncommitted messages are redelivered (3 seconds, 358 milliseconds) [info]...

References #1063

https://travis-ci.org/akka/alpakka-kafka/jobs/654815028#L459 ``` [info] - must wait for response and retryInterval before perform new ask *** FAILED *** (278 milliseconds) [info] java.lang.AssertionError: assertion failed: received unexpected message RealMessage(ListTopics,Actor[akka://KafkaConnectionCheckerSpec/system/testActor-123/$a#349783032]) after 0 millis...

https://travis-ci.org/akka/alpakka-kafka/jobs/649448356#L933 I found an issue comment that mentioned this: https://github.com/akka/alpakka-kafka/pull/673#issuecomment-445162791 ``` [error] Test docs.javadsl.ConsumerExampleTest.restartSource failed: java.lang.AssertionError: assertion failed: expected no StreamSupervisor children, but got [Actor[akka://ConsumerExampleTest/system/Materializers/StreamSupervisor-71/flow-10-0-ignoreSink#-132405203]], took 50.058s [error] at scala.Predef$.assert(Predef.scala:282)...