[kafka] branch trunk updated: MINOR: fix error message (#9730)

[mjsax]

This is an automated email from the ASF dual-hosted git repository.

mjsax pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new b689507  MINOR: fix error message (#9730)
b689507 is described below

commit b689507c417a0f846b8a86318312eb50e4ac2adb
Author: Matthias J. Sax <matth...@confluent.io>
AuthorDate: Thu Dec 17 17:09:45 2020 -0800

    MINOR: fix error message (#9730)
    
    Reviewers: A. Sophie Blee-Goldman <sop...@confluent.io>, Chia-Ping Tsai 
<chia7...@gmail.com>
---
 .../kafka/streams/integration/EosBetaUpgradeIntegrationTest.java      | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/streams/src/test/java/org/apache/kafka/streams/integration/EosBetaUpgradeIntegrationTest.java
 
b/streams/src/test/java/org/apache/kafka/streams/integration/EosBetaUpgradeIntegrationTest.java
index 22c5cf0..30f44dc 100644
--- 
a/streams/src/test/java/org/apache/kafka/streams/integration/EosBetaUpgradeIntegrationTest.java
+++ 
b/streams/src/test/java/org/apache/kafka/streams/integration/EosBetaUpgradeIntegrationTest.java
@@ -1045,8 +1045,8 @@ public class EosBetaUpgradeIntegrationTest {
                 assertThat(getAllRecordPerKey(key, result), 
equalTo(getAllRecordPerKey(key, expectedResult)));
             } catch (final AssertionError error) {
                 throw new AssertionError(
-                    "expected result: " + 
expectedResult.stream().map(KeyValue::toString).reduce("", (kv, str) -> 
str.isEmpty() ? kv : str + ", " + kv) +
-                    "\nreceived records: " + 
result.stream().map(KeyValue::toString).reduce("", (kv, str) -> str.isEmpty() ? 
kv : str + ", " + kv),
+                    "expected result: " + 
expectedResult.stream().map(KeyValue::toString).collect(Collectors.joining(", 
")) +
+                    "\nreceived records: " + 
result.stream().map(KeyValue::toString).collect(Collectors.joining(", ")),
                     error
                 );
             }