| Commit message (Collapse) | Author | Age | Files | Lines | |
|---|---|---|---|---|---|
| * | Skip test that fails on windowswindows | Dana Powers | 2016-03-17 | 1 | -0/+2 |
| | | |||||
| * | Handle windows socket error codes in BrokerConnection | Dana Powers | 2016-03-17 | 1 | -4/+6 |
| | | |||||
| * | Use socketpair for KafkaClient wake pipe windows compatibility | Dana Powers | 2016-03-17 | 2 | -6/+65 |
| | | |||||
| * | Fallback to curl if wget is not available | Dana Powers | 2016-03-17 | 1 | -1/+10 |
| | | |||||
| * | Release 1.0.21.0.2 | Dana Powers | 2016-03-14 | 1 | -1/+1 |
| | | |||||
| * | Update changelog for 1.0.2 release | Dana Powers | 2016-03-14 | 2 | -0/+67 |
| | | |||||
| * | Merge pull request #599 from zackdever/travis-master-deploy | Dana Powers | 2016-03-14 | 1 | -3/+1 |
| |\ | | | | | Only deploy master branch now that travis bug is fixed. | ||||
| | * | Only deploy master branch now that travis bug is fixed. | Zack Dever | 2016-03-14 | 1 | -3/+1 |
| | | | | | | | | | | | This https://github.com/travis-ci/travis-ci/issues/1675 is now closed, but I don't know of a good way to test this. | ||||
| * | | Attempt to clarify error message on consumer subscribe/assign assert failure | Dana Powers | 2016-03-14 | 1 | -2/+5 |
| | | | |||||
| * | | Merge pull request #598 from zackdever/producer-optimization | Dana Powers | 2016-03-14 | 2 | -5/+8 |
| |\ \ | |/ |/| | Producer optimization | ||||
| | * | remove unused import. needed a change to kick travis. | Zack Dever | 2016-03-14 | 1 | -1/+0 |
| | | | |||||
| | * | make Sender._topics_to_add a set instead of a list | Zack Dever | 2016-03-14 | 1 | -3/+4 |
| | | | |||||
| | * | only make a metadata event if we don't know the partitions | Zack Dever | 2016-03-14 | 1 | -1/+4 |
| |/ | |||||
| * | Merge pull request #597 from dpkp/consumer_poll_sleep | Dana Powers | 2016-03-14 | 1 | -1/+1 |
| |\ | | | | | KafkaConsumer.poll should sleep to prevent tight-loops | ||||
| | * | KafkaConsumer.poll should sleep to prevent tight-loopsconsumer_poll_sleep | Dana Powers | 2016-03-14 | 1 | -1/+1 |
| | | | |||||
| * | | join consumer threads in test_consumer_group cleanup | Dana Powers | 2016-03-14 | 1 | -2/+4 |
| |/ | |||||
| * | Re-render fixture config in restart loop if necessary | Dana Powers | 2016-03-14 | 1 | -0/+10 |
| | | |||||
| * | Merge pull request #587 from dpkp/topic_partition_type_error | Dana Powers | 2016-03-14 | 1 | -0/+17 |
| |\ | | | | | Raise TypeError in KafkaConsumer when partition is not a TopicPartition | ||||
| | * | Raise TypeError in KafkaConsumer when partition is not a TopicPartitiontopic_partition_type_error | Dana Powers | 2016-03-14 | 1 | -0/+17 |
| | | | |||||
| * | | Merge pull request #588 from dpkp/none_least_loaded_node | Dana Powers | 2016-03-14 | 2 | -0/+8 |
| |\ \ | | | | | | | Improve handling of least_loaded_node failure | ||||
| | * | | Check for None returned from least_loaded_node when no brokers are availablenone_least_loaded_node | Dana Powers | 2016-03-13 | 2 | -0/+8 |
| | |/ | |||||
| * | | Merge pull request #590 from dpkp/accumulator_bugfix | Dana Powers | 2016-03-14 | 1 | -2/+4 |
| |\ \ | | | | | | | Fix producer threading bug that can crash sender | ||||
| | * | | Fix producer threading bug that could crash sender (dict changing during ↵accumulator_bugfix | Dana Powers | 2016-03-14 | 1 | -2/+4 |
| | |/ | | | | | | | iteration) | ||||
| * | | More fixture logging improvements | Dana Powers | 2016-03-14 | 4 | -14/+19 |
| |/ | | | | | | | | - Add test logging NullHandler - Remove default logging level filtering in testutil - Log render_template info - More fixture logging cleanups - wait_for() should not handle child shutdown | ||||
| * | Fixup test fixtures for pylint | Dana Powers | 2016-03-13 | 2 | -1/+11 |
| | | |||||
| * | Merge pull request #585 from dpkp/truncate_buffer | Dana Powers | 2016-03-13 | 2 | -17/+27 |
| |\ | | | | | Truncate deallocated message buffers | ||||
| | * | Always truncate deallocated produce message bufferstruncate_buffer | Dana Powers | 2016-03-13 | 1 | -12/+5 |
| | | | |||||
| | * | Reduce end-to-end test to 100 messages; raise produce future exceptions ↵ | Dana Powers | 2016-03-13 | 1 | -5/+9 |
| | | | | | | | | | immediately | ||||
| | * | Add SimpleBufferPool test to verify reallocated buffers are empty | Dana Powers | 2016-03-13 | 1 | -0/+13 |
| | | | |||||
| * | | Improve Fixture logging | Dana Powers | 2016-03-13 | 10 | -63/+59 |
| |/ | | | | | | | - remove double console appenders from log4j.properties - also log to server.log file for interactive uses - drop internal _spawn from SpawnedService loop - write captured stdout/stderr directly to avoid logger re-formatting | ||||
| * | 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 |
| | | |||||
| * | Move logging format config to tox.ini to avoid duplicate log capture in ↵ | Dana Powers | 2016-03-13 | 2 | -2/+1 |
| | | | | | pytest output | ||||
| * | Merge pull request #583 from dpkp/consumer_heartbeat_fixes | Dana Powers | 2016-03-12 | 4 | -45/+108 |
| |\ | | | | | Fix Consumer Heartbeat Bugs | ||||
| | * | 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 |
| | | | | | | | - spawn fixtures via daemon threads - close fixtures atexit and in __del__ to avoid interpreter hangs - raise Exception on timeouts in open() | ||||
| * | Merge pull request #567 from twm/patch-1 | Dana Powers | 2016-03-09 | 1 | -1/+1 |
| |\ | | | | | Silence suprious warnings | ||||
| | * | Update base.py | Tom Most | 2016-02-26 | 1 | -1/+1 |
| | | | | | | | | | | | | | | | | | | | Our app uses `SimpleProducer` and logs lots of these warnings (from line 438): producer.stop() called, but producer is not async This destructor appears to be the cause. (Also, is it wise to do a thread join from a destructor?) | ||||
| * | | Merge pull request #578 from stefanth/bugfix-stefanth-1 | Dana Powers | 2016-03-09 | 1 | -1/+1 |
| |\ \ | | | | | | | Bug fix: KafkaConsumer.position() | ||||
| | * | | Bug fix: KafkaConsumer.position() | Stefán Þorvarðarson | 2016-03-09 | 1 | -1/+1 |
| |/ / | | | | | | | | | Method KafkaConsumer.position() was not refreshing position correctly when calling self._update_fetch_positions(). | ||||
| * | | Merge pull request #573 from scribu/patch-1 | Dana Powers | 2016-03-04 | 1 | -2/+2 |
| |\ \ | | | | | | | Fix `value_serializer` parameter in example | ||||
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |