openstack/deb-python-kafka
Code Issues Proposed changes

Commit Graph

  • ebaa5b6eb6 Catch response decode errors and log details decode_errors Dana Powers 2016-06-01 09:24:53 -07:00
  • 007b2e3836 Fix Legacy support url (#712) Jonas Gröger 2016-06-01 18:23:50 +02:00
  • 3a971ea95e Update docs/index.rst re 0.10 broker support Dana Powers 2016-05-24 14:30:24 -07:00
  • 5f90d436d2 Bump version for development Dana Powers 2016-05-24 14:31:55 -07:00
  • fea254f998 Release 1.2.0 1.2.0 Dana Powers 2016-05-24 13:24:01 -07:00
  • 8346ca4073 Update changelog for 1.2.0 release Dana Powers 2016-05-24 13:23:53 -07:00
  • fa704555df Update README re 0.10 brokers Dana Powers 2016-05-24 13:21:04 -07:00
  • 21fe199c7b Update compatibility for 0.10 kafka release Dana Powers 2016-05-24 13:18:30 -07:00
  • a673b1fc75 Add kafka 0.10.0.0 to test list Dana Powers 2016-05-24 11:02:33 -07:00
  • 38cb0bd40e Disabling travis deploys -- relying on manual uploads for now Dana Powers 2016-05-24 11:02:10 -07:00
  • cc9ed8b96f KAFKA-3388: Fix expiration of batches sitting in the accumulator (#699) Dana Powers 2016-05-22 22:07:33 -07:00
  • b6d28b8694 KAFKA-3388: Fix expiration of batches sitting in the accumulator KAFKA-3388 Dana Powers 2016-05-22 19:37:15 -07:00
  • b000303045 KAFKA-3197: when max.in.flight.request.per.connection = 1, attempt to guarantee ordering (#698) Dana Powers 2016-05-22 19:21:35 -07:00
  • b2a91ab8d8 KAFKA-3197: when max.in.flight.request.per.connection = 1, attempt to guarantee ordering KAFKA-3197 Dana Powers 2016-05-22 18:10:37 -07:00
  • 42293725e5 Dont use soon-to-be-reserved keyword await as function name (FutureProduceResult) (#697) Dana Powers 2016-05-22 17:16:20 -07:00
  • 77cb35078a Fix socket leaks in KafkaClient (#696) Dana Powers 2016-05-22 17:14:43 -07:00
  • 1d4251a9ef Use standard LZ4 framing for v1 messages / kafka 0.10 (#695) Dana Powers 2016-05-22 17:14:03 -07:00
  • c7b7be110f Dont use soon-to-be-reserved keyword await as function name (FutureProduceResult) await_reserved Dana Powers 2016-05-22 16:15:56 -07:00
  • 36794db6e7 Dont warn on socket disconnections caused by KafkaClient.close() fix_leaks Dana Powers 2016-05-22 15:19:51 -07:00
  • 412ebe4496 Cleanup unneeded bootstrap connection to avoid leak in KafkaClient Dana Powers 2016-05-22 15:19:17 -07:00
  • 355859ba16 Update lz4 codec tests lz4_0_10 Dana Powers 2016-05-22 13:31:23 -07:00
  • 2ac8503647 Cleanup wakeup socketpair on close to avoid leak in KafkaClient Dana Powers 2016-05-22 15:18:21 -07:00
  • 4cbc1e3374 lz4f does not support easy incremental decompression - raise RuntimeError Dana Powers 2016-05-22 15:02:07 -07:00
  • 6f651c9e9f LZ4 framing fixed in 0.10 / message v1 -- retain broken lz4 code for compatibility Dana Powers 2016-05-22 12:46:15 -07:00
  • 96530f6a9c Use Fetch/Produce API v2 for brokers >= 0.10 (uses message format v1) (#694) Dana Powers 2016-05-22 12:41:17 -07:00
  • c9bff0701e Use Fetch/Produce API v2 for brokers >= 0.10 (uses message format v1) produce_fetch_v2 Dana Powers 2016-05-22 11:35:26 -07:00
  • 7941a2ac7e Merge pull request #693 from dpkp/message_format_v1 Dana Powers 2016-05-22 10:28:56 -07:00
  • aa5bde6ac3 Add some simple message protocol tests message_format_v1 Dana Powers 2016-05-22 00:17:40 -07:00
  • 54eb2641ec Rename legacy protocol tests Dana Powers 2016-05-21 23:41:25 -07:00
  • 7719946d74 Improve consumer group test loop Dana Powers 2016-05-21 23:30:36 -07:00
  • 795cb9b29f KAFKA-3025: Message v1 -- add timetamp and use relative offset in compressed messagesets Dana Powers 2016-05-22 00:31:16 -07:00
  • 7f4a9361ea Always pass encoded message bytes to MessageSet.encode() Dana Powers 2016-05-21 21:43:44 -07:00
  • f2991be614 raise ValueError on protocol encode/decode errors Dana Powers 2016-05-21 21:25:55 -07:00
  • 329af06279 d/rules: Changed UPSTREAM_GIT protocol to https Ondřej Nový 2016-05-19 21:18:36 +02:00
  • 92f859d8da Add CRL support to SSL support (#683) Vincent Bernat 2016-05-19 16:19:34 +02:00
  • 254dcacb28 Fixup BrokerConnection check_version strict error checking: 0.9 will fail with CorrelationIdError Dana Powers 2016-05-17 07:23:37 -07:00
  • d7fa0731a0 supplement socket.gaierror exception in BrokerConnection.connect() (#687) Erik Beebe 2016-05-17 09:04:05 -05:00
  • a7e9dfc405 kafka/conn: use original hostname for SSL checks (#682) Vincent Bernat 2016-05-17 15:55:12 +02:00
  • 2c9930dea4 * [SimpleConsumer] Fix legacy SimpleConsumer when using compressed messages* [Legacy Protocol] Update legacy protocol to handle compressed messages Paul Cavallaro 2016-05-10 11:34:06 -04:00
  • 0684302d8f Merge pull request #679 from zackdever/kafka-PR-1265-bugfix Zack Dever 2016-05-03 18:21:14 -07:00
  • 416f50b6f7 small bug fix in Sensor Zack Dever 2016-05-03 17:43:50 -07:00
  • d401bde9ed Merge pull request #678 from dpkp/check_version_0_10 Dana Powers 2016-05-03 17:35:59 -07:00
  • a3b7dca1b0 Add protocol support for ApiVersionRequest; identify 0.10 brokers in check_version check_version_0_10 Dana Powers 2016-05-02 20:59:05 -07:00
  • 874f4874a7 Patch release: 1.1.1 1.1.1 Dana Powers 2016-04-25 22:52:11 -07:00
  • 5b393ac2b5 Merge pull request #671 from dpkp/disconnects Dana Powers 2016-04-25 22:33:19 -07:00
  • fa59d4da59 Improve socket disconnect handling disconnects Dana Powers 2016-04-25 18:59:37 -07:00
  • 959e57fb7d Disable standard metadata refresh hook during bootstrap Dana Powers 2016-04-25 18:58:40 -07:00
  • 0b664ff375 Add disconnected socket tests for conn.recv() Dana Powers 2016-04-25 21:45:01 -07:00
  • 2d759452cf Rename mocked socket as _socket in test_conn Dana Powers 2016-04-25 21:43:58 -07:00
  • 161fa6d76b handle unexpected reads in client_async James Brown 2016-04-25 10:56:58 -07:00
  • 22dd002800 Merge pull request #670 from zackdever/predictable-future Dana Powers 2016-04-25 16:27:37 -07:00
  • c7564d2397 Allow setting host interface in KafkaFixture.instance Dana Powers 2016-04-25 13:39:07 -07:00
  • 87e71b4e78 enable errors on callbacks in testing. fix broken test. Zack Dever 2016-04-25 14:48:50 -07:00
  • 0300edb353 use the same logic for callbacks regardless of is_done status Zack Dever 2016-04-25 14:22:51 -07:00
  • aefafd270a Fix throttle_time_ms sensor Zack Dever 2016-04-25 13:39:42 -07:00
  • 57ae06f1e5 Build universal wheels - kafka-python is compatible with both py2 and py3 Dana Powers 2016-04-25 13:35:46 -07:00
  • 715bbb436e Avoid some exceptions in Coordinator.__del__ (#668) Dana Powers 2016-04-25 13:12:43 -07:00
  • 37cffc3327 Avoid some exceptions in Coordinator.__del__ coordinator_del Dana Powers 2016-04-25 11:59:38 -07:00
  • 1bc2ce0778 Bump version for development Dana Powers 2016-04-25 12:01:47 -07:00
  • dcd369ed6a Fix hyperlinks in README to fix pypi rendering 1.1.0 Dana Powers 2016-04-24 23:38:28 -07:00
  • be83420636 Release 1.1.0 Dana Powers 2016-04-24 23:03:56 -07:00
  • dd589c320d Update changelogs for 1.1.0 release Dana Powers 2016-04-24 23:03:29 -07:00
  • b06e42329e Merge branch 'EasyPost-better_ipv6' Dana Powers 2016-04-24 16:31:02 -07:00
  • 434802dfa1 More thorough IPv6 support that uses getaddrinfo to resolve names James Brown 2016-04-11 16:52:35 -07:00
  • a12be0af80 Wait for future.is_done in check_version (fix for windows) Dana Powers 2016-04-24 15:37:59 -07:00
  • 56ba6075ac Merge pull request #649 from jayalane/master Dana Powers 2016-04-24 08:27:22 -07:00
  • 86130cbbab as per code review Chris Lane 2016-04-14 20:45:26 -07:00
  • cf679ae387 Merge pull request #637 from zackdever/metrics Zack Dever 2016-04-14 11:02:01 -07:00
  • 92436c0ec0 to squelch the __del issue Chris Lane 2016-04-13 19:54:55 -07:00
  • e2b340c440 instrument metrics for fetch requests Zack Dever 2016-04-13 13:52:36 -07:00
  • 81dc89a4fd trying to use locks a little less. still not ideal. Zack Dever 2016-04-11 15:19:56 -07:00
  • 00d1a8b5f9 Changing some commented out metrics to avoid future gotchas. Zack Dever 2016-04-07 17:50:37 -07:00
  • e010669b60 Beginnings of metrics instrumentation in kafka consumer. Zack Dever 2016-04-07 17:46:55 -07:00
  • caf4cdefe4 Basic dictionary reporter in place of the java JMX reporter. Zack Dever 2016-04-07 18:39:37 -07:00
  • 64e9cebfa5 Kafka metrics java port. No reporters or instrumentation. Zack Dever 2016-04-07 18:36:14 -07:00
  • 0c94b83a2d Merge pull request #621 from dpkp/ssl_support Dana Powers 2016-04-09 10:29:08 -07:00
  • a8b6e53eae Standards-Version is 3.9.8 now (no change) Ondřej Nový 2016-04-09 19:27:28 +02:00
  • 097198ccea Attempt to add ssl support to kafka fixtures Dana Powers 2016-04-04 19:54:22 -07:00
  • 01f03656cc Add SSL configuration kwargs to KafkaClient, KafkaConsumer, KafkaProducer Dana Powers 2016-04-04 19:54:01 -07:00
  • d1bfccfce1 Check for pending ssl bytes in KafkaClient loop Dana Powers 2016-04-04 19:52:09 -07:00
  • 688b7755a9 Update conn fixture to check for HANDSHAKE state Dana Powers 2016-04-04 18:57:32 -07:00
  • 5b3042cb6d Handle SSL HANDSHAKE state in KafkaClient state change handler Dana Powers 2016-04-09 09:24:05 -07:00
  • ffd1423a81 Add ssl support to BrokerConnection Dana Powers 2016-04-04 19:50:45 -07:00
  • cda2d59da4 Merge pull request #640 from dpkp/selectors Dana Powers 2016-04-09 08:48:51 -07:00
  • 237bd730fd Use selectors module in KafkaClient Dana Powers 2016-04-07 16:26:22 -07:00
  • 26260d4a04 Vendor selectors34 module Dana Powers 2016-04-07 16:25:28 -07:00
  • 810f08b799 Merge pull request #639 from dpkp/conn_state_callback Dana Powers 2016-04-08 17:00:47 -07:00
  • 897ca39991 Add state_change_callback to bootstrap connection Dana Powers 2016-04-08 15:36:18 -07:00
  • 85261e02e3 Drop bootstrap connection once first normal broker is connected Dana Powers 2016-04-08 15:43:47 -07:00
  • 3e70e17fa9 Add private _refresh_on_disconnects flag to KafkaClient Dana Powers 2016-04-08 15:40:42 -07:00
  • 1435356cc5 Move state logic from KafkaClient._maybe_connect to _conn_state_change as callback Dana Powers 2016-04-07 22:21:57 -07:00
  • 5368c81cf6 Add state_change_callback to BrokerConnection Dana Powers 2016-04-07 21:54:49 -07:00
  • 45b2c99690 Move check_version() logic to BrokerConnection Dana Powers 2016-04-07 23:53:22 -07:00
  • 4323e5c21c Split test_ready to test_is_ready Dana Powers 2016-04-07 22:13:00 -07:00
  • 2037d5f735 Speedup some failover tests w/ shorter SimpleClient timeout Dana Powers 2016-04-07 21:31:57 -07:00
  • af36c6ddd0 Reduce batch time in producer integration test (speedup test) Dana Powers 2016-04-07 21:30:35 -07:00
  • 6662d1e624 Default sleep=True in client.poll Dana Powers 2016-04-07 16:13:50 -07:00
  • 9b71b0da62 Make _wake_r socket non-blocking; drop select from _clear_wake_fd Dana Powers 2016-04-07 16:23:24 -07:00
  • ed053660a4 More _maybe_connect refactoring -- preparing for selectors Dana Powers 2016-04-07 16:22:32 -07:00
  • ebbdf8abc2 Can no longer have coordinator_id if coordinator_unknown() Dana Powers 2016-04-07 16:20:07 -07:00