Kafka0.10.2.1_1

The API need to change, the kafka clients are not backwards compatible and so it was best to just increase and fix up the code.

Show Active Consumers

http://localhost:9000/consumers

which gives

["consumer-1", "consumer-2", "consumer-3"]

Show specific consumer info

curl http://localhost:9000/consumers/<ConsumerGroupId>

State can be "Empty", "Dead", "Stable", "PreparingRebalance", "AwaitingSync"

{  
   "state":"Empty",
   "partition_assignment":[  
      {  
         "group":"console-consumer-20891",
         "coordinator":{  
            "id":0,
            "id_string":"0",
            "host":"foo.company.com",
            "port":9092
         },
         "topic":"products-in",
         "partition":1,
         "offset":3,
         "lag":0,
         "consumer_id":"-",
         "host":"-",
         "client_id":"-",
         "log_end_offset":3
      },
      {  
         "group":"console-consumer-20891",
         "coordinator":{  
            "id":0,
            "id_string":"0",
            "host":"foo.company.com",
            "port":9092
         },
         "topic":"products-in",
         "partition":0,
         "offset":3,
         "lag":0,
         "consumer_id":"consumer-1-7baba9b9-0ec3-4241-9433-f36255dd4708",
         "host":"/10.170.2.103",
         "client_id":"consumer-1",
         "log_end_offset":3
      }
   ]
}