edit kafka perperties.

MakoXiao · Oct 14, 2015 · 0f007ad · 0f007ad
1 parent 9173388
commit 0f007ad
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/README.md b/README.md
@@ -83,12 +83,12 @@ SOURCE RANDOMGEN
 CREATE OUTPUT STREAM s2 
     (c1 STRING)
 SINK kafakOutput
-    PROPERTIES ( topic = "cqlOut");
+    PROPERTIES ( topic = "cqlOut", zookeepers = "127.0.0.1:2181", brokers = "127.0.0.1:9092" );
 
 CREATE INPUT STREAM s3
     ( c1 STRING)
 SOURCE KafkaInput
-    PROPERTIES (groupid = "cqlClient", topic = "cqlInput")
+    PROPERTIES (groupid = "cqlClient", topic = "cqlInput", zookeepers = "127.0.0.1:2181", brokers = "127.0.0.1:9092" )
 
 CREATE OUTPUT STREAM s4
     (c1 STRING)