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

	Commit message (Collapse)	Author	Age	Files	Lines
*	Mock client.ensure_topic_exists in test_producer_sync_fail_on_errorproducer_new_topic	Dana Powers	2015-12-17	1	-10/+11
\|
*	Cleanup new producer tests...async_producer_connect_errors	Dana Powers	2015-12-04	1	-6/+6
\|
*	Merge pull request #435 from docker-hub/fix-producer-cleanup-logic	Dana Powers	2015-12-02	1	-0/+14
\|\ \| \| \| \|	Reworked the if statement logic to only call stop() on not-stopped producer objects
\| *	Fixing https://github.com/mumrah/kafka-python/issues/434	toli	2015-07-24	1	-0/+14
\| \| \| \| \| \| \| \| \| \|	Reworked the if statement logic to only call stop() on not-stopped objects. added tests
* \|	Producer test fix for python3	Viktor Shlapakov	2015-06-17	1	-1/+1
\| \|
* \|	Add basic keyed producer tests	Viktor Shlapakov	2015-06-17	1	-2/+22
\|/
*	Support sync_fail_on_error kwarg in Producer	Dana Powers	2015-06-09	1	-2/+18
\|
*	Add Unit test for async producer leader change; return ProduceResponse on ↵	Dana Powers	2015-06-09	1	-10/+56
\| \| \| \|	success
*	Deprecate async producer batch_send kwarg -- use 'async' instead	Dana Powers	2015-06-06	1	-17/+0
\|
*	FailedPayloadsError now only has a single payload; use .payload attribute	Dana Powers	2015-06-06	1	-2/+2
\| \| \| \|	.failed_payloads attribute has been removed.
*	Check response.error for async producer	Viktor Shlapakov	2015-06-03	1	-2/+2
\|
*	Improve async producer code: logic and style fixes	Viktor Shlapakov	2015-06-03	1	-33/+20
\| \| \| \| \| \| \| \| \| \|	- send_producer_request with fail_on_error=False to retry failed reqs only - using an internal dict with with namedtuple keys for retry counters - refresh metadata on refresh_error irrespective to retries options - removed infinite retries (retry_options.limit=None) as an over-feature - separate producer init args for retries options (limit,backoff,on_timeouts) - AsyncProducerQueueFull returns a list of failed messages - producer tests improved thanks to @rogaha and @toli
*	Increase producer test timeout	Viktor Shlapakov	2015-06-03	1	-1/+1
\|
*	Fix small issues with names/tests	Viktor Shlapakov	2015-06-03	1	-7/+5
\|
*	async queue: refactored code; add one more test	Eduard Iskandarov	2015-06-03	1	-2/+16
\|
*	add producer send batch queue overfilled test	Искандаров Эдуард	2015-06-03	1	-1/+17
\|
*	Clean and simplify retry logic	Viktor Shlapakov	2015-06-03	1	-3/+5
\|
*	Improved retry logic	Viktor Shlapakov	2015-06-03	1	-3/+3
\|
*	Fixed tests and other issues after rebase	Viktor Shlapakov	2015-06-03	1	-30/+19
\|
*	Fixed compatible issues with tests	Viktor Shlapakov	2015-06-03	1	-12/+11
\|
*	Producer _send_upstream fixes, added tests for retries	Viktor Shlapakov	2015-06-03	1	-0/+137
\|
*	Just encode to bytes if it isn't bytes.	John Anderson	2015-01-24	1	-6/+10
\|
*	Alert if the topic is not sent as bytes	John Anderson	2015-01-23	1	-0/+11
\|
*	Separate consumers/producers/partitioners	Dana Powers	2014-09-10	1	-1/+1
\|
*	Merge pull request #227 from wizzat-feature/py3	Dana Powers	2014-09-07	1	-5/+5
\|\ \| \| \| \| \| \| \| \| \| \| \| \| \| \| \| \| \| \| \| \| \| \| \| \| \| \| \| \| \| \| \| \|	Python 3 Support Conflicts: kafka/producer.py test/test_client.py test/test_client_integration.py test/test_codec.py test/test_consumer.py test/test_consumer_integration.py test/test_failover_integration.py test/test_producer.py test/test_producer_integration.py test/test_protocol.py test/test_util.py
\| *	More bytes topics	Bruno Renié	2014-09-03	1	-1/+1
\| \|
\| *	Make all unit tests pass on py3.3/3.4	Bruno Renié	2014-09-03	1	-2/+2
\| \|
\| *	Use base unittest or unittest2 depending on python version	Bruno Renié	2014-09-03	1	-2/+2
\| \|
* \|	Cleanup tests: no more import *; remove unused	Dana Powers	2014-09-04	1	-6/+2
\|/
*	Add producer unit test (test/test_producer.py); check supported types in ↵	Dana Powers	2014-08-26	1	-0/+31
	send_messages