openstack
/
deb-python-kafka
Code Issues Proposed changes

Commit Graph

  • b1e2a49e54 Patch Release 1.2.4 1.2.4 Dana Powers 2016-07-08 16:15:56 -0700
  • c921b2ac4c Update consumer_timeout_ms docstring per #749 Dana Powers 2016-07-08 16:04:09 -0700
  • 77971ac093 Merge pull request #752 from dpkp/compacted_offsets Dana Powers 2016-07-08 16:01:08 -0700
  • 7b5ade10a5 Use explicit subscription state flag to handle seek() during message iteration compacted_offsets Dana Powers 2016-07-08 15:06:37 -0700
  • 003bb0a830 Fix consumer iteration on compacted topics Dana Powers 2016-07-08 14:45:36 -0700
  • 58991c5fa2 Add ssl_password to default_config dicts. Send ssl_password when loading cert chains (#750) Ashley McKemie 2016-07-08 09:43:27 -0500
  • 455001d3a8 Push out one more patch for 1.2.3 release 1.2.3 Dana Powers 2016-07-05 23:05:04 -0700
  • 75ee7fd06d Avoid AttributeErrors in _unregister_cleanup (#747) Dana Powers 2016-07-05 22:59:03 -0700
  • f9abba4a63 Avoid AttributeErrors in _unregister_cleanup 741 Dana Powers 2016-07-05 18:38:48 -0700
  • 114bfa8767 Patch Release 1.2.3 Dana Powers 2016-07-02 13:16:06 -0700
  • 6b5a068799 Randomize order of topics/partitions processed by fetcher to improve balance (#732) Dana Powers 2016-06-29 11:20:08 -0700
  • db47136671 allow client.check_version timeout to be set in Producer and Consumer constructors (#647) eastlondoner 2016-06-29 18:49:28 +0100
  • 229ac5d1c9 Wakeup socket optimizations (#740) Dana Powers 2016-06-26 15:07:10 -0700
  • 13715b4e3f Wakeup socket optimizations no_sleep_til_brooklyn Dana Powers 2016-06-26 12:29:02 -0700
  • b2bc1f0ed7 assert will be disabled by "python -O" (#736) tyronecai 2016-06-23 23:01:38 +0800
  • bb2a54116f Bump version for development Dana Powers 2016-06-21 22:23:53 -0700
  • 47c5045781 Patch Release 1.2.2 1.2.2 Dana Powers 2016-06-21 14:44:01 -0700
  • ccbb189c02 Clarify timeout unit (#734) ms7s 2016-06-21 17:28:59 +0200
  • cbcb4a6f85 Avoid busy poll during metadata refresh failure with retry_backoff_ms (#733) Dana Powers 2016-06-20 19:17:49 -0700
  • 06abc63522 Avoid busy poll during metadata refresh failure with retry_backoff_ms metadata_refresh_backoff Dana Powers 2016-06-20 09:23:07 -0700
  • 38d89d9094 Randomize order of topics/partitions processed by fetcher to improve balance fetcher_randomize_order Dana Powers 2016-06-19 09:26:43 -0700
  • 461ccbd9ec check_version should scan nodes until version found or timeout (#731) Dana Powers 2016-06-19 08:26:30 -0700
  • 22e1c7ebdc KakfaClient.check_version: Scan all brokers until a version is identified or timeout check_version Dana Powers 2016-06-18 16:48:57 -0700
  • 915466a9fc Always process pending MetadataRequest in conn.check_version Dana Powers 2016-06-18 16:43:57 -0700
  • 8818987162 Mute all connection logging during conn.check_version Dana Powers 2016-06-18 16:43:20 -0700
  • 0b5a49e58d Update KafkaClient.least_loaded_node (#730) Dana Powers 2016-06-18 23:18:42 -0700
  • 66f3ce81a2 Update KafkaClient.least_loaded_node least_loaded_node Dana Powers 2016-06-18 16:32:01 -0700
  • 6271c02c6e Use weakref when registering a producer.close atexit to fix normal gc (#728) Dana Powers 2016-06-18 14:51:23 -0700
  • 6d3f31d276 Use weakref when registering a producer.close atexit to fix normal gc at_exit_weakref Dana Powers 2016-06-17 09:03:52 -0700
  • de7eef4718 Test that del(producer) terminates async thread Dana Powers 2016-06-17 10:11:08 -0700
  • 5b9c55817b Close selector when closing the client connection to fix fd leak. (#729) Michael Smith 2016-06-17 14:24:00 -0700
  • 1e532c6740 tweak spelling mistake (#719) steve8918 2016-06-17 10:44:06 -0700
  • 81860eeea1 Rearrange connection tests to separate legacy KafkaConnection Dana Powers 2016-06-04 16:49:38 -0700
  • 2afe09e7c1 Bump version for development Dana Powers 2016-06-01 17:47:56 -0700
  • 21dae47b38 Patch Release 1.2.1 1.2.1 Dana Powers 2016-06-01 16:55:06 -0700
  • 8805d30b78 Fix regression in MessageSet decoding wrt PartialMessages (#716) Dana Powers 2016-06-01 16:49:17 -0700
  • 644a1141b0 Catch response decode errors and log details (#715) Dana Powers 2016-06-01 16:48:43 -0700
  • ed85c58726 Fix bug in MessageSet decoding that crashed multi-partition FetchResponse partial_messages Dana Powers 2016-06-01 15:43:02 -0700
  • 4ed0453b53 Test decoding messagesets with partial messages Dana Powers 2016-06-01 14:34:45 -0700
  • ebaa5b6eb6 Catch response decode errors and log details decode_errors Dana Powers 2016-06-01 09:24:53 -0700
  • 007b2e3836 Fix Legacy support url (#712) Jonas Gröger 2016-06-01 18:23:50 +0200
  • 3a971ea95e Update docs/index.rst re 0.10 broker support Dana Powers 2016-05-24 14:30:24 -0700
  • 5f90d436d2 Bump version for development Dana Powers 2016-05-24 14:31:55 -0700
  • fea254f998 Release 1.2.0 1.2.0 Dana Powers 2016-05-24 13:24:01 -0700
  • 8346ca4073 Update changelog for 1.2.0 release Dana Powers 2016-05-24 13:23:53 -0700
  • fa704555df Update README re 0.10 brokers Dana Powers 2016-05-24 13:21:04 -0700
  • 21fe199c7b Update compatibility for 0.10 kafka release Dana Powers 2016-05-24 13:18:30 -0700
  • a673b1fc75 Add kafka 0.10.0.0 to test list Dana Powers 2016-05-24 11:02:33 -0700
  • 38cb0bd40e Disabling travis deploys -- relying on manual uploads for now Dana Powers 2016-05-24 11:02:10 -0700
  • cc9ed8b96f KAFKA-3388: Fix expiration of batches sitting in the accumulator (#699) Dana Powers 2016-05-22 22:07:33 -0700
  • b6d28b8694 KAFKA-3388: Fix expiration of batches sitting in the accumulator KAFKA-3388 Dana Powers 2016-05-22 19:37:15 -0700
  • b000303045 KAFKA-3197: when max.in.flight.request.per.connection = 1, attempt to guarantee ordering (#698) Dana Powers 2016-05-22 19:21:35 -0700
  • 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 -0700
  • 42293725e5 Dont use soon-to-be-reserved keyword await as function name (FutureProduceResult) (#697) Dana Powers 2016-05-22 17:16:20 -0700
  • 77cb35078a Fix socket leaks in KafkaClient (#696) Dana Powers 2016-05-22 17:14:43 -0700
  • 1d4251a9ef Use standard LZ4 framing for v1 messages / kafka 0.10 (#695) Dana Powers 2016-05-22 17:14:03 -0700
  • c7b7be110f Dont use soon-to-be-reserved keyword await as function name (FutureProduceResult) await_reserved Dana Powers 2016-05-22 16:15:56 -0700
  • 36794db6e7 Dont warn on socket disconnections caused by KafkaClient.close() fix_leaks Dana Powers 2016-05-22 15:19:51 -0700
  • 412ebe4496 Cleanup unneeded bootstrap connection to avoid leak in KafkaClient Dana Powers 2016-05-22 15:19:17 -0700
  • 355859ba16 Update lz4 codec tests lz4_0_10 Dana Powers 2016-05-22 13:31:23 -0700
  • 2ac8503647 Cleanup wakeup socketpair on close to avoid leak in KafkaClient Dana Powers 2016-05-22 15:18:21 -0700
  • 4cbc1e3374 lz4f does not support easy incremental decompression - raise RuntimeError Dana Powers 2016-05-22 15:02:07 -0700
  • 6f651c9e9f LZ4 framing fixed in 0.10 / message v1 -- retain broken lz4 code for compatibility Dana Powers 2016-05-22 12:46:15 -0700
  • 96530f6a9c Use Fetch/Produce API v2 for brokers >= 0.10 (uses message format v1) (#694) Dana Powers 2016-05-22 12:41:17 -0700
  • 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 -0700
  • 7941a2ac7e Merge pull request #693 from dpkp/message_format_v1 Dana Powers 2016-05-22 10:28:56 -0700
  • aa5bde6ac3 Add some simple message protocol tests message_format_v1 Dana Powers 2016-05-22 00:17:40 -0700
  • 54eb2641ec Rename legacy protocol tests Dana Powers 2016-05-21 23:41:25 -0700
  • 7719946d74 Improve consumer group test loop Dana Powers 2016-05-21 23:30:36 -0700
  • 795cb9b29f KAFKA-3025: Message v1 -- add timetamp and use relative offset in compressed messagesets Dana Powers 2016-05-22 00:31:16 -0700
  • 7f4a9361ea Always pass encoded message bytes to MessageSet.encode() Dana Powers 2016-05-21 21:43:44 -0700
  • f2991be614 raise ValueError on protocol encode/decode errors Dana Powers 2016-05-21 21:25:55 -0700
  • 329af06279 d/rules: Changed UPSTREAM_GIT protocol to https Ondřej Nový 2016-05-19 21:18:36 +0200
  • 92f859d8da Add CRL support to SSL support (#683) Vincent Bernat 2016-05-19 16:19:34 +0200
  • 254dcacb28 Fixup BrokerConnection check_version strict error checking: 0.9 will fail with CorrelationIdError Dana Powers 2016-05-17 07:23:37 -0700
  • d7fa0731a0 supplement socket.gaierror exception in BrokerConnection.connect() (#687) Erik Beebe 2016-05-17 09:04:05 -0500
  • a7e9dfc405 kafka/conn: use original hostname for SSL checks (#682) Vincent Bernat 2016-05-17 15:55:12 +0200
  • 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 -0400
  • 0684302d8f Merge pull request #679 from zackdever/kafka-PR-1265-bugfix Zack Dever 2016-05-03 18:21:14 -0700
  • 416f50b6f7 small bug fix in Sensor Zack Dever 2016-05-03 17:43:50 -0700
  • d401bde9ed Merge pull request #678 from dpkp/check_version_0_10 Dana Powers 2016-05-03 17:35:59 -0700
  • 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 -0700
  • 874f4874a7 Patch release: 1.1.1 1.1.1 Dana Powers 2016-04-25 22:52:11 -0700
  • 5b393ac2b5 Merge pull request #671 from dpkp/disconnects Dana Powers 2016-04-25 22:33:19 -0700
  • fa59d4da59 Improve socket disconnect handling disconnects Dana Powers 2016-04-25 18:59:37 -0700
  • 959e57fb7d Disable standard metadata refresh hook during bootstrap Dana Powers 2016-04-25 18:58:40 -0700
  • 0b664ff375 Add disconnected socket tests for conn.recv() Dana Powers 2016-04-25 21:45:01 -0700
  • 2d759452cf Rename mocked socket as _socket in test_conn Dana Powers 2016-04-25 21:43:58 -0700
  • 161fa6d76b handle unexpected reads in client_async James Brown 2016-04-25 10:56:58 -0700
  • 22dd002800 Merge pull request #670 from zackdever/predictable-future Dana Powers 2016-04-25 16:27:37 -0700
  • c7564d2397 Allow setting host interface in KafkaFixture.instance Dana Powers 2016-04-25 13:39:07 -0700
  • 87e71b4e78 enable errors on callbacks in testing. fix broken test. Zack Dever 2016-04-25 14:48:50 -0700
  • 0300edb353 use the same logic for callbacks regardless of is_done status Zack Dever 2016-04-25 14:22:51 -0700
  • aefafd270a Fix throttle_time_ms sensor Zack Dever 2016-04-25 13:39:42 -0700
  • 57ae06f1e5 Build universal wheels - kafka-python is compatible with both py2 and py3 Dana Powers 2016-04-25 13:35:46 -0700
  • 715bbb436e Avoid some exceptions in Coordinator.__del__ (#668) Dana Powers 2016-04-25 13:12:43 -0700
  • 37cffc3327 Avoid some exceptions in Coordinator.__del__ coordinator_del Dana Powers 2016-04-25 11:59:38 -0700
  • 1bc2ce0778 Bump version for development Dana Powers 2016-04-25 12:01:47 -0700
  • dcd369ed6a Fix hyperlinks in README to fix pypi rendering 1.1.0 Dana Powers 2016-04-24 23:38:28 -0700
  • be83420636 Release 1.1.0 Dana Powers 2016-04-24 23:03:56 -0700