You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by rm...@apache.org on 2016/03/16 17:32:41 UTC
[4/4] flink git commit: [hotfix][examples] Add zookeeper.connect to
usage line
[hotfix][examples] Add zookeeper.connect to usage line
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/edafb3e6
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/edafb3e6
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/edafb3e6
Branch: refs/heads/master
Commit: edafb3e6cd48bfec6660b22454d19540dc07ad65
Parents: d8dcfac
Author: Stefano Baghino <st...@radicalbit.io>
Authored: Wed Mar 16 15:50:08 2016 +0100
Committer: Robert Metzger <rm...@apache.org>
Committed: Wed Mar 16 17:31:39 2016 +0100
----------------------------------------------------------------------
.../apache/flink/streaming/examples/kafka/WriteIntoKafka.java | 7 ++++---
1 file changed, 4 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/edafb3e6/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/kafka/WriteIntoKafka.java
----------------------------------------------------------------------
diff --git a/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/kafka/WriteIntoKafka.java b/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/kafka/WriteIntoKafka.java
index 697b8e0..a44cbd2 100644
--- a/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/kafka/WriteIntoKafka.java
+++ b/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/kafka/WriteIntoKafka.java
@@ -30,15 +30,16 @@ import org.apache.flink.streaming.util.serialization.SimpleStringSchema;
* Generate a String every 500 ms and write it into a Kafka topic
*
* Please pass the following arguments to run the example:
- * --topic test --bootstrap.servers localhost:9092
+ * --topic test --bootstrap.servers localhost:9092 --zookeeper.connect localhost:2181
*
*/
public class WriteIntoKafka {
public static void main(String[] args) throws Exception {
ParameterTool parameterTool = ParameterTool.fromArgs(args);
- if(parameterTool.getNumberOfParameters() < 2) {
- System.out.println("Missing parameters!\nUsage: Kafka --topic <topic> --bootstrap.servers <kafka brokers>");
+ if(parameterTool.getNumberOfParameters() < 3) {
+ System.out.println("Missing parameters!");
+ System.out.println("Usage: Kafka --topic <topic> --bootstrap.servers <kafka brokers> --zookeeper.connect <zk quorum>");
System.exit(1);
}