From 00bce080acc407902ee342caf2a84eca6af48644 Mon Sep 17 00:00:00 2001 From: glikson Date: Tue, 22 Dec 2015 11:39:59 +0200 Subject: [PATCH] Use "new line" delimeters in a portable way This fixes failure of the unit test on Windows Signed-off-by: glikson --- .../apache/kafka/connect/file/FileStreamSinkTaskTest.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/connect/file/src/test/java/org/apache/kafka/connect/file/FileStreamSinkTaskTest.java b/connect/file/src/test/java/org/apache/kafka/connect/file/FileStreamSinkTaskTest.java index 754e7f5cba159..8a21c74bf5a50 100644 --- a/connect/file/src/test/java/org/apache/kafka/connect/file/FileStreamSinkTaskTest.java +++ b/connect/file/src/test/java/org/apache/kafka/connect/file/FileStreamSinkTaskTest.java @@ -47,6 +47,7 @@ public void setup() { @Test public void testPutFlush() { HashMap offsets = new HashMap<>(); + final String newLine = System.getProperty("line.separator"); // We do not call task.start() since it would override the output stream @@ -55,7 +56,7 @@ public void testPutFlush() { )); offsets.put(new TopicPartition("topic1", 0), new OffsetAndMetadata(1L)); task.flush(offsets); - assertEquals("line1\n", os.toString()); + assertEquals("line1" + newLine, os.toString()); task.put(Arrays.asList( new SinkRecord("topic1", 0, null, null, Schema.STRING_SCHEMA, "line2", 2), @@ -64,6 +65,6 @@ public void testPutFlush() { offsets.put(new TopicPartition("topic1", 0), new OffsetAndMetadata(2L)); offsets.put(new TopicPartition("topic2", 0), new OffsetAndMetadata(1L)); task.flush(offsets); - assertEquals("line1\nline2\nline3\n", os.toString()); + assertEquals("line1" + newLine + "line2" + newLine + "line3" + newLine, os.toString()); } }