Sean Glover
Sean Glover
The issue is that in-flight messages can't be invalidated once they leave Alpakka Kafka stages in the graph. Due to the asynchronous nature of akka streams, it's possible that there...
You code structure looks fine to me. Assuming your logging is configured correctly and your business logic isn't swallowing any exceptions, it should log a stream failure if one occurred....
> We have explicitly tested that scenario, where we built a custom MyException extends Exception which breaks the app as expected. No, the onComplete was never called! In my earlier...
To carry on what I mentioned in #1062, I'm going to run our integration tests locally for a little while to be safe. What I'm doing is doing repeated loops...
On second thought. I'll add a temp task to the travis build to do this instead.
> Can you run the same configuration on master? Yes, I'll use the #1065 to do both.
https://travis-ci.org/akka/alpakka-kafka/jobs/592616580#L832
https://travis-ci.org/akka/alpakka-kafka/jobs/595824299#L591
https://travis-ci.org/akka/alpakka-kafka/jobs/640314577#L650
It's back. https://travis-ci.org/github/akka/alpakka-kafka/jobs/696759317#L626 ``` --> [akka.kafka.internal.CommittingWithMockSpec: should collect commits to be sent to commitAsync] Start of log messages of test that [Failed(org.scalatest.exceptions.TestFailedException: the commits are aggregated to a low number...