delta/python-packages/kafka-python.git/kafka/consumer, branch batch_size_zero github.com: mumrah/kafka-python.git KAFKA-3044: Re-word consumer.poll behaviour 2016-02-15T22:23:38+00:00 Dana Powers dana.powers@gmail.com 2016-02-15T22:23:38+00:00 b2404578d203baecd41eb7b286e8cec10e037a0d 






Issue 545: Convert deserializer StopIteration errors to raw Exceptions
2016-02-15T20:31:18+00:00

Dana Powers
dana.powers@gmail.com

2016-02-15T20:31:10+00:00

7c779b31dbdd6a69741de5d300d52cc52479054f












Fix Typos (Issue 536)
2016-02-15T17:16:53+00:00

Dana Powers
dana.powers@gmail.com

2016-02-15T17:16:53+00:00

48a71beb2f8c565debd9ea07fc8ada7a2210cbdf












KAFKA-3191: Improve offset committing docstrings
2016-02-03T01:06:16+00:00

Dana Powers
dana.powers@gmail.com

2016-02-03T01:06:16+00:00

e90094ca82a23934eb08a3e19dc1c248ca0e525e












a few extra AssertionError messages in KafkaConsumer
2016-02-03T00:59:46+00:00

Dana Powers
dana.powers@gmail.com

2016-02-03T00:59:46+00:00

d56d2faddabd36ecbec73954bd4a8f17ed501e84












KAFKA-3170: default consumer config for fetch_min_bytes should be 1
2016-02-03T00:58:28+00:00

Dana Powers
dana.powers@gmail.com

2016-02-02T17:59:56+00:00

daa082c07435f3d50a691cc3f8437e3a5d116a50












Add more assertions in KafkaConsumer (primarily to seek* methods)
2016-02-01T08:20:22+00:00

Dana Powers
dana.powers@gmail.com

2016-02-01T08:20:22+00:00

2a783d047aa97cef80ba964cdd2d8dcaaebb4f66












Be sure to get all metadata when subscribing to a regex pattern.
2016-02-01T08:17:42+00:00

Dana Powers
dana.powers@gmail.com

2016-02-01T08:17:42+00:00

894c9aac50ee9a0b0034ea396a7a13e3b5150114












Implement KafkaConsumer.topics()
2016-02-01T08:10:08+00:00

Dana Powers
dana.powers@gmail.com

2016-02-01T07:54:34+00:00

d3d6ea939b85ca033293898e2c4c63eda2335aab

 - add ClusterMetadata.need_all_topic_metadata attribute
 - client requests metadata for all topics if attribute True





 - add ClusterMetadata.need_all_topic_metadata attribute
 - client requests metadata for all topics if attribute True







Add KafkaConsumer.highwater(partition) to get highwater offsets from FetchResponses
2016-02-01T07:46:31+00:00

Dana Powers
dana.powers@gmail.com

2016-02-01T07:46:31+00:00

843b34732d3cc5593c9e03c5ea062d705086eb8c