You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@brooklyn.apache.org by al...@apache.org on 2015/07/16 01:34:54 UTC
[2/3] incubator-brooklyn git commit: Fix Kafka installation
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 <va...@cloudsoftcorp.com>
Authored: Tue Jul 14 21:45:28 2015 +0100
Committer: Valentin Aitken <va...@cloudsoftcorp.com>
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)));