Hello Ismael,
On Wed, May 18, 2016 at 5:54 PM, Ismael Juma <[email protected]> wrote:
> Your second example should work as well. Can you please include the code
> you are using to test the scenario and what Kafka version you are using
> (0.9.0.0 or 0.9.0.1, I guess)?
This is the code I'm using:
```
(with-open [p (producer {"bootstrap.servers" "192.168.33.20:9091"
"max.block.ms" "500"
"request.timeout.ms" "1000"
"metadata.fetch.timeout.ms" "10000"}
(byte-array-serializer)
(byte-array-serializer))]
(.get (send p (record "test" (.getBytes "Kafka Up."))))
(Thread/sleep 10000) ; While it sleeps, I shut down Kafka.
(.get (send p (record "test" (.getBytes "Kafka Down")))))
```
Kafka version: 0.9.0.0
clj-kafka version: 0.3.4
Samuel
