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

	Commit message (Collapse)	Author	Age	Files	Lines
*	Vendor six 1.10.0six	Dana Powers	2016-08-01	1	-1/+1
\|
*	Use explicit subscription state flag to handle seek() during message iterationcompacted_offsets	Dana Powers	2016-07-08	1	-0/+2
\|
*	Update imports from kafka.common -> kafka.errors / kafka.structs	Dana Powers	2016-04-05	1	-1/+2
\|
*	KAFKA-2698: add paused API	Zack Dever	2016-03-16	1	-0/+5
\|
*	Attempt to clarify error message on consumer subscribe/assign assert failure	Dana Powers	2016-03-14	1	-2/+5
\|
*	Add KafkaConsumer.highwater(partition) to get highwater offsets from ↵	Dana Powers	2016-01-31	1	-0/+1
\| \| \| \|	FetchResponses
*	KAFKA-2978: consumer stops fetching when consumed and fetch positions get ↵	Dana Powers	2016-01-10	1	-23/+11
\| \| \| \|	out of sync
*	Add error checking to mark_for_reassignment	Dana Powers	2016-01-10	1	-0/+3
\|
*	Prefer assert or more-specific error to IllegalState / IllegalArgument	Dana Powers	2015-12-30	1	-6/+3
\|
*	More Docstring Improvements	Dana Powers	2015-12-30	1	-22/+91
\|
*	Log as INFO: group join, leader election, partition assignments	Dana Powers	2015-12-29	1	-0/+1
\|
*	Improve various docstrings	Dana Powers	2015-12-29	1	-3/+10
\|
*	Make add_assigned_partition private(ish) in SubscriptionState	Dana Powers	2015-12-29	1	-3/+3
\|
*	Define ConsumerRebalanceListener abstract class	Dana Powers	2015-12-28	1	-0/+84
\|
*	New class SubscriptionState, based on upstream Java client	Dana Powers	2015-12-28	1	-0/+304