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":[] | |
} |