Fix producer example and lein version string
This commit is contained in:
parent
8f2370e6b5
commit
ac8ce7090c
1 changed files with 2 additions and 2 deletions
|
@ -11,7 +11,7 @@ Development is against the 0.8 release of Kafka. The protocols for 0.7 and 0.8 a
|
||||||
Add the following to your [Leiningen](http://github.com/technomancy/leiningen) `project.clj`:
|
Add the following to your [Leiningen](http://github.com/technomancy/leiningen) `project.clj`:
|
||||||
|
|
||||||
```clj
|
```clj
|
||||||
[clj-kafka "0.2.1-0.8"]
|
[clj-kafka "0.1.2-0.8"]
|
||||||
```
|
```
|
||||||
|
|
||||||
## Usage
|
## Usage
|
||||||
|
@ -32,7 +32,7 @@ Discovery of Kafka brokers from Zookeeper:
|
||||||
"serializer.class" "kafka.serializer.DefaultEncoder"
|
"serializer.class" "kafka.serializer.DefaultEncoder"
|
||||||
"partitioner.class" "kafka.producer.DefaultPartitioner"}))
|
"partitioner.class" "kafka.producer.DefaultPartitioner"}))
|
||||||
|
|
||||||
(send-message p (keyed-message "test" (.getBytes "this is my message")))
|
(send-message p (message "test" (.getBytes "this is my message")))
|
||||||
```
|
```
|
||||||
|
|
||||||
### Zookeeper Consumer
|
### Zookeeper Consumer
|
||||||
|
|
Loading…
Reference in a new issue