[kafka] branch 2.7 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 2.7
in repository https://gitbox.apache.org/repos/asf/kafka.git


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

commit 83d5257be38b970bb490085c7878e43338ea9e44
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 8129d05..36c250a 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
@@ -1046,8 +1046,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
                 );
             }