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
*	Ignore _socketobject errors in pylint -- v1.5.4 started throwing no-member er...	Dana Powers	2016-01-23	1	-1/+1
*	Pylint ignores to fix weird 2.7 error in new pylint version	Dana Powers	2016-01-23	1	-0/+3
*	Fix client poll tests (called with sleep=False)	Dana Powers	2016-01-23	1	-4/+5
*	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	8	-14/+51
\|\
\| *	Add DeprecationWarnings to legacy KafkaClient, Simple/MultiProcess/Consumer, ...deprecation_warnings	Dana Powers	2016-01-12	8	-14/+51
* \|	Merge pull request #503 from dpkp/iterator_fetches	Dana Powers	2016-01-12	3	-35/+96
\|\ \ \| \|/ \|/\|
\| *	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
* \|	Add mocking to test_coordinator::test_close to fix random test failure (via t...	Dana Powers	2016-01-11	1	-0/+1
\|/
*	Merge pull request #496 from dpkp/idle_sleep	Dana Powers	2016-01-10	2	-11/+30
\|\
\| *	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	3	-9/+10
*	Merge pull request #502 from dpkp/task_poll_timeout	Dana Powers	2016-01-10	4	-15/+47
\|\
\| *	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	2	-4/+32
* \|	Log generation and member_id in threaded consumer group test	Dana Powers	2016-01-10	1	-1/+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
*	Merge pull request #500 from dpkp/kafka-2978	Dana Powers	2016-01-10	4	-74/+53
\|\
\| *	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	4	-13/+607
\|\
\| *	Add ConsumerCoordinator unit tests	Dana Powers	2016-01-10	1	-0/+568
\| *	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	2	-18/+170
\|\ \ \| \|/ \|/\|
\| *	Refresh metadata on failed connection attemptshandle_disconnect	Dana Powers	2016-01-09	1	-0/+5
\| *	Fill out more async client unit tests	Dana Powers	2016-01-09	1	-18/+165
* \|	Move ConsumerProtocol definition to kafka.coordinator.protocol	Dana Powers	2016-01-10	3	-35/+44
\|/