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

	Commit message (Expand)	Author	Age	Files	Lines
*	Use socketpair for KafkaClient wake pipe windows compatibility	Dana Powers	2016-03-17	1	-6/+8
*	Check for None returned from least_loaded_node when no brokers are availablenone_least_loaded_node	Dana Powers	2016-03-13	1	-0/+4
*	Merge pull request #557 from dpkp/socket_buffer_size_optional	Dana Powers	2016-02-18	1	-4/+6
\|\
\| *	Dont override system rcvbuf or sndbuf unless user configures explicitlysocket_buffer_size_optional	Dana Powers	2016-02-17	1	-4/+6
* \|	break up some circular references and close client wake pipe on __del__	aisch	2016-02-16	1	-0/+4
\|/
*	bootstrap node should be last resort in least_loaded_node()	Dana Powers	2016-02-15	1	-0/+7
*	KafkaClient.connection_delay should return 0 when connecting to avoid unneces...	Dana Powers	2016-02-15	1	-4/+10
*	Fixup RequestTimeoutError -> RequestTimedOutError	Dana Powers	2016-02-15	1	-1/+1
*	Improve KafkaClient.check_version()	Dana Powers	2016-02-15	1	-13/+27
*	Implement KafkaConsumer.topics()	Dana Powers	2016-02-01	1	-1/+5
*	Add error 104 / Connection reset by peer to expected check_version errors	Dana Powers	2016-01-25	1	-2/+2
*	Small KafkaClient.check_version() improvements	Dana Powers	2016-01-25	1	-3/+20
*	Log new KafkaClient under kafka.client until files are merged	Dana Powers	2016-01-25	1	-1/+1
*	Write bytes to wake_fd	Dana Powers	2016-01-24	1	-1/+1
*	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
*	Remove sleep call in client.poll -- expect callers to manage this and log war...	Dana Powers	2016-01-12	1	-6/+5
*	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	1	-5/+6
*	Check delayed task timeout in client.poll()	Dana Powers	2016-01-10	1	-2/+4
*	Refresh metadata on failed connection attemptshandle_disconnect	Dana Powers	2016-01-09	1	-0/+5
*	Add metadata_max_age_ms and retry_backoff_ms options to async client	Dana Powers	2016-01-07	1	-0/+8
*	Fix future redefine bug in client.poll	Dana Powers	2016-01-04	1	-3/+3
*	Catch py3 ConnectionErrors	Dana Powers	2016-01-03	1	-3/+9
*	Add KafkaClient.check_version() to guess broker version	Dana Powers	2016-01-03	1	-0/+52
*	Fix bug in _initiate_connect preventing reconnect to 'bootstrap'	Dana Powers	2016-01-03	1	-3/+3
*	sys.maxint not supported in python3	Dana Powers	2016-01-01	1	-4/+3
*	Prefer assert or more-specific error to IllegalState / IllegalArgument	Dana Powers	2015-12-30	1	-7/+7
*	More Docstring Improvements	Dana Powers	2015-12-30	1	-60/+131
*	Fix blacked_out typo in least_loaded_node	Dana Powers	2015-12-30	1	-1/+1
*	Rename KafkaClient.connection_failed -> is_disconnected	Dana Powers	2015-12-30	1	-1/+1
*	Improve removed tasks handing in DelayedTaskQueue.pop_ready	Dana Powers	2015-12-30	1	-2/+5
*	Remove unnecessary calls in KafkaClient._poll	Dana Powers	2015-12-30	1	-13/+13
*	Resolve delayed task futures in KafkaClient.poll	Dana Powers	2015-12-30	1	-3/+6
*	Remove unused connection_delay method from KafkaClient	Dana Powers	2015-12-30	1	-18/+0
*	Switch configs from attributes to dict to make passing / inspecting easier	Dana Powers	2015-12-29	1	-44/+29
*	New async KafkaClient, based on java NetworkClient and ConsumerClient	Dana Powers	2015-12-28	1	-0/+502