Skip to content

Instantly share code, notes, and snippets.

Avatar

Todd Palino toddpalino

View GitHub Profile
View gist:e7f8189eb06d06b09480
// Set up the Zookeeper lock for notification
appContext.NotifierLock = zk.NewLock(zkconn, appContext.Config.Zookeeper.LockPath, zk.WorldACL(zk.PermAll))
View gist:552634d679b59a6e2793
{
"error": false,
"message": "consumer group status returned",
"status": {
"cluster": "local",
"group": "kafkamirror_aggregate",
"status": "WARN",
"complete": true,
"partitions": [
{
View gist:af4dd273a01791eab606
{
"error":false,
"message":"consumer group status returned",
"status":{
"cluster":"local",
"group":"kafkamirror_aggregate",
"status":"OK",
"complete":true,
"partitions":[]
}
You can’t perform that action at this time.