summaryrefslogtreecommitdiff
Commit message (Expand)AuthorAgeFilesLines
* Skip test that fails on windowswindowsDana Powers2016-03-171-0/+2
* Handle windows socket error codes in BrokerConnectionDana Powers2016-03-171-4/+6
* Use socketpair for KafkaClient wake pipe windows compatibilityDana Powers2016-03-172-6/+65
* Fallback to curl if wget is not availableDana Powers2016-03-171-1/+10
* Release 1.0.21.0.2Dana Powers2016-03-141-1/+1
* Update changelog for 1.0.2 releaseDana Powers2016-03-142-0/+67
* Merge pull request #599 from zackdever/travis-master-deployDana Powers2016-03-141-3/+1
|\
| * Only deploy master branch now that travis bug is fixed.Zack Dever2016-03-141-3/+1
* | Attempt to clarify error message on consumer subscribe/assign assert failureDana Powers2016-03-141-2/+5
* | Merge pull request #598 from zackdever/producer-optimizationDana Powers2016-03-142-5/+8
|\ \ | |/ |/|
| * remove unused import. needed a change to kick travis.Zack Dever2016-03-141-1/+0
| * make Sender._topics_to_add a set instead of a listZack Dever2016-03-141-3/+4
| * only make a metadata event if we don't know the partitionsZack Dever2016-03-141-1/+4
|/
* Merge pull request #597 from dpkp/consumer_poll_sleepDana Powers2016-03-141-1/+1
|\
| * KafkaConsumer.poll should sleep to prevent tight-loopsconsumer_poll_sleepDana Powers2016-03-141-1/+1
* | join consumer threads in test_consumer_group cleanupDana Powers2016-03-141-2/+4
|/
* Re-render fixture config in restart loop if necessaryDana Powers2016-03-141-0/+10
* Merge pull request #587 from dpkp/topic_partition_type_errorDana Powers2016-03-141-0/+17
|\
| * Raise TypeError in KafkaConsumer when partition is not a TopicPartitiontopic_partition_type_errorDana Powers2016-03-141-0/+17
* | Merge pull request #588 from dpkp/none_least_loaded_nodeDana Powers2016-03-142-0/+8
|\ \
| * | Check for None returned from least_loaded_node when no brokers are availablenone_least_loaded_nodeDana Powers2016-03-132-0/+8
| |/
* | Merge pull request #590 from dpkp/accumulator_bugfixDana Powers2016-03-141-2/+4
|\ \
| * | Fix producer threading bug that could crash sender (dict changing during iter...accumulator_bugfixDana Powers2016-03-141-2/+4
| |/
* | More fixture logging improvementsDana Powers2016-03-144-14/+19
|/
* Fixup test fixtures for pylintDana Powers2016-03-132-1/+11
* Merge pull request #585 from dpkp/truncate_bufferDana Powers2016-03-132-17/+27
|\
| * Always truncate deallocated produce message bufferstruncate_bufferDana Powers2016-03-131-12/+5
| * Reduce end-to-end test to 100 messages; raise produce future exceptions immed...Dana Powers2016-03-131-5/+9
| * Add SimpleBufferPool test to verify reallocated buffers are emptyDana Powers2016-03-131-0/+13
* | Improve Fixture loggingDana Powers2016-03-1310-63/+59
|/
* Add ignore_leadernotavailable kwarg to SimpleClient.load_metadata_for_topicsDana Powers2016-03-133-11/+15
* Use producer retries and flush timeout in producer end-to-end testDana Powers2016-03-131-1/+2
* Add optional timeout parameter to KafkaProducer.flush()Dana Powers2016-03-132-9/+13
* Fix for FutureProduceResult.await on python2.6Dana Powers2016-03-131-1/+2
* Move logging format config to tox.ini to avoid duplicate log capture in pytes...Dana Powers2016-03-132-2/+1
* Merge pull request #583 from dpkp/consumer_heartbeat_fixesDana Powers2016-03-124-45/+108
|\
| * Consumer should timeout internal iterator if heartbeat ttl is expiredconsumer_heartbeat_fixesDana Powers2016-03-121-3/+15
| * Add heartbeat timeout testDana Powers2016-03-121-3/+24
| * factor group checking logic to KafkaConsumer._use_consumer_group()Dana Powers2016-03-121-24/+37
| * Log successful heartbeat as INFO; improve heartbeat response loggingDana Powers2016-03-121-11/+12
| * HeartbeatTask should reschedule heartbeat on coordinator_unknown()Dana Powers2016-03-121-2/+6
| * Add test for unknown coordinator heartbeat taskDana Powers2016-03-121-2/+14
|/
* Add timestamps to basic test loggingDana Powers2016-03-121-1/+2
* Sync rendered fixture templates to disk to avoid racesDana Powers2016-03-121-0/+8
* Improve Zookeeper / Kafka Fixture managementDana Powers2016-03-122-4/+22
* Merge pull request #567 from twm/patch-1Dana Powers2016-03-091-1/+1
|\
| * Update base.pyTom Most2016-02-261-1/+1
* | Merge pull request #578 from stefanth/bugfix-stefanth-1Dana Powers2016-03-091-1/+1
|\ \
| * | Bug fix: KafkaConsumer.position()Stefán Þorvarðarson2016-03-091-1/+1
|/ /
* | Merge pull request #573 from scribu/patch-1Dana Powers2016-03-041-2/+2
|\ \
View Lorry Controller Status