Sean Glover comments

Results 258 comments of


                                            Sean Glover

[Failure] TransactionsSpec: must complete with messages filtered out and transient failure causing an abort with restartable source

https://travis-ci.org/akka/alpakka-kafka/jobs/615297999#L468

[Failure] TransactionsSpec: must complete with messages filtered out and transient failure causing an abort with restartable source

Still happening with increased timefactor https://travis-ci.org/akka/alpakka-kafka/jobs/625749137#L476

[Failure] TransactionsSpec: must complete with messages filtered out and transient failure causing an abort with restartable source

https://travis-ci.org/akka/alpakka-kafka/jobs/640314579#L465

[Failure] TransactionsSpec: must complete with messages filtered out and transient failure causing an abort with restartable source

Hopefully resolved with #1048

[Failure] TransactionsSpec: must complete with messages filtered out and transient failure causing an abort with restartable source

Observed a timeout with this test again, at a new point. ``` [info] java.lang.AssertionError: assertion failed: timeout (100 seconds) during expectMsg while waiting for OnNext(1) [info] at scala.Predef$.assert(Predef.scala:170) [info] at...

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

https://travis-ci.org/github/akka/alpakka-kafka/jobs/720689643#L464

Producer.committableSink doesn't respect commit settings or apply backpressure

@gabrielreid `Producer.committableSink` was recently modified under the hood to use the new `CommittingProducerSinkStage` which optimizes the produce and committing logic. If you want back-pressure on offset commits you can still...

Source doesn't resume partitions after a failed seek() operation

Thanks for raising the issue. What exception is raised when the seek fails? I think it would be acceptable to log a warning for such failures and carry on. Do...

Kafka Consumer dies after a reconnect following a network hiccup

FYI I have no plans to upgrade Akka to releases under Lightbend's new license, but I understand the concern. Replacing Akka would be a huge effort so I have hopes...

False positive ProducerMessage.Results

I agree with @ennru that this issue is of a larger scope than just Alpakka Kafka (it's a Kafka producing corner case), but a PR to add it to the...