Commit message (Collapse) | Author | Age | Files | Lines | |
---|---|---|---|---|---|
* | Improve KafkaClient connect and ready handlingnode_not_ready | Dana Powers | 2016-04-04 | 1 | -26/+19 |
| | | | | | | - merge _initiate and _finish into _maybe_connect - add connected(node_id) method - only short-circuit send() when not connected | ||||
* | Improve Coordinator Error handling | Dana Powers | 2016-04-04 | 1 | -8/+14 |
| | | | | | | | - coordinator_unknown() should not check ready(node_id) - dont mark coordinator dead on not-ready or inflight-requests errors - improve coordinator and heartbeat logging - dont gate group metadata requests on ready() check [conn handles now] | ||||
* | Drop now-redundant ready() check in Fetcher._handle_offset_response | Dana Powers | 2016-04-04 | 1 | -3/+0 |
| | |||||
* | Improve Broker connection handling of not-ready nodes | Dana Powers | 2016-04-04 | 1 | -24/+26 |
| | | | | | | | - simplify connect state logic - add connecting() method to check state - add BrokerConnection details to exceptions - return NodeNotReady as Future if still connecting | ||||
* | Changed transltae to replace to support python 3 | Tim Evens | 2016-03-30 | 1 | -1/+2 |
| | |||||
* | Kafka IPv6 Support. | Tim Evens | 2016-03-30 | 3 | -18/+63 |
| | | | | | | IPv6 address without port can be defined as the IPv6 address. If the address is a hostname or if a port is included, then the address MUST be wrapped in brackets [] (E.g. [somehost]:1234 or [fd00:1001::2]:1234). | ||||
* | Merge pull request #603 from dpkp/windows | Dana Powers | 2016-03-24 | 3 | -10/+71 |
|\ | | | | | Updates to support Windows | ||||
| * | 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 |
| | | |||||
* | | catch all errors thrown by _get_leader_for_partition in SimpleClient | Zack Dever | 2016-03-17 | 1 | -1/+2 |
| | | |||||
* | | Merge pull request #602 from zackdever/KAFKA-2698 | Dana Powers | 2016-03-17 | 2 | -0/+13 |
|\ \ | | | | | | | KAFKA-2698: add paused API | ||||
| * | | KAFKA-2698: add paused API | Zack Dever | 2016-03-16 | 2 | -0/+13 |
| |/ | |||||
* | | Add default_offset_commit_callback to KafkaConsumer DEFAULT_CONFIGS | Dana Powers | 2016-03-17 | 1 | -0/+1 |
| | | |||||
* | | Bump version for development | Dana Powers | 2016-03-17 | 1 | -1/+1 |
|/ | |||||
* | Release 1.0.21.0.2 | Dana Powers | 2016-03-14 | 1 | -1/+1 |
| | |||||
* | Attempt to clarify error message on consumer subscribe/assign assert failure | Dana Powers | 2016-03-14 | 1 | -2/+5 |
| | |||||
* | 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 |
| | |||||
* | KafkaConsumer.poll should sleep to prevent tight-loopsconsumer_poll_sleep | Dana Powers | 2016-03-14 | 1 | -1/+1 |
| | |||||
* | 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 |
| |/ | |||||
* | | Fix producer threading bug that could crash sender (dict changing during ↵accumulator_bugfix | Dana Powers | 2016-03-14 | 1 | -2/+4 |
|/ | | | | iteration) | ||||
* | Always truncate deallocated produce message bufferstruncate_buffer | Dana Powers | 2016-03-13 | 1 | -12/+5 |
| | |||||
* | Add ignore_leadernotavailable kwarg to SimpleClient.load_metadata_for_topics | Dana Powers | 2016-03-13 | 3 | -11/+15 |
| | |||||
* | 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 |
| | |||||
* | Consumer should timeout internal iterator if heartbeat ttl is expiredconsumer_heartbeat_fixes | Dana Powers | 2016-03-12 | 1 | -3/+15 |
| | |||||
* | 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 |
| | |||||
* | 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?) | ||||
* | | 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(). | ||||
* | | Fix typo ifr.future.fail => ifr.future.failure | Morten Lied Johansen | 2016-02-26 | 1 | -1/+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 | 1 | -1/+1 |
| | |||||
* | Mock client.ready() call to test coordinator offset fetch request | Dana Powers | 2016-02-19 | 1 | -1/+2 |
| | |||||
* | Catch duplicate batch.done() calls -- this can happen if we maybe_expire ↵ | Dana Powers | 2016-02-18 | 1 | -1/+4 |
| | | | | then process a response errback | ||||
* | 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 / ↵ | Dana Powers | 2016-02-18 | 1 | -1/+2 |
| | | | | partition | ||||
* | 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 buffers | ||||
| * | 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 explicitly |