{"action":"closed","issue":{"url":"https://api.github.com/repos/dpkp/kafka-python/issues/708","repository_url":"https://api.github.com/repos/dpkp/kafka-python","labels_url":"https://api.github.com/repos/dpkp/kafka-python/issues/708/labels{/name}","comments_url":"https://api.github.com/repos/dpkp/kafka-python/issues/708/comments","events_url":"https://api.github.com/repos/dpkp/kafka-python/issues/708/events","html_url":"https://github.com/dpkp/kafka-python/issues/708","id":157058231,"number":708,"title":"KafkaConsumer not reading messages from queue... only reading from last published","user":{"login":"shiladityasen","id":16183428,"avatar_url":"https://avatars.githubusercontent.com/u/16183428?v=3","gravatar_id":"","url":"https://api.github.com/users/shiladityasen","html_url":"https://github.com/shiladityasen","followers_url":"https://api.github.com/users/shiladityasen/followers","following_url":"https://api.github.com/users/shiladityasen/following{/other_user}","gists_url":"https://api.github.com/users/shiladityasen/gists{/gist_id}","starred_url":"https://api.github.com/users/shiladityasen/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/shiladityasen/subscriptions","organizations_url":"https://api.github.com/users/shiladityasen/orgs","repos_url":"https://api.github.com/users/shiladityasen/repos","events_url":"https://api.github.com/users/shiladityasen/events{/privacy}","received_events_url":"https://api.github.com/users/shiladityasen/received_events","type":"User","site_admin":false},"labels":[],"state":"closed","locked":false,"assignee":null,"milestone":null,"comments":1,"created_at":"2016-05-26T19:18:47Z","updated_at":"2016-05-26T21:30:55Z","closed_at":"2016-05-26T21:30:55Z","body":"I am doing these experiments in an IPython environment on OSX El Capitan.\r\n\r\nThese are the messages that have already been published in the topic 'test' by a command-line publisher:  \r\n\r\n```\r\nThis is a message\r\nThis is another message\r\nNew message\r\nCompletely new message\r\nAgain, new message\r\nnew new\r\nThis one will get delivered\r\nWhat?\r\n```\r\n This is how I am setting up my consumer:\r\n\r\n```\r\nfrom kafka import KafkaConsumer  \r\nconsumer = KafkaConsumer('test', bootstrap_servers='localhost:9092',  auto_offset_reset='earliest')  \r\nfor msg in consumer:  \r\n    print msg\r\n```  \r\n\r\nHowever, this is only giving as output:  \r\n`ConsumerRecord(topic=u'test', partition=0, offset=7, timestamp=1464290063509, timestamp_type=0, key=None, value='What?')`  \r\nEven if I have set `auto_offset_reset='earliest'`... Shouldn't it just read from the start and give me all messages published to this topic?  \r\nHow do I get all messages from beginning?"}}
{"actor":{"display_login":"shiladityasen"}}