kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gwens...@apache.org
Subject kafka git commit: MINOR: Fix FileStreamSourceTask to create the reader around System.in when using stdin as the input source.
Date Mon, 28 Sep 2015 12:46:19 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk b62f8ea43 -> e90562fb1


MINOR: Fix FileStreamSourceTask to create the reader around System.in when using stdin as
the input source.

Author: Ewen Cheslack-Postava <me@ewencp.org>

Reviewers: Gwen Shapira

Closes #251 from ewencp/minor-fix-filestream-stdin-source


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/e90562fb
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/e90562fb
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/e90562fb

Branch: refs/heads/trunk
Commit: e90562fb19996db901771ad9757d12b0a2f50f9e
Parents: b62f8ea
Author: Ewen Cheslack-Postava <me@ewencp.org>
Authored: Mon Sep 28 05:46:09 2015 -0700
Committer: Gwen Shapira <cshapi@gmail.com>
Committed: Mon Sep 28 05:46:09 2015 -0700

----------------------------------------------------------------------
 .../java/org/apache/kafka/copycat/file/FileStreamSourceTask.java    | 1 +
 1 file changed, 1 insertion(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/e90562fb/copycat/file/src/main/java/org/apache/kafka/copycat/file/FileStreamSourceTask.java
----------------------------------------------------------------------
diff --git a/copycat/file/src/main/java/org/apache/kafka/copycat/file/FileStreamSourceTask.java
b/copycat/file/src/main/java/org/apache/kafka/copycat/file/FileStreamSourceTask.java
index 91292e9..cf71be3 100644
--- a/copycat/file/src/main/java/org/apache/kafka/copycat/file/FileStreamSourceTask.java
+++ b/copycat/file/src/main/java/org/apache/kafka/copycat/file/FileStreamSourceTask.java
@@ -52,6 +52,7 @@ public class FileStreamSourceTask extends SourceTask {
             stream = System.in;
             // Tracking offset for stdin doesn't make sense
             streamOffset = null;
+            reader = new BufferedReader(new InputStreamReader(stream));
         }
         topic = props.getProperty(FileStreamSourceConnector.TOPIC_CONFIG);
         if (topic == null)


Mime
View raw message