watcher tools

[adyliu]

Creating a tool to watching the consumer status is amusive.

It can watch the consumer status of all topic with groups.

[adyliu]

added in v1.2.0 Link

Example:

Jafka watcher v0.2
  groupid      topic part consumeoffset totaloffset backlog                                  consumerid
-------------------------------------------------------------------------------------------------------
photopark tblogimage  1-0     121230494   121230599     105 photopark_tc_5_159-1339040416363-e428facb-0
photopark tblogimage  1-1      87924338    87924338       0 photopark_tc_5_159-1339040416363-e428facb-1
photopark tblogimage  1-2      87908005    87908005       0 photopark_tc_5_212-1340246219710-efc784f1-0
photopark tblogimage  1-3      87899692    87899905     213 photopark_tc_5_212-1340246219710-efc784f1-1
photopark tblogimage  1-4      87924020    87924020       0 photopark_tc_5_213-1339040315446-e47f9f72-0
photopark tblogimage  2-0      88167393    88167498     105 photopark_tc_5_213-1339040315446-e47f9f72-1
photopark tblogimage  2-1      87786106    87786314     208 photopark_tc_5_214-1339040366844-f6b37c0f-0
photopark tblogimage  2-2      88057150    88057360     210 photopark_tc_5_214-1339040366844-f6b37c0f-1
photopark tblogimage  2-3      87854004    87854004       0 photopark_tc_5_215-1339040385096-47c89faf-0
photopark tblogimage  2-4      88039214    88039329     115 photopark_tc_5_215-1339040385096-47c89faf-1

groupid   topic part consumeoffset totaloffset backlog                               consumerid
-----------------------------------------------------------------------------------------------
  extra account  1-0      95668235    95668311      76 extra_tc_157_82-1339670439107-6be03593-0
  extra account  1-1      95634374    95634549     175 extra_tc_157_82-1339670439107-6be03593-1
  extra account  2-0      95712383    95712383       0 extra_tc_157_83-1339670474718-8ebfc51c-0
  extra account  2-1      95820883    95820883       0 extra_tc_157_83-1339670474718-8ebfc51c-1

groupid    topic part consumeoffset totaloffset backlog                                consumerid
-------------------------------------------------------------------------------------------------
 adyliu tblogMsg  1-0   12577131586 12577154830   23244 adyliu_tc_156_44-1340242868216-f436c999-0
 adyliu tblogMsg  1-1   11957111056 11957132422   21366 adyliu_tc_156_44-1340242868216-f436c999-0
 adyliu tblogMsg  1-2   11801019099 11801094963   75864 adyliu_tc_156_45-1340243307267-95831114-0
 adyliu tblogMsg  1-3   11715465305 11715528980   63675 adyliu_tc_156_45-1340243307267-95831114-0
 adyliu tblogMsg  2-0   12813639965 12813662698   22733 adyliu_tc_156_47-1340243400768-6bc2c5bc-0
 adyliu tblogMsg  2-1   11548369884 11548416571   46687 adyliu_tc_156_47-1340243400768-6bc2c5bc-0
 adyliu tblogMsg  2-2   12060774953 12060791047   16094 adyliu_tc_157_79-1340243447536-eb6aae7a-0
 adyliu tblogMsg  2-3   11771358718 11771391869   33151 adyliu_tc_157_79-1340243447536-eb6aae7a-0