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

	Commit message (Collapse)	Author	Age	Files	Lines
*	Remove unused importskafka-3318	Dana Powers	2016-04-05	1	-1/+0
\|
*	Update imports from kafka.common -> kafka.errors / kafka.structs	Dana Powers	2016-04-05	1	-2/+2
\|
*	Improve kafka.cluster docstrings	Dana Powers	2016-02-16	1	-7/+65
\|
*	Add lock to synchronize metadata updates and future handling	Dana Powers	2016-02-15	1	-18/+34
\|
*	warn (not error) on LeaderNotAvailable - this is usually not cause for concern	Dana Powers	2016-02-15	1	-2/+2
\|
*	Update ClusterMetadata comments	Dana Powers	2016-02-15	1	-7/+7
\|
*	Track set of unauthorized_topics in ClusterMetadata	Dana Powers	2016-02-15	1	-0/+3
\|
*	Remove unused cluster._version private attribute	Dana Powers	2016-02-15	1	-4/+1
\|
*	Keep full PartitionMetadata from MetadataResponses	Dana Powers	2016-02-15	1	-6/+10
\|
*	Implement KafkaConsumer.topics()	Dana Powers	2016-02-01	1	-2/+4
\| \| \| \| \|	- add ClusterMetadata.need_all_topic_metadata attribute - client requests metadata for all topics if attribute True
*	Add available_partitions_for_topic() and partitions_for_broker()	Dana Powers	2016-01-23	1	-2/+23
\|
*	Improve cluster.ttl() readability	Dana Powers	2016-01-10	1	-3/+7
\|
*	Switch configs from attributes to dict to make passing / inspecting easier	Dana Powers	2015-12-29	1	-8/+12
\|
*	Add ClusterMetadata.add_group_coordinator()	Dana Powers	2015-12-28	1	-0/+39
\|
*	Rename Cluster -> ClusterMetadata; align with upstream Metadata class	Dana Powers	2015-12-28	1	-66/+121
\|
*	Switch BrokerConnection to (mostly) non-blocking IO.	Dana Powers	2015-12-17	1	-1/+1
\| \| \| \| \| \|	- return kafka.Future on send() - recv is now non-blocking call that completes futures when possible - update KafkaClient to block on future completion
*	few small cleanups	Zack Dever	2015-12-04	1	-1/+1
\|
*	Add simple Cluster class to manage broker metadata	Dana Powers	2015-12-04	1	-0/+91