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

	Commit message (Expand)	Author	Age	Files	Lines
*	DefaultPartitioner - implements java client logic	Dana Powers	2016-01-24	1	-0/+23
*	Support encode and repr on raw BytesIO MessageSets (used in new producer)	Dana Powers	2016-01-24	1	-0/+12
*	Add Message and MessageSet HEADER_SIZE bytes	Dana Powers	2016-01-24	1	-0/+2
*	Dont need to refresh metadata on GroupCoordinatorNotAvailableErrors	Dana Powers	2016-01-24	1	-1/+4
*	Write bytes to wake_fd	Dana Powers	2016-01-24	1	-1/+1
*	Warn on 0.8.2 GroupCoordinator no-topic-quirk, dont raise exception	Dana Powers	2016-01-23	1	-2/+5
*	Pylint ignores to fix weird 2.7 error in new pylint version	Dana Powers	2016-01-23	1	-0/+3
*	Add available_partitions_for_topic() and partitions_for_broker()	Dana Powers	2016-01-23	1	-2/+23
*	KafkaClient.add_topic() -- for use by async producer	Dana Powers	2016-01-23	1	-0/+15
*	Optionally sleep in KafkaClient.poll(), add KafkaClient.wakeup()	Dana Powers	2016-01-23	1	-7/+37
*	Add back connection_delay method to KafkaClient - used by KafkaProducer	Dana Powers	2016-01-18	1	-0/+20
*	Merge pull request #507 from dpkp/deprecation_warnings	Dana Powers	2016-01-12	6	-5/+43
\|\
\| *	Add DeprecationWarnings to legacy KafkaClient, Simple/MultiProcess/Consumer, ...deprecation_warnings	Dana Powers	2016-01-12	6	-5/+43
* \|	Sleep in KafkaConsumer iterator if no partition assignment; dont block in pol...iterator_fetches	Dana Powers	2016-01-12	1	-4/+25
* \|	Remove sleep call in client.poll -- expect callers to manage this and log war...	Dana Powers	2016-01-12	1	-6/+5
* \|	Move consumer_timeout handling to private method	Dana Powers	2016-01-12	1	-5/+7
* \|	Attempt to pipeline fetchrequests in iterator	Dana Powers	2016-01-12	1	-1/+2
* \|	Use private deque to track in-flight fetchrequests	Dana Powers	2016-01-12	1	-0/+16
* \|	Update docstring and comments in _create_fetch_requests re KAFKA-2978	Dana Powers	2016-01-10	1	-5/+2
* \|	Reorganize init_fetches calls during iteration	Dana Powers	2016-01-10	2	-7/+20
* \|	Check for assignment changes before yielding new record	Dana Powers	2016-01-10	1	-0/+9
* \|	Fetcher logging should be debug or trace (left higher during testing)	Dana Powers	2016-01-10	2	-9/+12
\|/
*	Pass consumer timeout to client.poll() in iterator; check timeout before iter...idle_sleep	Dana Powers	2016-01-10	1	-1/+4
*	Fix sec / millisec unit bug in KafkaConsumer._poll_once()	Dana Powers	2016-01-10	1	-1/+1
*	Receive all available responses in client._poll	Dana Powers	2016-01-10	1	-3/+4
*	If a completed future is polled, do not block	Dana Powers	2016-01-10	1	-6/+13
*	Avoid CPU spinnning when there are no sockets to read	Dana Powers	2016-01-10	1	-0/+8
*	Fix delayed_task timeout commit 45d26b6	Dana Powers	2016-01-10	2	-6/+7
*	Merge pull request #502 from dpkp/task_poll_timeout	Dana Powers	2016-01-10	3	-13/+19
\|\
\| *	Improve KafkaConsumer iterator loop timeoutstask_poll_timeout	Dana Powers	2016-01-10	1	-8/+8
\| *	Improve cluster.ttl() readability	Dana Powers	2016-01-10	1	-3/+7
\| *	Check delayed task timeout in client.poll()	Dana Powers	2016-01-10	1	-2/+4
* \|	Fix debug logging call in PR 500	Dana Powers	2016-01-10	1	-1/+1
\|/
*	Remove old kafka.consumer.kafka module	Dana Powers	2016-01-10	1	-771/+0
*	KAFKA-2978: consumer stops fetching when consumed and fetch positions get out...	Dana Powers	2016-01-10	4	-74/+53
*	Merge pull request #501 from dpkp/coordinator_tests	Dana Powers	2016-01-10	3	-13/+39
\|\
\| *	ConsumerCoordinator cleanups	Dana Powers	2016-01-10	2	-13/+36
\| *	Add error checking to mark_for_reassignment	Dana Powers	2016-01-10	1	-0/+3
* \|	Merge pull request #499 from dpkp/handle_disconnect	Dana Powers	2016-01-10	1	-0/+5
\|\ \ \| \|/ \|/\|
\| *	Refresh metadata on failed connection attemptshandle_disconnect	Dana Powers	2016-01-09	1	-0/+5
* \|	Move ConsumerProtocol definition to kafka.coordinator.protocol	Dana Powers	2016-01-10	3	-35/+44
\|/
*	Merge branch '0.9'	Dana Powers	2016-01-07	45	-1022/+6372
\|\
\| *	Fix KafkaClient->SimpleClient references0.9	Dana Powers	2016-01-07	4	-5/+5
\| *	Add metadata_max_age_ms and retry_backoff_ms options to async client	Dana Powers	2016-01-07	1	-0/+8
\| *	Docstring updates	Dana Powers	2016-01-07	5	-182/+209
\| *	Reorg kafka imports	Dana Powers	2016-01-07	1	-11/+12
\| *	Fix future redefine bug in client.poll	Dana Powers	2016-01-04	2	-3/+4
\| *	Call errbacks with future.exception	Dana Powers	2016-01-03	1	-1/+1
\| *	Import queue from six.moves	Dana Powers	2016-01-03	2	-8/+3
\| *	Catch py3 ConnectionErrors	Dana Powers	2016-01-03	2	-10/+27