Merge pull request #124 from redBorder/bugfix/17120_cluster_is_not_ac…

…ting_as_cluster

Druid realtime is not acting as a cluster because shardSpec partition is not correctly set

resources/attributes/default.rb

@@ -211,5 +211,7 @@
 default["redborder"]["druid"]["historical"]["tier"]     = "default"
 default["redborder"]["druid"]["historical"]["maxsize"]  = -1
 
+# Realtime
+default["redborder"]["druid"]["realtime"]["partition_num"] = 0
 
 default["redborder"]["pending_changes"]=0

resources/recipes/configure.rb

@@ -136,6 +136,8 @@
 druid_realtime "Configure Druid Realtime" do
   name node["hostname"]
   ipaddress node["ipaddress_sync"]
+  zookeeper_hosts node["redborder"]["zookeeper"]["zk_hosts"]
+  partition_num node["redborder"]["druid"]["realtime"]["partition_num"]
   memory_kb node["redborder"]["memory_services"]["druid-realtime"]["memory"]
   action (manager_services["druid-realtime"] ? [:add, :register] : [:remove, :deregister])
 end

resources/recipes/prepare_system.rb

@@ -108,6 +108,11 @@
   node.default["redborder"]["kafka"]["host_index"] = node["redborder"]["managers_per_services"]["kafka"].index(node.name)
 end
 
+#set druid realtime partition id (its needed in cluster mode for druid brokers)
+if node["redborder"]["managers_per_services"]["druid-realtime"].include?(node.name)
+  node.default["redborder"]["druid"]["realtime"]["partition_num"] = node["redborder"]["managers_per_services"]["druid-realtime"].index(node.name)
+end
+
 #get an array of managers
 managers_list = []
 node["redborder"]["cluster_info"].each_key do |mgr|