delta/python-packages/kafka-python.git - github.com: mumrah/kafka-python.git

	Commit message (Expand)	Author	Age	Files	Lines
...
* \| \|	Fix names for async retries opts, add timeout for put	Viktor Shlapakov	2015-06-03	4	-20/+34
* \| \|	Simplification of retry logic	Viktor Shlapakov	2015-06-03	2	-31/+29
* \| \|	Fix small issues with names/tests	Viktor Shlapakov	2015-06-03	2	-9/+11
* \| \|	async queue: refactored code; add one more test	Eduard Iskandarov	2015-06-03	1	-2/+7
* \| \|	add producer send batch queue overfilled test	Искандаров Эдуард	2015-06-03	1	-1/+7
* \| \|	Disable retry on timeouts by default (old behaviour)	Viktor Shlapakov	2015-06-03	1	-1/+1
* \| \|	Clean and simplify retry logic	Viktor Shlapakov	2015-06-03	2	-60/+49
* \| \|	Arg fixes for base/keyed producers	Viktor Shlapakov	2015-06-03	2	-4/+2
* \| \|	Improved retry logic	Viktor Shlapakov	2015-06-03	4	-31/+73
* \| \|	Fixed tests and other issues after rebase	Viktor Shlapakov	2015-06-03	2	-2/+1
* \| \|	Returned default behaviour with no retries	Viktor Shlapakov	2015-06-03	1	-1/+1
* \| \|	Fix: check failed reqs to retry only for positive limit	Viktor Shlapakov	2015-06-03	1	-3/+3
* \| \|	Fixed compatible issues with tests	Viktor Shlapakov	2015-06-03	1	-3/+5
* \| \|	Producer _send_upstream fixes, added tests for retries	Viktor Shlapakov	2015-06-03	1	-6/+20
* \| \|	Fixed base producer imports	Viktor Shlapakov	2015-06-03	1	-1/+2
* \| \|	Retries for async batching	Viktor Shlapakov	2015-06-03	4	-15/+50
\| \|/ \|/\|
* \|	Check vs None directly.	William Ting	2015-05-17	1	-4/+4
\|/
*	Fix calling of _offsets	Arturo Filastò	2015-05-14	1	-1/+1
*	Merge pull request #367 from dpkp/clean_metadata_refresh	Dana Powers	2015-04-12	1	-13/+14
\|\
\| *	Update debug log messages in client.load_metadata_for_topics	Dana Powers	2015-04-12	1	-2/+2
\| *	clean local metadata before requesting refresh in load_metadata_for_topics()	Dana Powers	2015-04-12	1	-2/+7
\| *	Simplify client.reset_topic_metadata	Dana Powers	2015-04-12	1	-9/+5
* \|	Merge pull request #366 from dpkp/failed_payloads	Dana Powers	2015-04-12	1	-79/+77
\|\ \ \| \|/ \|/\|
\| *	Improve send_produce_request docstring	Dana Powers	2015-04-06	1	-6/+17
\| *	Add debug logging for all broker-aware requests/responses	Dana Powers	2015-04-06	1	-0/+3
\| *	Refactor KafkaClient._send_broker_aware_request to return a list of responses	Dana Powers	2015-04-06	1	-73/+57
* \|	Use kafka_bytestring when decoding message topics in KafkaConsumer.fetch_mess...	Dana Powers	2015-04-04	1	-18/+22
* \|	Use list comprehension on _topics in KafkaConsumer.fetch_messages	Dana Powers	2015-04-04	1	-8/+8
* \|	call _consume_topic_partition() before storing offset	Dana Powers	2015-04-04	1	-1/+1
* \|	Fix python3 str/bytes bug in KafkaConsumer.set_topic_partitions({(topic, part...	Dana Powers	2015-04-04	1	-1/+1
\|/
*	Merge pull request #360 from dpkp/atexit_cleanup	Dana Powers	2015-04-04	2	-4/+51
\|\
\| *	Register atexit handlers for consumer and producer thread/multiprocess cleanu...	Dana Powers	2015-03-31	2	-4/+51
* \|	Make external API consistently support python3 strings for topic.	Space	2015-04-03	5	-4/+17
\|/
*	Merge pull request #356 from dpkp/always_fetch_offsets	Dana Powers	2015-03-30	3	-12/+30
\|\
\| *	Bulk fetch offset partitions in base consumer -- suggested by ecanzonieri	Dana Powers	2015-03-30	1	-8/+9
\| *	Fetch previously committed offsets in base consumer class so long as	Dana Powers	2015-03-30	3	-12/+29
* \|	Merge pull request #355 from dpkp/correlation_id_modulo	Dana Powers	2015-03-30	1	-7/+7
\|\ \ \| \|/ \|/\|
\| *	Rollover KafkaClient correlation ids at 2**31 to keep within int32 protocol e...	Dana Powers	2015-03-29	1	-7/+7
* \|	Merge pull request #357 from dpkp/del_consumer_stop	Dana Powers	2015-03-30	1	-0/+3
\|\ \
\| * \|	Stop consumers on delete	Dana Powers	2015-03-30	1	-0/+3
\| \|/
* \|	fixup kafka consumer docstring	Dana Powers	2015-03-29	1	-1/+1
* \|	Improve KafkaConsumer docstrings	Dana Powers	2015-03-29	1	-134/+94
\|/
*	Merge pull request #340 from dpkp/deprecate_metadata_broker_list	Dana Powers	2015-03-29	1	-8/+26
\|\
\| *	Deprecate KafkaConsumer config metadata_broker_list in favor of bootstrap_ser...	Dana Powers	2015-03-23	1	-8/+26
* \|	Merge pull request #336 from scrapinghub/feature-mp-consumer-params	Dana Powers	2015-03-29	2	-35/+51
\|\ \
\| * \|	Manageable queue.put() operation for MPConsumer processes	Viktor Shlapakov	2015-03-25	2	-4/+12
\| * \|	Using mp.manager to solve the issue with join for MPConsumer	Viktor Shlapakov	2015-03-24	1	-6/+7
\| * \|	Moving to **kwargs for MPConsumer options	Viktor Shlapakov	2015-03-24	1	-1/+2
\| * \|	Moved additional MP consumer options to **kwargs	Viktor Shlapakov	2015-03-13	1	-3/+3
\| * \|	Using additional params for MP consumer child process	Viktor Shlapakov	2015-03-13	1	-26/+32