Skip to content

Commit

Permalink
Moving to the lastest version of Kafka 08
Browse files Browse the repository at this point in the history
  • Loading branch information
Gaurav Gupta committed Jun 27, 2013
1 parent 93344cf commit 9d3c7be
Show file tree
Hide file tree
Showing 2 changed files with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -268,7 +268,7 @@ private void produceCount(URI brokerURI, ArrayList<byte[]> monitorSet) {
// Shuffle the broker

Properties props = new Properties();
props.put("broker.list",
props.put("metadata.broker.list",
brokerURI.getHost() + ":" + brokerURI.getPort());
props.put("producer.type", "async");
props.put("request.required.acks", "1");
Expand Down
Binary file modified lib/kafka-0.8-SNAPSHOT.jar
Binary file not shown.

0 comments on commit 9d3c7be

Please sign in to comment.