toddpalino

	// Set up the Zookeeper lock for notification
	appContext.NotifierLock = zk.NewLock(zkconn, appContext.Config.Zookeeper.LockPath, zk.WorldACL(zk.PermAll))

toddpalino

{
  "error": false,
  "message": "consumer group status returned",
  "status": {
    "cluster": "local",
    "group": "kafkamirror_aggregate",
    "status": "WARN",
    "complete": true,
    "partitions": [
      {

toddpalino

{
  "error":false,
  "message":"consumer group status returned",
  "status":{
    "cluster":"local",
    "group":"kafkamirror_aggregate",
    "status":"OK",
    "complete":true,
    "partitions":[]
  }