Commit message (Collapse) | Author | Age | Files | Lines | |
---|---|---|---|---|---|
* | Add DeprecationWarnings to legacy KafkaClient, Simple/MultiProcess/Consumer, ↵deprecation_warnings | Dana Powers | 2016-01-12 | 6 | -5/+43 |
| | | | | and KafkaConnection | ||||
* | Pass consumer timeout to client.poll() in iterator; check timeout before ↵idle_sleep | Dana Powers | 2016-01-10 | 1 | -1/+4 |
| | | | | iterating fetcher | ||||
* | Fix sec / millisec unit bug in KafkaConsumer._poll_once() | Dana Powers | 2016-01-10 | 1 | -1/+1 |
| | |||||
* | Receive all available responses in client._poll | Dana Powers | 2016-01-10 | 1 | -3/+4 |
| | |||||
* | If a completed future is polled, do not block | Dana Powers | 2016-01-10 | 1 | -6/+13 |
| | |||||
* | Avoid CPU spinnning when there are no sockets to read | Dana Powers | 2016-01-10 | 1 | -0/+8 |
| | |||||
* | Fix delayed_task timeout commit 45d26b6 | Dana Powers | 2016-01-10 | 2 | -6/+7 |
| | |||||
* | Merge pull request #502 from dpkp/task_poll_timeout | Dana Powers | 2016-01-10 | 3 | -13/+19 |
|\ | | | | | Add delayed task timeouts to _poll calls | ||||
| * | Improve KafkaConsumer iterator loop timeoutstask_poll_timeout | Dana Powers | 2016-01-10 | 1 | -8/+8 |
| | | | | | | | | | | | | - Consider all delayed tasks, not just heartbeat - Include metadata update timeout - Fix second / millisecond bug calling client.poll() | ||||
| * | Improve cluster.ttl() readability | Dana Powers | 2016-01-10 | 1 | -3/+7 |
| | | |||||
| * | Check delayed task timeout in client.poll() | Dana Powers | 2016-01-10 | 1 | -2/+4 |
| | | |||||
* | | Fix debug logging call in PR 500 | Dana Powers | 2016-01-10 | 1 | -1/+1 |
|/ | |||||
* | Remove old kafka.consumer.kafka module | Dana Powers | 2016-01-10 | 1 | -771/+0 |
| | |||||
* | KAFKA-2978: consumer stops fetching when consumed and fetch positions get ↵ | Dana Powers | 2016-01-10 | 4 | -74/+53 |
| | | | | out of sync | ||||
* | Merge pull request #501 from dpkp/coordinator_tests | Dana Powers | 2016-01-10 | 3 | -13/+39 |
|\ | | | | | ConsumerCoordinator cleanups and test coverage | ||||
| * | ConsumerCoordinator cleanups | Dana Powers | 2016-01-10 | 2 | -13/+36 |
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | - default assignors to RoundRobinPartitionAssignor - check offsets types in commit_offsets_* methods - succeed future in _send_offset_commit_request when no offsets - raise exception if no subscribed topics in group_protocols() - fix _subscription typo in metadata listener callbacks - short circuit if no partitions passed to fetch_committed_offsets - line-wrap comments - return future from commit_offsets_async - return future value from commit_offsets_sync - fix self._failed_request callback partial args - comment out metrics class for now | ||||
| * | Add error checking to mark_for_reassignment | Dana Powers | 2016-01-10 | 1 | -0/+3 |
| | | |||||
* | | Merge pull request #499 from dpkp/handle_disconnect | Dana Powers | 2016-01-10 | 1 | -0/+5 |
|\ \ | |/ |/| | Refresh metadata on failed connection attempts | ||||
| * | Refresh metadata on failed connection attemptshandle_disconnect | Dana Powers | 2016-01-09 | 1 | -0/+5 |
| | | |||||
* | | Move ConsumerProtocol definition to kafka.coordinator.protocol | Dana Powers | 2016-01-10 | 3 | -35/+44 |
|/ | |||||
* | Merge branch '0.9' | Dana Powers | 2016-01-07 | 45 | -1022/+6372 |
|\ | | | | | | | | | | | | | | | Conflicts: kafka/codec.py kafka/version.py test/test_producer.py test/test_producer_integration.py | ||||
| * | Fix KafkaClient->SimpleClient references0.9 | Dana Powers | 2016-01-07 | 4 | -5/+5 |
| | | |||||
| * | Add metadata_max_age_ms and retry_backoff_ms options to async client | Dana Powers | 2016-01-07 | 1 | -0/+8 |
| | | |||||
| * | Docstring updates | Dana Powers | 2016-01-07 | 5 | -182/+209 |
| | | |||||
| * | Reorg kafka imports | Dana Powers | 2016-01-07 | 1 | -11/+12 |
| | | | | | | | | | | | | | | - kafka.KafkaClient is new async client - kafka.SimpleClient is old sync client - update copyright / author info - add BrokerConnection; drop KafkaConnection | ||||
| * | Fix future redefine bug in client.poll | Dana Powers | 2016-01-04 | 2 | -3/+4 |
| | | |||||
| * | Call errbacks with future.exception | Dana Powers | 2016-01-03 | 1 | -1/+1 |
| | | |||||
| * | Import queue from six.moves | Dana Powers | 2016-01-03 | 2 | -8/+3 |
| | | |||||
| * | Catch py3 ConnectionErrors | Dana Powers | 2016-01-03 | 2 | -10/+27 |
| | | |||||
| * | Message value can be None | Dana Powers | 2016-01-03 | 1 | -1/+1 |
| | | |||||
| * | Override Message __hash__ to use _encode_self and not recalc crcs | Dana Powers | 2016-01-03 | 1 | -0/+3 |
| | | |||||
| * | Assert Message value and (optional) key are bytes | Dana Powers | 2016-01-03 | 1 | -0/+2 |
| | | |||||
| * | Add __hash__ method to Struct | Dana Powers | 2016-01-03 | 1 | -0/+3 |
| | | |||||
| * | Switch to new KafkaConsumer in module imports | Dana Powers | 2016-01-03 | 1 | -1/+1 |
| | | |||||
| * | Add deprecated methods to KafkaConsumer w/ notes on alternatives | Dana Powers | 2016-01-03 | 1 | -0/+31 |
| | | |||||
| * | Drop unused method from ConsumerCoordinator | Dana Powers | 2016-01-03 | 1 | -5/+0 |
| | | |||||
| * | Disable pylint error on __iter__ (next is provided via six.Iterator) | Dana Powers | 2016-01-03 | 2 | -2/+2 |
| | | |||||
| * | Keep support for old largest/smallest auto_offset_reset options | Dana Powers | 2016-01-03 | 1 | -0/+7 |
| | | |||||
| * | Return empty dict from KafkaConsumer.poll if no records | Dana Powers | 2016-01-03 | 1 | -1/+1 |
| | | |||||
| * | Support consumer_timeout_ms in new KafkaConsumer | Dana Powers | 2016-01-03 | 1 | -2/+17 |
| | | |||||
| * | Check for 0.8.2 GroupCoordinator quirk in BrokerConnection | Dana Powers | 2016-01-03 | 1 | -1/+13 |
| | | |||||
| * | Check api_version in ConsumerCoordinator | Dana Powers | 2016-01-03 | 1 | -32/+94 |
| | | | | | | | | | | | | | | - Full group support in 0.9 - Kafka-storage offsets w/ GroupCoordinator in 0.8.2 - Zookeeper-storage offsets in 0.8.1 - Assign all partitions locally if < 0.9 | ||||
| * | Add api_version config to KafkaConsumer; disable features inline by version | Dana Powers | 2016-01-03 | 1 | -11/+36 |
| | | |||||
| * | Add KafkaClient.check_version() to guess broker version | Dana Powers | 2016-01-03 | 1 | -0/+52 |
| | | |||||
| * | Fix bug in _initiate_connect preventing reconnect to 'bootstrap' | Dana Powers | 2016-01-03 | 1 | -3/+3 |
| | | |||||
| * | Fix timeout bug in BrokerConnection.connect() | Dana Powers | 2016-01-03 | 1 | -8/+9 |
| | | |||||
| * | Raise exception in KafkaConsumer on unrecognized kwargs | Dana Powers | 2016-01-02 | 1 | -1/+4 |
| | | |||||
| * | Batched message methods now return dict of lists | Dana Powers | 2016-01-02 | 2 | -4/+4 |
| | | |||||
| * | Improve iterator interface | Dana Powers | 2016-01-02 | 2 | -12/+44 |
| | | | | | | | | | | | | | | | | - Support single message consumption via next(consumer) in py2/py3 - batch message methods (Fetcher.fetched_records / KafkaConsumer.poll) are incompatible with iterators -- message generator state keeps messages internally after they are popped from _records, but before subscription_state is updated. | ||||
| * | Fixup b6a2ad9: Fail with ConnectionErrors in BrokerConnection.send | Dana Powers | 2016-01-02 | 1 | -2/+3 |
| | |