From 5efe63f189a4d9096ff14891549d899a475ab22a Mon Sep 17 00:00:00 2001 From: Jendrik Poloczek Date: Mon, 2 Oct 2017 13:15:01 +0200 Subject: [PATCH] Updated: README.md and CHANGELOG.md --- CHANGELOG.md | 7 +++++++ README.md | 8 ++++---- 2 files changed, 11 insertions(+), 4 deletions(-) diff --git a/CHANGELOG.md b/CHANGELOG.md index d9e9739..4b86215 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -1,5 +1,12 @@ # Changelog +## Mocked Streams 1.4.0 + +* Build against Apache Kafka 0.11.0.1 +* Added record order and multiple emissions by Svend Vanderveken +* Updated SBT to 1.0.2 +* Added Svend Vanderveken to CONTRIBUTORS.md + ## Mocked Streams 1.2.2 * Build against Apache Kafka 0.11.0.0 diff --git a/README.md b/README.md index 14a980d..c36203d 100644 --- a/README.md +++ b/README.md @@ -50,13 +50,13 @@ It also allows you to have multiple input and output streams. If your topology u mstreams.output("out-a", strings, ints, expA.size) shouldEqual(expectedA) mstreams.output("out-b", strings, ints, expB.size) shouldEqual(expectedB) -## Event order and multiple emissions +## Record order and multiple emissions -The events provided to the mock stream will be submitted to the topology during the test in the order in which they appear in the fixture. You can also submit events multiple times to the same topics, at various moments in your scenario. +The records provided to the mocked stream will be submitted to the topology during the test in the order in which they appear in the fixture. You can also submit records multiple times to the same topics, at various moments in your scenario. -This can be handy to validate that your topology behaviour is or is not dependent on the order in which the events are received and processed. +This can be handy to validate that your topology behaviour is or is not dependent on the order in which the records are received and processed. -In the example below, 2 events are first submitted to topic A, then 3 to topic B, then 1 more to topic A again. +In the example below, 2 records are first submitted to topic A, then 3 to topic B, then 1 more to topic A again. val firstInputForTopicA = Seq(("x", int(1)), ("y", int(2))) val firstInputForTopicB = Seq(("x", int(4)), ("y", int(3)), ("y", int(5)))