{"push_id":897197598,"size":14,"distinct_size":14,"ref":"refs/heads/0.9","head":"eea162eb0366ec15782568ae29e482814b06cc0e","before":"9740b2b88b41726f143b3367285dbc118bfa0a8a","commits":[{"sha":"d0de279459a92e787730f5c85a2cf6f2741cbd97","author":{"email":"d546d6c90bbf1198eb46618e79996e13fbe4e3d5@rd.io","name":"Dana Powers"},"message":"Change KafkaProtocol to encode/decode Structs, not bytes\n  - add Payload to kafka.common Request/Responses namedtuples\n  - OffsetFetch and OffsetCommit still need to be converted","distinct":true,"url":"https://api.github.com/repos/dpkp/kafka-python/commits/d0de279459a92e787730f5c85a2cf6f2741cbd97"},{"sha":"17d6a68f6ececea3b4d0290dc84c4c2fc9508e9a","author":{"email":"d546d6c90bbf1198eb46618e79996e13fbe4e3d5@rd.io","name":"Dana Powers"},"message":"Add client_id and correlation_id to BrokerConnection constructor kwargs","distinct":true,"url":"https://api.github.com/repos/dpkp/kafka-python/commits/17d6a68f6ececea3b4d0290dc84c4c2fc9508e9a"},{"sha":"4be8a58592e63859964ca903fa09a7a31ba0c3a2","author":{"email":"d546d6c90bbf1198eb46618e79996e13fbe4e3d5@rd.io","name":"Dana Powers"},"message":"Exception handling cleanup in BrokerConnection (also catch struct.errors in recv)","distinct":true,"url":"https://api.github.com/repos/dpkp/kafka-python/commits/4be8a58592e63859964ca903fa09a7a31ba0c3a2"},{"sha":"ad030ccd4df57305bb624b03eddaa2641f956160","author":{"email":"d546d6c90bbf1198eb46618e79996e13fbe4e3d5@rd.io","name":"Dana Powers"},"message":"Refactor KafkaClient to use BrokerConnections and new Request/Response structs","distinct":true,"url":"https://api.github.com/repos/dpkp/kafka-python/commits/ad030ccd4df57305bb624b03eddaa2641f956160"},{"sha":"a3ec9bd8e8c730c9f6715b536c0c590230fc2e28","author":{"email":"d546d6c90bbf1198eb46618e79996e13fbe4e3d5@rd.io","name":"Dana Powers"},"message":"Update references to kafka.common Request/Response (now Payload)","distinct":true,"url":"https://api.github.com/repos/dpkp/kafka-python/commits/a3ec9bd8e8c730c9f6715b536c0c590230fc2e28"},{"sha":"172a272c4258ddb76f8e8e246ade1618116610c7","author":{"email":"d546d6c90bbf1198eb46618e79996e13fbe4e3d5@rd.io","name":"Dana Powers"},"message":"Handle PartialMessage / ConsumerFetchSizeTooSmall in SimpleConsumer","distinct":true,"url":"https://api.github.com/repos/dpkp/kafka-python/commits/172a272c4258ddb76f8e8e246ade1618116610c7"},{"sha":"1a50de4c3c3fb06c97bb83ffb8854fc71a96a7a9","author":{"email":"d546d6c90bbf1198eb46618e79996e13fbe4e3d5@rd.io","name":"Dana Powers"},"message":"Update client tests for new protocol usage","distinct":true,"url":"https://api.github.com/repos/dpkp/kafka-python/commits/1a50de4c3c3fb06c97bb83ffb8854fc71a96a7a9"},{"sha":"99514c3337e507710a071ed19561502de5968a35","author":{"email":"d546d6c90bbf1198eb46618e79996e13fbe4e3d5@rd.io","name":"Dana Powers"},"message":"Skip consumer tests that cause iterator errors -- needs investigation","distinct":true,"url":"https://api.github.com/repos/dpkp/kafka-python/commits/99514c3337e507710a071ed19561502de5968a35"},{"sha":"5c0bf5f377f15e301ad8ac011854db54ab0f6f92","author":{"email":"d546d6c90bbf1198eb46618e79996e13fbe4e3d5@rd.io","name":"Dana Powers"},"message":"Update to Payload namedtuples in consumer tests","distinct":true,"url":"https://api.github.com/repos/dpkp/kafka-python/commits/5c0bf5f377f15e301ad8ac011854db54ab0f6f92"},{"sha":"f304fb6c4d37a54d142a83e9f654d098347a0750","author":{"email":"d546d6c90bbf1198eb46618e79996e13fbe4e3d5@rd.io","name":"Dana Powers"},"message":"Skip protocol tests for now -- need updating","distinct":true,"url":"https://api.github.com/repos/dpkp/kafka-python/commits/f304fb6c4d37a54d142a83e9f654d098347a0750"},{"sha":"98f393ba6f8dda107c464069fa846e390aee9b42","author":{"email":"d546d6c90bbf1198eb46618e79996e13fbe4e3d5@rd.io","name":"Dana Powers"},"message":"Default consumer integration tests should not use offset commits","distinct":true,"url":"https://api.github.com/repos/dpkp/kafka-python/commits/98f393ba6f8dda107c464069fa846e390aee9b42"},{"sha":"06cc91c64cb35dd1c02597f091f8bf10d63daf3d","author":{"email":"d546d6c90bbf1198eb46618e79996e13fbe4e3d5@rd.io","name":"Dana Powers"},"message":"Support requests that do not expect a response in BrokerConnection","distinct":true,"url":"https://api.github.com/repos/dpkp/kafka-python/commits/06cc91c64cb35dd1c02597f091f8bf10d63daf3d"},{"sha":"e37049fb691cdab1d18becf044aaeaf58d46b5d2","author":{"email":"d546d6c90bbf1198eb46618e79996e13fbe4e3d5@rd.io","name":"Dana Powers"},"message":"Add next_correlation_id_recv + send helper methods to BrokerConnection","distinct":true,"url":"https://api.github.com/repos/dpkp/kafka-python/commits/e37049fb691cdab1d18becf044aaeaf58d46b5d2"},{"sha":"eea162eb0366ec15782568ae29e482814b06cc0e","author":{"email":"d546d6c90bbf1198eb46618e79996e13fbe4e3d5@rd.io","name":"Dana Powers"},"message":"Update kafka.common imports to Payloads namedtuples in test_protocol","distinct":true,"url":"https://api.github.com/repos/dpkp/kafka-python/commits/eea162eb0366ec15782568ae29e482814b06cc0e"}]}