From 9606b5c8ec0699887f59586fb8569dcba267920e Mon Sep 17 00:00:00 2001 From: Homer Strong Date: Fri, 9 Mar 2012 18:15:15 -0800 Subject: [PATCH] Update README.md --- README.md | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/README.md b/README.md index d732804..0b6653c 100644 --- a/README.md +++ b/README.md @@ -43,7 +43,7 @@ Or sending a single message: ```clj (use 'clj-kafka.consumer.simple) -(def c (create-consumer "localhost" 9092)) +(def c (consumer "localhost" 9092)) (def f (fetch "test" 0 0 4096)) (messages c f) @@ -59,7 +59,8 @@ The Zookeeper consumer uses broker information contained within Zookeeper to con (use 'clj-kafka.consumer.zk) (use 'clj-kafka.core) -(def config {"zk.connect" "localhost:2181"}) +(def config {"zk.connect" "localhost:2181" + "groupid" "my-task-group"}) (with-resource [c (consumer config)] shutdown