toddpalino
/ gist:e7f8189eb06d06b09480
Created Jun 13, 2015
View gist:e7f8189eb06d06b09480
| // Set up the Zookeeper lock for notification | |
| appContext.NotifierLock = zk.NewLock(zkconn, appContext.Config.Zookeeper.LockPath, zk.WorldACL(zk.PermAll)) |
toddpalino
/ gist:552634d679b59a6e2793
Last active Aug 29, 2015
View gist:552634d679b59a6e2793
| { | |
| "error": false, | |
| "message": "consumer group status returned", | |
| "status": { | |
| "cluster": "local", | |
| "group": "kafkamirror_aggregate", | |
| "status": "WARN", | |
| "complete": true, | |
| "partitions": [ | |
| { |
toddpalino
/ gist:af4dd273a01791eab606
Created Jun 1, 2015
View gist:af4dd273a01791eab606
| { | |
| "error":false, | |
| "message":"consumer group status returned", | |
| "status":{ | |
| "cluster":"local", | |
| "group":"kafkamirror_aggregate", | |
| "status":"OK", | |
| "complete":true, | |
| "partitions":[] | |
| } |