Kafka0.10.0.1

basic application showing consumer offsets stored in kafka. Tested with kafka 0.10.0.1

Show Active Consumers

http://localhost:9000/consumers

which gives

[
    {
      "protocolType": "consumer",
      "groupId": "consumer-1"
    }
    {
      "protocolType": "consumer",
      "groupId": "consumer-2"
    }
    {
      "protocolType": "consumer",
      "groupId": "consumer-3"
    }
]

Show specific consumer info

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

[
    {
      "owner": "consumer-2_/132.34.134.12",
      "lag": 155758,
      "log_end_offset": 2580124,
      "offset": 2424366,
      "partition": 1,
      "topic": "foobar",
      "group": "consumer-1"
    }
    {
      "owner": "consumer-2_/132.34.134.12",
      "lag": 155758,
      "log_end_offset": 2580124,
      "offset": 2424366,
      "partition": 2,
      "topic": "foobar",
      "group": "consumer-1"
    }
    {
      "owner": "consumer-2_/132.34.134.12",
      "lag": 155758,
      "log_end_offset": 2580124,
      "offset": 2424366,
      "partition": 3,
      "topic": "foobar",
      "group": "consumer-1"
    }
]