diff --git a/README.md b/README.md index 88a2641..3c3f5bd 100644 --- a/README.md +++ b/README.md @@ -242,7 +242,7 @@ effort to support. # Resources * Kafka Improvement Proposals (KIP) for Transaction Support - * [KIP-98 - Exactly Once Delivery and Transactional Messaging](https://cwiki.apache.org/confluence/display/KAFKA/KIP-98+-+Exactly+Once+Delivery+and+Transactional+Messaging) + * [KIP-98: Exactly Once Delivery and Transactional Messaging](https://cwiki.apache.org/confluence/display/KAFKA/KIP-98+-+Exactly+Once+Delivery+and+Transactional+Messaging) * [KIP-129: Streams Exactly-Once Semantics](https://cwiki.apache.org/confluence/display/KAFKA/KIP-129%3A+Streams+Exactly-Once+Semantics) * [You Cannot Have Exactly-Once Delivery](http://bravenewgeek.com/you-cannot-have-exactly-once-delivery/) * [You Cannot Have Exactly-Once Delivery Redux](http://bravenewgeek.com/you-cannot-have-exactly-once-delivery-redux/) diff --git a/src/main/scala/seglo/apps/AssertSinkTopic.scala b/src/main/scala/seglo/apps/AssertSinkTopic.scala index d03ab54..5ed29c7 100644 --- a/src/main/scala/seglo/apps/AssertSinkTopic.scala +++ b/src/main/scala/seglo/apps/AssertSinkTopic.scala @@ -79,16 +79,14 @@ object AssertSinkTopic extends App { } :+ (partition, "END", "END_TRANSFORM") - Try { - /** - * Asserts that the generated expected records occur in order in the actual records. Because Kafka only - * guarantees message order within a partition we can only assert order per partition. ScalaTest has a nice - * collections matcher to help here. - * - * http://doc.scalatest.org/3.0.0/index.html#org.scalatest.Matchers@inOrderElementsOf[R](elements:scala.collection.GenTraversable[R]):org.scalatest.words.ResultOfInOrderElementsOfApplication - */ - records should contain inOrderElementsOf expectedPartitionRecords - } + /** + * Asserts that the generated expected records occur in order in the actual records. Because Kafka only + * guarantees message order within a partition we can only assert order per partition. ScalaTest has a nice + * collections matcher to help here. + * + * http://doc.scalatest.org/3.0.0/index.html#org.scalatest.Matchers@inOrderElementsOf[R](elements:scala.collection.GenTraversable[R]):org.scalatest.words.ResultOfInOrderElementsOfApplication + */ + records should contain inOrderElementsOf expectedPartitionRecords } }.isSuccess }