openstack
/
deb-python-kafka
Code Issues Proposed changes

Commit Graph

  • 17ac98c7b1 OpenDev Migration Patch debian/newton OpenDev Sysadmins 2019-04-19 19:32:37 +0000
  • 165b897139 Use for join-time-max and sync-time-max metrics Max() measure function (#1146) master Alexey Pervushin 2017-07-20 22:07:50 -0700
  • 0c78f70452 added gssapi support (Kerberos) for SASL (#1152) Harald 2017-07-20 19:09:26 +0200
  • c8237fc53b Add note, that `max_in_flight_requests_per_connection>1` may change order or messages (#1149) Taras Voinarovskyi 2017-07-18 02:39:37 +0300
  • 6f0395786a producer: fix produce timeout message (#1151) Mika Eloranta 2017-07-18 02:39:04 +0300
  • d0c6b1f95c Protocol updates for 0.11.0.0 (#1127) Dana Powers 2017-07-09 08:04:39 -0700
  • 2f75169504 Use logging's built-in string interpolation Jeff Widman 2017-07-07 11:32:25 -0700
  • 43939b29b5 change_subscription called only when necessary (#1132) Petr Šebek 2017-07-07 21:29:40 +0200
  • 71ce772484 Fix typo Jeff Widman 2017-07-01 02:37:52 -0700
  • cf8c034b89 Cleanup protocol change comments protocol_updates Dana Powers 2017-06-19 17:18:59 -0700
  • b8da199b54 producer: Set exit timeout to 0 for atexit handler to match __del__ (#1126) Hannu Valtonen 2017-06-20 03:09:43 +0300
  • 2533680134 Add new protocol definitions for 0.11.0.0 Dana Powers 2017-06-19 15:55:52 -0700
  • b1cc966439 KIP-144: Exponential backoff for broker reconnections (#1124) Dana Powers 2017-06-19 10:16:02 -0700
  • 3a67f64168 Add new FetchRequest v4/v5, MetadataRequest v3/v4 Dana Powers 2017-06-19 10:11:53 -0700
  • cceaf4ae09 Backoff on unavailable group coordinator retry (#1125) Dana Powers 2017-06-19 09:18:56 -0700
  • 5ea283ce48 Fix conn.connection_delay exp_backoff Dana Powers 2017-06-19 08:28:02 -0700
  • 8a7d4cd66a Backoff on unavailable group coordinator retry backoff_coordinator_retry Dana Powers 2017-06-18 23:55:39 -0700
  • 12d740ed0d Update KafkaConsumer / KafkaProducer docstrings and defaults Dana Powers 2017-06-18 23:49:50 -0700
  • a11b63d81a Update per KIP-144 Dana Powers 2017-06-18 23:45:49 -0700
  • c12e04bc0c Use randomized exponential backoff policy for BrokerConnection Dana Powers 2016-06-19 22:27:10 -0700
  • bbbac3dc36 Fixup for #1085 -- only check for changed metadata on disconnected nodes Dana Powers 2017-06-18 23:18:41 -0700
  • 2a41fa1fe4 Deal with brokers that disappear, reappear with different IP address (#1085) Mike Fischer 2017-04-24 13:24:15 +0800
  • 26a810220a Do not test fetched_size with fetch_max_bytes since 0.11 brokers will return more data than 0.10 Dana Powers 2017-06-17 08:47:44 -0700
  • c5f1c6901f Increase max_buffer_size for test_large_messages Dana Powers 2017-06-17 08:46:54 -0700
  • b4f71229d0 Fix fetch_max_bytes=1 consumer integration test Dana Powers 2017-06-17 07:18:54 -0700
  • d127928e44 Use fixture hostname (dont assume localhost) Dana Powers 2017-06-17 07:10:03 -0700
  • 6b316c0971 Add 0.11.0.0 server resources (reduced offsets.topic.replication.factor=1) Dana Powers 2017-06-17 07:07:47 -0700
  • 707906263d Do not test fetched_size with fetch_max_bytes since 0.11 brokers will return more data than 0.10 0_11_0_0 Dana Powers 2017-06-17 08:47:44 -0700
  • e07aba87db Increase max_buffer_size for test_large_messages Dana Powers 2017-06-17 08:46:54 -0700
  • 82a9fb455d Fix fetch_max_bytes=1 consumer integration test Dana Powers 2017-06-17 07:18:54 -0700
  • 6be1b4baff Use fixture hostname (dont assume localhost) Dana Powers 2017-06-17 07:10:03 -0700
  • 7b4237733d Add 0.11.0.0 server resources (reduced offsets.topic.replication.factor=1) Dana Powers 2017-06-17 07:07:47 -0700
  • 97261f491d Describe consumer thread-safety Linus Wallgren 2017-05-18 22:49:20 +0200
  • 73d78bc76a Update exception docstring Andrew Kowalik 2017-05-04 10:47:20 -0700
  • 83f2d322a9 raise KafkaTimeoutException when flush times out Andrew Kowalik 2017-05-04 10:46:38 -0700
  • bb626dbffb Follow-up: support manual py26 testing; dont advertise 3.3 support Dana Powers 2017-06-16 23:05:17 -0700
  • b1a6d3301f Add kafka 0.10.2.1 into integration testing version (#1096) Jianbin Wei 2017-06-16 22:58:58 -0700
  • 72205c4692 pylint 1.7.0+ supports python 3.6 and merge py36 into common tstenv (#1095) Jianbin Wei 2017-05-03 14:44:19 -0700
  • a2b5ddc375 Improve error message when expiring batches in KafkaProducer (#1077) Dana Powers 2017-05-03 08:08:06 -0700
  • 83617b956d Warn dont raise on DNS lookup failures (#1091) Dana Powers 2017-05-03 08:06:59 -0700
  • 384420425c Ignore not-context-manager pylint error (#1092) Dana Powers 2017-04-29 11:36:35 -0700
  • 1d9f8c8172 Ignore not-context-manager pylint error pylint_fixup Dana Powers 2017-04-29 10:37:02 -0700
  • e31c18a968 Warn dont raise on DNS lookup failures warn_dns_error Dana Powers 2017-04-29 10:15:32 -0700
  • a8c93398af Improve error message when expiring batches in KafkaProducer batch_expiration_message Dana Powers 2017-04-12 22:44:00 -0700
  • 120410bcb4 Follow-up to #1068: remove not-implemented comments Dana Powers 2017-04-10 12:38:02 -0700
  • a503682ee6 readthedocs.io follow-up to #1074 for docs/ Dana Powers 2017-04-10 10:11:05 -0700
  • 5bcb333b3a Update RTD links with https / .io (#1074) Jeff Widman 2017-04-10 10:06:55 -0700
  • 04296994de Timeout idle connections via connections_max_idle_ms (#1068) Dana Powers 2017-04-10 10:06:46 -0700
  • 8ed5592d5a Update RTD links with https / .io update-rtd-links Jeff Widman 2017-04-09 22:00:24 -0700
  • 7c24135eaf Avoid multiple connection attempts when refreshing metadata (#1067) Dana Powers 2017-04-05 23:13:02 -0700
  • bb9642f04c Catch socket.errors when sending / recving bytes on wake socketpair (#1069) Dana Powers 2017-04-05 10:11:21 -0700
  • a4d4a7412e Catch socket.errors when sending / recving bytes on wake socketpair wake_socketpair_exceptions Dana Powers 2017-04-04 22:00:37 -0700
  • 4ff60ab842 Add support for connections_max_idle_ms timeout_idle_connections Dana Powers 2017-04-04 18:07:44 -0700
  • 9acbc6faf2 Move BrokerConnection node_id from config to attribute Dana Powers 2017-04-04 18:07:14 -0700
  • af244a4bff Avoid multiple connection attempts when refreshing metadata metadata_wait_for_connect Dana Powers 2017-04-04 16:31:13 -0700
  • d40d106c73 Fix poll() hyperlink in KafkaClient Jeff Widman 2017-03-29 14:17:58 -0700
  • acbb510b8d Update README: Prefer python-lz4 over lz4tools (#1057) Kirill Ignatev 2017-03-27 22:41:30 +0300
  • bee0bbe3af Fix typo (#1054) Jeff Widman 2017-03-27 12:40:30 -0700
  • 998147dae9 Bump version for development Dana Powers 2017-03-14 15:43:16 -0700
  • 0e24da3410 Release 1.3.3 1.3.3 Dana Powers 2017-03-14 13:36:40 -0700
  • 65ba8822b1 Derive all api classes from Request / Response base classes (#1030) Dana Powers 2017-03-14 13:34:37 -0700
  • a00f9ead16 Alter test skips: python-lz4 works on python26, but not pypy Dana Powers 2017-03-14 11:38:49 -0700
  • fea10d9c16 LZ4 support in kafka 0.8/0.9 does not accept a ContentSize header Dana Powers 2017-03-14 11:01:58 -0700
  • fb023fe85d Prefer python-lz4 over lz4f if available Dana Powers 2017-03-13 14:22:57 -0700
  • 3b899decb8 Free lz4 decompression context to avoid leak Dana Powers 2017-03-09 11:08:48 -0800
  • fd054aaea7 Alter test skips: python-lz4 works on python26, but not pypy leak_z4 Dana Powers 2017-03-14 11:38:49 -0700
  • 9ba21b8367 LZ4 support in kafka 0.8/0.9 does not accept a ContentSize header Dana Powers 2017-03-14 11:01:58 -0700
  • e775e05d65 Update changelog Dana Powers 2017-03-13 19:04:02 -0700
  • 47004bbd02 Avoid re-encoding for message crc check (#1027) Dana Powers 2017-03-13 16:41:38 -0700
  • 92a66e3009 Additional docstrings for autocommit close option Dana Powers 2017-03-13 16:39:53 -0700
  • 195df5fb98 Optionally skip auto-commit during consumer.close (#1031) Dana Powers 2017-03-13 16:39:23 -0700
  • 43820dfb93 Prefer python-lz4 over lz4f if available Dana Powers 2017-03-13 14:22:57 -0700
  • ce57dac0c6 Return copy of consumer subscription set (#1029) Dana Powers 2017-03-13 12:42:47 -0700
  • 894cfec656 Derive all api classes from Request / Response base classes request_response_classes Dana Powers 2017-03-12 19:57:36 -0700
  • 1730db6dc4 Return copy of subscription subscription_copy Dana Powers 2017-03-06 10:31:03 -0800
  • ae28c20131 Test that consumer.subscription() returns a copy Dana Powers 2017-03-13 10:31:40 -0700
  • 7afdb5b8ba Optionally skip auto-commit during consumer.close skip_autocommit_consumer_close Dana Powers 2017-03-06 10:30:10 -0800
  • 8cc77b1547 Avoid re-encoding for message crc check faster_validate_crc Dana Powers 2017-03-13 10:07:56 -0700
  • 844d8fe31f BrokerConnection.receive_bytes(data) -> response events receive_bytes_pipe Dana Powers 2017-01-07 10:52:01 -0800
  • 3745c64069 Add kafka.protocol.frame.KafkaBytes Dana Powers 2017-01-07 10:43:43 -0800
  • 899f11730d Fix kwarg handing in kafka.protocol.struct.Struct (#1025) Dana Powers 2017-03-09 15:12:27 -0800
  • bb709f4c14 Short-circuit group coordinator requests when NodeNotReady (#995) Dana Powers 2017-03-09 14:26:09 -0800
  • 6ef7675ba0 Avoid unknown coordinator after client poll (#1023) Dana Powers 2017-03-09 12:49:05 -0800
  • 23d1cc444d Free lz4 decompression context to avoid leak Dana Powers 2017-03-09 11:08:48 -0800
  • 218a9014b7 Add optional kwarg to ready and is_ready to disable metadata-priority logic (#1017) Dana Powers 2017-03-08 22:53:31 -0800
  • 05ad46aaf2 A few Sphinx documentation updates (#1019) Jeff Widman 2017-03-08 22:52:08 -0800
  • 1813d7d21e Fix integration test that requires consumer group Dana Powers 2017-03-07 16:27:06 -0800
  • c22473952b Update changelog Dana Powers 2017-03-07 14:50:20 -0800
  • 5a0e9715f4 Fixed couple of "leaks" when gc is disabled (#979) Max Baryshnikov 2017-02-07 22:31:06 +0300
  • 82d50f443e Fixup :meth: sphinx documentation for use in KafkaConsumer.rst etc Dana Powers 2017-03-07 12:25:30 -0800
  • a4338169d4 Add ClusterMetadata documentation Dana Powers 2017-03-07 11:33:23 -0800
  • 1810816b00 For 0.8.2, only attempt connection to coordinator if least_loaded_node succeeds Dana Powers 2017-03-07 11:32:36 -0800
  • 91cb3158e5 Fixup comment reference to _maybe_connect Dana Powers 2017-03-07 11:14:49 -0800
  • 6ad52f7c95 Recategorize some bugfix changes in docs; add PR 1016 Dana Powers 2017-03-06 16:15:23 -0800
  • 77e1ba36b3 Disable default consumer group (#1016) Dana Powers 2017-03-06 16:09:22 -0800
  • 634d24fa5b Tweak README docs to show use of consumer group (no longer default); clarify producer.flush Dana Powers 2017-03-06 16:08:33 -0800
  • 642bd67b85 Update changelog in preparation for release Dana Powers 2017-03-06 16:07:43 -0800
  • f8dc1ab792 Add python3.6 support to pypi metadata Dana Powers 2017-03-06 16:07:22 -0800
  • ebb6c3bd85 change default timeout of KafkaProducer.close() to threading.TIMEOUT_MAX gaosheng 2017-02-20 23:48:55 +0800
  • fb09c0aa72 Add client info logging re bootstrap; log connection attempts to balance with close Dana Powers 2017-03-06 15:16:45 -0800