{"action":"reopened","issue":{"url":"https://api.github.com/repos/jhalliday/csc8101/issues/4","labels_url":"https://api.github.com/repos/jhalliday/csc8101/issues/4/labels{/name}","comments_url":"https://api.github.com/repos/jhalliday/csc8101/issues/4/comments","events_url":"https://api.github.com/repos/jhalliday/csc8101/issues/4/events","html_url":"https://github.com/jhalliday/csc8101/issues/4","id":56817362,"number":4,"title":"Consumer problems","user":{"login":"DonatasD","id":6634240,"avatar_url":"https://avatars.githubusercontent.com/u/6634240?v=3","gravatar_id":"","url":"https://api.github.com/users/DonatasD","html_url":"https://github.com/DonatasD","followers_url":"https://api.github.com/users/DonatasD/followers","following_url":"https://api.github.com/users/DonatasD/following{/other_user}","gists_url":"https://api.github.com/users/DonatasD/gists{/gist_id}","starred_url":"https://api.github.com/users/DonatasD/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/DonatasD/subscriptions","organizations_url":"https://api.github.com/users/DonatasD/orgs","repos_url":"https://api.github.com/users/DonatasD/repos","events_url":"https://api.github.com/users/DonatasD/events{/privacy}","received_events_url":"https://api.github.com/users/DonatasD/received_events","type":"User","site_admin":false},"labels":[],"state":"open","locked":false,"assignee":null,"milestone":null,"comments":1,"created_at":"2015-02-06T14:25:15Z","updated_at":"2015-02-09T12:50:07Z","closed_at":null,"body":"My Consumer seems to start the job properly and do the work. However, it does not consume all the messages from queue.\r\n-- Meters ----------------------------------------------------------------------\r\nthroughput\r\n             count = 457546\r\n         mean rate = 4836.02 events/second\r\n     1-minute rate = 4113.17 events/second\r\n     5-minute rate = 2027.04 events/second\r\n    15-minute rate = 1347.94 events/second\r\n\r\n\r\n INFO [myclient_ip-172-31-11-102-1423232252518-a037b72d_watcher_executor] (Logging.scala:68) - [myclient_ip-172-31-11-102-1423232252518-a037b72d], stopping watcher executor thread for consumer myclient_ip-172-31-11-102-1423232252518-a037b72d\r\n\r\nAs you can see myclient group have not consumed all the messages it had to.\r\n\r\nubuntu@ip-172-31-11-102:~/Big-data-cassandra$ ~/kafka/bin/kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --zkconnect localhost:2181 --group myclient\r\nGroup           Topic                          Pid Offset          logSize         Lag             Owner\r\nSLF4J: Failed to load class \"org.slf4j.impl.StaticLoggerBinder\".\r\nSLF4J: Defaulting to no-operation (NOP) logger implementation\r\nSLF4J: See http://www.slf4j.org/codes.html#StaticLoggerBinder for further details.\r\nmyclient        csc8101                        0   268803          50489553        50220750        none\r\nmyclient        csc8101                        1   259671          49879429        49619758        none\r\nmyclient        csc8101                        2   259346          50039695        49780349        none\r\nmyclient        csc8101                        3   237359          49591323        49353964        none\r\n\r\n\r\n"}}