You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by pt...@apache.org on 2014/04/21 21:44:43 UTC
[44/50] [abbrv] git commit: update to kafka 0.8.1
update to kafka 0.8.1
Project: http://git-wip-us.apache.org/repos/asf/incubator-storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-storm/commit/a72aafae
Tree: http://git-wip-us.apache.org/repos/asf/incubator-storm/tree/a72aafae
Diff: http://git-wip-us.apache.org/repos/asf/incubator-storm/diff/a72aafae
Branch: refs/heads/master
Commit: a72aafae503c8314b26330e0d4f440fb4632a483
Parents: 7d1bf2a
Author: P. Taylor Goetz <pt...@gmail.com>
Authored: Wed Apr 9 10:33:16 2014 -0400
Committer: P. Taylor Goetz <pt...@gmail.com>
Committed: Wed Apr 9 10:33:16 2014 -0400
----------------------------------------------------------------------
external/storm-kafka/pom.xml | 2 +-
.../storm-kafka/src/test/storm/kafka/KafkaTestBroker.java | 7 ++++++-
2 files changed, 7 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/a72aafae/external/storm-kafka/pom.xml
----------------------------------------------------------------------
diff --git a/external/storm-kafka/pom.xml b/external/storm-kafka/pom.xml
index 15743b6..9385678 100644
--- a/external/storm-kafka/pom.xml
+++ b/external/storm-kafka/pom.xml
@@ -106,7 +106,7 @@
<dependency>
<groupId>org.apache.kafka</groupId>
<artifactId>${kafkaArtifact}</artifactId>
- <version>0.8.0</version>
+ <version>0.8.1</version>
<exclusions>
<exclusion>
<groupId>org.apache.zookeeper</groupId>
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/a72aafae/external/storm-kafka/src/test/storm/kafka/KafkaTestBroker.java
----------------------------------------------------------------------
diff --git a/external/storm-kafka/src/test/storm/kafka/KafkaTestBroker.java b/external/storm-kafka/src/test/storm/kafka/KafkaTestBroker.java
index d2a44a4..db4663d 100644
--- a/external/storm-kafka/src/test/storm/kafka/KafkaTestBroker.java
+++ b/external/storm-kafka/src/test/storm/kafka/KafkaTestBroker.java
@@ -6,6 +6,7 @@ import com.netflix.curator.retry.ExponentialBackoffRetry;
import com.netflix.curator.test.TestingServer;
import kafka.server.KafkaServerStartable;
+import java.io.IOException;
import java.util.Properties;
/**
@@ -48,6 +49,10 @@ public class KafkaTestBroker {
public void shutdown() {
kafka.shutdown();
- server.stop();
+ try {
+ server.stop();
+ } catch (IOException e) {
+ e.printStackTrace();
+ }
}
}