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

	Commit message (Expand)	Author	Age	Files	Lines
*	Move logging format config to tox.ini to avoid duplicate log capture in pytes...testing	Dana Powers	2016-03-13	2	-2/+1
*	Add ignore_leadernotavailable kwarg to SimpleClient.load_metadata_for_topics	Dana Powers	2016-03-13	3	-11/+15
*	Use producer retries and flush timeout in producer end-to-end test	Dana Powers	2016-03-13	1	-1/+2
*	Add optional timeout parameter to KafkaProducer.flush()	Dana Powers	2016-03-13	2	-9/+13
*	Fix for FutureProduceResult.await on python2.6	Dana Powers	2016-03-13	1	-1/+2
*	Merge pull request #583 from dpkp/consumer_heartbeat_fixes	Dana Powers	2016-03-12	4	-45/+108
\|\
\| *	Consumer should timeout internal iterator if heartbeat ttl is expiredconsumer_heartbeat_fixes	Dana Powers	2016-03-12	1	-3/+15
\| *	Add heartbeat timeout test	Dana Powers	2016-03-12	1	-3/+24
\| *	factor group checking logic to KafkaConsumer._use_consumer_group()	Dana Powers	2016-03-12	1	-24/+37
\| *	Log successful heartbeat as INFO; improve heartbeat response logging	Dana Powers	2016-03-12	1	-11/+12
\| *	HeartbeatTask should reschedule heartbeat on coordinator_unknown()	Dana Powers	2016-03-12	1	-2/+6
\| *	Add test for unknown coordinator heartbeat task	Dana Powers	2016-03-12	1	-2/+14
\|/
*	Add timestamps to basic test logging	Dana Powers	2016-03-12	1	-1/+2
*	Sync rendered fixture templates to disk to avoid races	Dana Powers	2016-03-12	1	-0/+8
*	Improve Zookeeper / Kafka Fixture management	Dana Powers	2016-03-12	2	-4/+22
*	Merge pull request #567 from twm/patch-1	Dana Powers	2016-03-09	1	-1/+1
\|\
\| *	Update base.py	Tom Most	2016-02-26	1	-1/+1
* \|	Merge pull request #578 from stefanth/bugfix-stefanth-1	Dana Powers	2016-03-09	1	-1/+1
\|\ \
\| * \|	Bug fix: KafkaConsumer.position()	Stefán Þorvarðarson	2016-03-09	1	-1/+1
\|/ /
* \|	Merge pull request #573 from scribu/patch-1	Dana Powers	2016-03-04	1	-2/+2
\|\ \
\| * \|	Fix `value_deserializer` parameter in example	Cristi Burcă	2016-03-02	1	-1/+1
\| * \|	Fix `value_serializer` parameter in example	Cristi Burcă	2016-03-01	1	-1/+1
\|/ /
* \|	Merge pull request #566 from mortenlj/master	Dana Powers	2016-02-27	1	-1/+1
\|\ \ \| \|/ \|/\|
\| *	Fix typo ifr.future.fail => ifr.future.failure	Morten Lied Johansen	2016-02-26	1	-1/+1
\|/
*	Update to Kafka 0.9.0.1 for integration testing	Dana Powers	2016-02-23	7	-6/+184
*	Merge pull request #564 from shichao-an/master	Dana Powers	2016-02-23	1	-0/+1
\|\
\| *	Add missing imports: KafkaError	Shichao An	2016-02-23	1	-0/+1
\|/
*	Bump version for development of next release	Dana Powers	2016-02-22	1	-1/+1
*	Release 1.0.11.0.1	Dana Powers	2016-02-19	3	-3/+3
*	Update Changelog for 1.0.1 patch release	Dana Powers	2016-02-19	2	-0/+60
*	Mock client.ready() call to test coordinator offset fetch request	Dana Powers	2016-02-19	2	-1/+3
*	Migrate load_example.py to KafkaProducer / KafkaConsumer	Dana Powers	2016-02-18	1	-17/+22
*	Catch duplicate batch.done() calls -- this can happen if we maybe_expire then...	Dana Powers	2016-02-18	1	-1/+4
*	Warn if pending batches failed during flush	Dana Powers	2016-02-18	1	-0/+3
*	Fix concurrency bug in RecordAccumulator.ready()	Dana Powers	2016-02-18	1	-2/+6
*	Some attributes may not exist in __del__ if we failed assertions	Dana Powers	2016-02-18	2	-2/+2
*	Fix bug in SimpleBufferPool memory condition waiting / timeout	Dana Powers	2016-02-18	1	-4/+5
*	More friendly warning when offset fetch request returns unknown topic / parti...	Dana Powers	2016-02-18	1	-1/+2
*	Verify node ready before sending offset fetch request from coordinator	Dana Powers	2016-02-18	1	-0/+5
*	Merge pull request #558 from dpkp/batch_size_zero	Dana Powers	2016-02-18	2	-5/+7
\|\
\| *	Support batch_size = 0 in producer buffersbatch_size_zero	Dana Powers	2016-02-17	2	-5/+7
* \|	Merge pull request #557 from dpkp/socket_buffer_size_optional	Dana Powers	2016-02-18	4	-18/+26
\|\ \
\| * \|	Dont override system rcvbuf or sndbuf unless user configures explicitlysocket_buffer_size_optional	Dana Powers	2016-02-17	4	-18/+26
\| \|/
* \|	Merge pull request #553 from aisch/kafka_client_fd_leak	Dana Powers	2016-02-17	5	-7/+64
\|\ \
\| * \|	break up some circular references and close client wake pipe on __del__	aisch	2016-02-16	5	-7/+64
\|/ /
* \|	Merge pull request #550 from dpkp/range_assignor	Dana Powers	2016-02-16	7	-13/+171
\|\ \ \| \|/ \|/\|
\| *	Add RangePartitionAssignor (and use as default); add assignor testsrange_assignor	Dana Powers	2016-02-16	7	-13/+171
\|/
*	Make sure all consumers are in same generation before stopping group test	Dana Powers	2016-02-16	1	-0/+13
*	Improve kafka.cluster docstrings	Dana Powers	2016-02-16	1	-7/+65
*	Bump version for development	Dana Powers	2016-02-15	1	-1/+1