Fix Kafka installation - updated kafka version - installing from binary instead of compiling from source
Project: http://git-wip-us.apache.org/repos/asf/incubator-brooklyn/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-brooklyn/commit/5bb5b7f0 Tree: http://git-wip-us.apache.org/repos/asf/incubator-brooklyn/tree/5bb5b7f0 Diff: http://git-wip-us.apache.org/repos/asf/incubator-brooklyn/diff/5bb5b7f0 Branch: refs/heads/master Commit: 5bb5b7f0e0a081546d24bed44f260344a6f67151 Parents: 3330714 Author: Valentin Aitken <[email protected]> Authored: Tue Jul 14 21:45:28 2015 +0100 Committer: Valentin Aitken <[email protected]> Committed: Tue Jul 14 21:45:28 2015 +0100 ---------------------------------------------------------------------- .../java/brooklyn/entity/messaging/kafka/KafkaSupport.java | 7 ------- 1 file changed, 7 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-brooklyn/blob/5bb5b7f0/software/messaging/src/test/java/brooklyn/entity/messaging/kafka/KafkaSupport.java ---------------------------------------------------------------------- diff --git a/software/messaging/src/test/java/brooklyn/entity/messaging/kafka/KafkaSupport.java b/software/messaging/src/test/java/brooklyn/entity/messaging/kafka/KafkaSupport.java index e4315a6..c80befa 100644 --- a/software/messaging/src/test/java/brooklyn/entity/messaging/kafka/KafkaSupport.java +++ b/software/messaging/src/test/java/brooklyn/entity/messaging/kafka/KafkaSupport.java @@ -52,13 +52,6 @@ public class KafkaSupport { * Send a message to the {@link KafkaCluster} on the given topic. */ public void sendMessage(String topic, String message) { - ZooKeeperNode zookeeper = cluster.getZooKeeper(); - for(Entity e : cluster.getCluster().getChildren()) { - if(e instanceof KafkaBroker) { - - break; - } - } Optional<Entity> anyBrokerNodeInCluster = Iterables.tryFind(cluster.getCluster().getChildren(), Predicates.and( Predicates.instanceOf(KafkaBroker.class), EntityPredicates.attributeEqualTo(KafkaBroker.SERVICE_UP, true)));
