Todd Palino toddpalino
toddpalino
/ gist:af4dd273a01791eab606
Created
June 1, 2015 19:20
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| { | |
| "error":false, | |
| "message":"consumer group status returned", | |
| "status":{ | |
| "cluster":"local", | |
| "group":"kafkamirror_aggregate", | |
| "status":"OK", | |
| "complete":true, | |
| "partitions":[] | |
| } |
toddpalino
/ gist:552634d679b59a6e2793
Last active
August 29, 2015 14:22
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| { | |
| "error": false, | |
| "message": "consumer group status returned", | |
| "status": { | |
| "cluster": "local", | |
| "group": "kafkamirror_aggregate", | |
| "status": "WARN", | |
| "complete": true, | |
| "partitions": [ | |
| { |
toddpalino
/ gist:e7f8189eb06d06b09480
Created
June 13, 2015 16:43
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| // Set up the Zookeeper lock for notification | |
| appContext.NotifierLock = zk.NewLock(zkconn, appContext.Config.Zookeeper.LockPath, zk.WorldACL(zk.PermAll)) |