| Commit message (Collapse) | Author | Age | Files | Lines | |
|---|---|---|---|---|---|
| * | Add kafka.serializer interfacesserialize_interface | Dana Powers | 2016-12-17 | 5 | -24/+67 |
| | | |||||
| * | Fixup doc references to max_in_flight_requests_per_connection | Dana Powers | 2016-12-17 | 3 | -3/+3 |
| | | |||||
| * | Fix typo: passowrd --> password (#901) | Jeff Widman | 2016-12-12 | 1 | -1/+1 |
| | | |||||
| * | Fix possible request draining in ensure_active_group (#896) | Dana Powers | 2016-12-02 | 2 | -12/+16 |
| | | |||||
| * | DOC: Fix typo 'Defualt' -> 'Default'. (#895) | Rolando (Max) Espinoza | 2016-11-30 | 3 | -3/+3 |
| | | |||||
| * | When hostname lookup is necessary, do every connect (#812) | Evan Bender | 2016-11-20 | 2 | -5/+37 |
| | | | | | | Fixes a bug where lookup was done only once for the whole life of the process -- if a broker's IP changed, client couldn't reconnect. | ||||
| * | Use six.string_types for topic type check in #824 | Dana Powers | 2016-11-20 | 1 | -2/+2 |
| | | |||||
| * | Raise exception if given a bad topic name (#824) | Samuel Taylor | 2016-11-20 | 1 | -0/+7 |
| | | |||||
| * | Added doc for `max_poll_records` option (#881) | Taras Voinarovskyi | 2016-11-20 | 1 | -1/+2 |
| | | |||||
| * | setting proper topic value in case if it's empty (#867) | Alexander Sibiryakov | 2016-11-18 | 1 | -11/+4 |
| | | |||||
| * | Always include an error for logging when the coordinator is marked dead (#890) | Dana Powers | 2016-11-18 | 2 | -9/+9 |
| | | |||||
| * | Args are optional in BrokerResponseError str (#889) | Dana Powers | 2016-11-18 | 1 | -3/+3 |
| | | |||||
| * | :wPass timestamp into Message, not just mimic it (#875) | Taras Voinarovskyi | 2016-11-18 | 1 | -2/+6 |
| | | |||||
| * | Always check for request timeouts (#887) | Dana Powers | 2016-11-18 | 2 | -4/+12 |
| | | | | | * Check for requests that timeout without causing a socket read/write event | ||||
| * | typo (#883) | sharego | 2016-11-15 | 1 | -1/+1 |
| | | | | type error | ||||
| * | Update param in warning (#878) | Dana Powers | 2016-11-14 | 1 | -2/+2 |
| |\ | | | | | In Kafka 9, advertised.host.name was renamed to advertised.listeners | ||||
| | * | Update param in warning | Jeff Widman | 2016-11-11 | 1 | -2/+2 |
| | | | | | | | In Kafka 9, advertised.host.name was renamed to advertised.listeners | ||||
| * | | Remove old design notes from Kafka 8 era (#876) | Jeff Widman | 2016-11-14 | 1 | -32/+0 |
| | | | |||||
| * | | Fix typos (#874) | Dana Powers | 2016-11-14 | 12 | -18/+18 |
| |\ \ | |/ |/| | |||||
| | * | Fix typos | Jeff Widman | 2016-11-14 | 12 | -18/+18 |
| |/ | |||||
| * | Revert consumer iterators from max_poll_records (#856) | Dana Powers | 2016-10-24 | 2 | -14/+180 |
| | | |||||
| * | Fix murmur2 bug handling python2 bytes that do not ascii encode (#815) | Dana Powers | 2016-10-22 | 3 | -27/+20 |
| | | | | | | | * Add test for murmur2 py2 bytes bug * Fix murmur2 handling of python2 bytes * Drop bytearray / str / unicode MurmurPartitioner tests -- no longer supported * Make DefaultPartitioner importable from kafka.partitioner | ||||
| * | Bugfix on max_poll_records - TypeError: object of type NoneType has no len() | Dana Powers | 2016-10-04 | 1 | -1/+1 |
| | | |||||
| * | KAFKA-3007: KafkaConsumer max_poll_records (#831) | Dana Powers | 2016-09-28 | 5 | -262/+123 |
| | | |||||
| * | Update Partitioners for use with KafkaProducer (#827) | barrotsteindev | 2016-09-28 | 5 | -24/+112 |
| | | |||||
| * | Monkeypatch max_in_flight_requests_per_connection when checking broker ↵ | Dana Powers | 2016-09-28 | 1 | -6/+11 |
| | | | | | version (#834) | ||||
| * | Fix message timestamp_type (#828) | Josh Yudaken | 2016-09-15 | 1 | -1/+4 |
| | | |||||
| * | Added ssl_password config option to KafkaProducer class, identical to… (#830) | kierkegaard13 | 2016-09-15 | 2 | -0/+5 |
| | | | | | | | | | * Added ssl_password config option to KafkaProducer class, identical to option in KafkaConsumer class * removed non-ascii characters * changed - to : in comments | ||||
| * | from kafka import ConsumerRebalanceListener, OffsetAndMetadata | Dana Powers | 2016-09-04 | 1 | -1/+2 |
| | | |||||
| * | Fix quota violation exception message (#809) | Dana Powers | 2016-08-20 | 1 | -4/+4 |
| | | |||||
| * | Improve KafkaProducer docstring re retries config | Dana Powers | 2016-08-20 | 1 | -3/+5 |
| | | |||||
| * | Add comment for round robin partitioner with different subscriptions | Dana Powers | 2016-08-20 | 1 | -0/+15 |
| | | |||||
| * | Use 0.10.0.1 for integration tests (#803) | Dana Powers | 2016-08-11 | 6 | -5/+193 |
| | | | | | | | * Add 0.10.0.1 fixture resources * Use new release 0.10.0.1 for 0.10 testing | ||||
| * | Bump version for development | Dana Powers | 2016-08-11 | 1 | -1/+1 |
| | | |||||
| * | Patch Release 1.3.11.3.1 | Dana Powers | 2016-08-08 | 3 | -1/+15 |
| | | |||||
| * | HOTFIX: Fix BrokerConnectionMetrics when sensors already exist (i.e., on ↵ | Dana Powers | 2016-08-08 | 1 | -11/+15 |
| | | | | | reconnects) (#799) | ||||
| * | Bump version for development | Dana Powers | 2016-08-04 | 1 | -1/+1 |
| | | |||||
| * | Release 1.3.01.3.0 | Dana Powers | 2016-08-04 | 4 | -2/+120 |
| | | |||||
| * | Dump fixture logs on failure | Dana Powers | 2016-08-04 | 1 | -0/+2 |
| | | |||||
| * | Drain pending requests to the coordinator before initiating group rejoin (#798) | Dana Powers | 2016-08-04 | 1 | -0/+8 |
| | | |||||
| * | Send combined size and payload bytes to socket to avoid potentially split ↵ | Dana Powers | 2016-08-04 | 1 | -6/+6 |
| | | | | | packets with TCP_NODELAY (#797) | ||||
| * | Merge pull request #796 from dpkp/fixture_auto_ports | Dana Powers | 2016-08-04 | 3 | -32/+27 |
| |\ | | | | | Fixture auto ports | ||||
| | * | Dont include kafka.vendor in coveragefixture_auto_ports | Dana Powers | 2016-08-04 | 2 | -3/+6 |
| | | | |||||
| | * | Try to bind to a new port on fixture failure retries | Dana Powers | 2016-08-04 | 1 | -29/+21 |
| |/ | |||||
| * | Change coordinator.needs_join_prepare -> coordinator.rejoining; fix consumer ↵ | Dana Powers | 2016-08-04 | 2 | -5/+10 |
| | | | | | group test (#795) | ||||
| * | Merge pull request #794 from dpkp/conn_metrics | Dana Powers | 2016-08-04 | 13 | -49/+253 |
| |\ | | | | | Complete metrics instrumentation | ||||
| | * | Instrument bufferpool-wait-ratio metric in KafkaProducerconn_metrics | Dana Powers | 2016-08-04 | 3 | -8/+17 |
| | | | |||||
| | * | Instrument metrics in BrokerConnection | Dana Powers | 2016-08-04 | 4 | -17/+127 |
| | | | |||||
| | * | Treat metric_group_prefix as config in KafkaConsumer | Dana Powers | 2016-08-04 | 6 | -19/+17 |
| | | | |||||
| | * | Metrics instance must be passed explicitly from KafkaConsumer to KafkaClient | Dana Powers | 2016-08-04 | 1 | -1/+1 |
| | | | |||||
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |