-
Install zookeeper using puppet without module
Hi, In this post, I was given the task to provide a standalone zookeeper cluster with basic auth on the latest version. The reason that happened is that we are using a very old module on our Kafka clusters and a new requirement appeared to install the latest version of 3.5.5. The old module had…
-
Small go code example for zookeeper resource editing
Hi, We have the task of “service restart coordination” for our Apache Kafka cluster. It’s still a work in progress but if you want to use the zookeeper for some status verification and update, something like this will work as an example. package main import ( “fmt” “io” “launchpad.net/gozk” “os” “strings” “sync” “time” ) const…
-
Kafka cluster nodes and controller using golang
Hi, Using the golang library for zookeeper from here you can get very easily the nodes that are registered in the cluster controller node. In order to install this module, beside needing to setup the GOPATH you will have also to install packages from linux distro repo called: bzr, gcc, libzookeeper-mt-dev Once all of this…
-
Use case for deleting corrupted Kafka topic
Hi, We had a week ago a case in which the client could not delete a topic from the cluster (Kafka version in this case was 1.0.0). When the topic was listed, there were no leaders assigned for the partitions. It was pretty clear that it would not delete it until we fixed it. First…
-
Observer functionality for puppet zookeeper module
Morning, I know it’s been some time since i last posted but i didn’t had the time to play that much. Today i want to share with you the use case in which we needed to modify the module used for the deployment of zookeeper in order to include also observer role. The link that…