| Commit message (Collapse) | Author | Age | Files | Lines | ||
|---|---|---|---|---|---|---|
| ... | ||||||
| * | | 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 | |||||
| | * | | 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 | |
| |/ / | | | | | `json.loads()` is for deserialising. | |||||
| * | | Merge pull request #566 from mortenlj/master | Dana Powers | 2016-02-27 | 1 | -1/+1 | |
| |\ \ | |/ |/| | Fix typo ifr.future.fail => ifr.future.failure in conn.py | |||||
| | * | 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 | |||||
| | * | 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 | |
| | | ||||||
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |