delta/python-packages/kafka-python.git/kafka/consumer, branch benchmarksgithub.com: mumrah/kafka-python.git
First stab at public metrics() interface for KafkaConsumer / KafkaProducer2016-07-16T21:05:50+00:00Dana Powersdana.powers@gmail.com2016-07-11T04:40:10+00:009b5c5acd9a8ba044c90ce3583c6c5231369627d6
Add comment re fetcher stats on compressed topics2016-07-16T21:05:50+00:00Dana Powersdana.powers@gmail.com2016-07-11T06:59:05+00:007a6f2349ea05bda9ee6103e7f8214b9778ebcce6
Fixup metrics_sample_window_ms docstring in consumer2016-07-16T21:05:49+00:00Dana Powersdana.powers@gmail.com2016-07-11T04:39:18+00:00abaea8e4b9110c54bf4b2b14a4cdd007b1ce7e29
KAFKA-3785: Fetcher spending unnecessary time during metrics recording2016-07-16T21:05:49+00:00Dana Powersdana.powers@gmail.com2016-07-11T04:38:10+00:00fc5338bc5521ebed2a81357673f5665ddc000a7d
Add api_version config to KafkaClient, deprecate str in favor of tuples (#761)2016-07-16T20:04:28+00:00Dana Powersdana.powers@gmail.com2016-07-16T20:04:28+00:0020f4c95289c694f81a60228a9820601eb57402f4
Add skip_double_compressed_messages option to KafkaConsumer2016-07-15T06:57:04+00:00Dana Powersdana.powers@gmail.com2016-07-15T06:57:04+00:00ad13500cd1276b71bd88fbe3836d7982a6bf1ce3
Log warning if message set appears double-compressed in KafkaConsumer2016-07-15T06:38:14+00:00Dana Powersdana.powers@gmail.com2016-07-15T06:38:14+00:00ed6098c272f90edb375b3ac39c2556338c810a35
Drop recursion in _unpack_message_set2016-07-15T06:05:45+00:00Dana Powersdana.powers@gmail.com2016-07-11T06:32:01+00:00a8c86d379adabeecfe9ba8dd47f7280b0fc3199c
Update consumer_timeout_ms docstring per #7492016-07-08T23:04:09+00:00Dana Powersdana.powers@gmail.com2016-07-08T23:04:09+00:00c921b2ac4cec7459f8a84a0583e8892e6b3f2c6f
Use explicit subscription state flag to handle seek() during message iteration2016-07-08T22:06:37+00:00Dana Powersdana.powers@gmail.com2016-07-08T22:06:37+00:007b5ade10a5f4197ec19fce5d77484100c6dc1273