This closes #742
Project: http://git-wip-us.apache.org/repos/asf/incubator-brooklyn/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-brooklyn/commit/d7ac3ac1 Tree: http://git-wip-us.apache.org/repos/asf/incubator-brooklyn/tree/d7ac3ac1 Diff: http://git-wip-us.apache.org/repos/asf/incubator-brooklyn/diff/d7ac3ac1 Branch: refs/heads/master Commit: d7ac3ac11d70b0ba1b6e3f5d7cbcd5d1615bbd33 Parents: 812e385 5bb5b7f Author: Aled Sage <[email protected]> Authored: Thu Jul 16 00:34:16 2015 +0100 Committer: Aled Sage <[email protected]> Committed: Thu Jul 16 00:34:16 2015 +0100 ---------------------------------------------------------------------- parent/pom.xml | 2 +- software/messaging/pom.xml | 4 +- .../kafka/AbstractfKafkaSshDriver.java | 16 +-- .../brooklyn/entity/messaging/kafka/Kafka.java | 4 +- .../entity/messaging/kafka/KafkaBroker.java | 2 +- .../entity/messaging/kafka/KafkaBrokerImpl.java | 7 -- .../messaging/kafka/KafkaBrokerSshDriver.java | 7 +- .../entity/messaging/kafka/KafkaTopic.java | 46 -------- .../entity/messaging/kafka/KafkaZooKeeper.java | 4 + .../messaging/kafka/KafkaZooKeeperDriver.java | 1 + .../messaging/kafka/KafkaZooKeeperImpl.java | 5 + .../kafka/KafkaZooKeeperSshDriver.java | 15 +++ .../entity/messaging/kafka/server.properties | 89 +++++++-------- .../messaging/kafka/KafkaIntegrationTest.java | 6 +- .../entity/messaging/kafka/KafkaSupport.java | 111 +++++++++++-------- 15 files changed, 152 insertions(+), 167 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-brooklyn/blob/d7ac3ac1/parent/pom.xml ----------------------------------------------------------------------
