Hazelcast Ranger Discovery

This is a discovery strategy extension for Hazelcast to make discovery work on ranger. This library compiles only on Java 8.

Dependencies

• ranger 1.0-RC10
• Hazelcast 5.3.2

Usage

Hazelcast Ranger Discovery provides a easy way to enable member discovery with elastic applications on docker & DCOS like environment where using a static host list or using multicast based discovery is not possible.

Build instructions

• Clone the source:

  git clone github.com/phaneesh/hazelcast-ranger-discovery
  

• Build

  mvn install
  

Maven Dependency

Use the following repository:

<repository>
    <id>clojars</id>
    <name>Clojars repository</name>
    <url>https://clojars.org/repo</url>
</repository>

Use the following maven dependency:

<dependency>
    <groupId>com.ranger.hazelcast.servicediscovery</groupId>
    <artifactId>hazelcast-ranger-discovery</artifactId>
    <version>5.2.3-1</version>
</dependency>

Using Hazelcast Ranger Discovery

Config config = new Config();
//This is important to enable the discovery strategy
config.setProperty("hazelcast.discovery.enabled", "true");
config.setProperty("hazelcast.discovery.public.ip.enabled", "true");
config.setProperty("hazelcast.socket.client.bind.any", "true");
config.setProperty("hazelcast.socket.bind.any", "true");
NetworkConfig networkConfig = config.getNetworkConfig();
JoinConfig joinConfig = networkConfig.getJoin();
joinConfig.getTcpIpConfig().setEnabled(false);
joinConfig.getMulticastConfig().setEnabled(false);
joinConfig.getAwsConfig().setEnabled(false);
DiscoveryConfig discoveryConfig = joinConfig.getDiscoveryConfig();
//Set the discovery strategy to RangerDiscoveryStrategy
DiscoveryStrategyConfig discoveryStrategyConfig = new DiscoveryStrategyConfig(new RangerDiscoveryStrategyFactory());
//Zookeeper connection string used by ranger
discoveryStrategyConfig.addProperty("zk-connection-string", testingCluster.getConnectString());
//Namespace that needs to be used by ranger for this service
discoveryStrategyConfig.addProperty("namespace", "hz_disco");
//Service name that needs to be used
discoveryStrategyConfig.addProperty("service-name", "hz_disco_test");
//Set the refresh interval. Default value is 5000
discoveryStrategyConfig.addProperty("health-update-interval-ms", 3000);
//Set the stale update threshold. Default value is 16000 (allows for 3 missed updates)
discoveryStrategyConfig.addProperty("health-update-interval-ms", 31000);
discoveryConfig.addDiscoveryStrategyConfig(discoveryStrategyConfig);
//Create the hazelcast instance
HazelcastInstance hazelcast = Hazelcast.newHazelcastInstance(config);

Note

If you are using hazelcast in applications deployed on DCOS; then you should set the following configuration for discovery to work

NetworkConfig networkConfig = config.getNetworkConfig();
networkConfig.setPublicAddress("<public ip address/host name>" +":" +"<public port>");

Example: (On DCOS + Marathon assuming hazelcast container port is set to 5701)

NetworkConfig networkConfig = config.getNetworkConfig();
networkConfig.setPublicAddress(System.getenv("HOST") +":" +System.getenv("PORT_5701"))

LICENSE

Copyright 2016 Phaneesh Nagaraja phaneesh.n@gmail.com.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.