openstack
/
deb-python-kafka
Code Issues Proposed changes

Commit Graph

  • 6bd1e1db57 Always include an error for logging when the coordinator is marked dead (#890) Dana Powers 2016-11-18 10:43:26 -0800
  • ff56bdbcc6 Args are optional in BrokerResponseError str (#889) Dana Powers 2016-11-18 10:15:39 -0800
  • 92ed46eee4 Always include an error for logging when the coordinator is marked dead coordinator_dead_error_logging Dana Powers 2016-11-18 09:20:41 -0800
  • 6c9f7280c5 :wPass timestamp into Message, not just mimic it (#875) Taras Voinarovskyi 2016-11-18 19:08:19 +0200
  • f71cfc4607 Always check for request timeouts (#887) Dana Powers 2016-11-18 09:07:53 -0800
  • da8d4c1e8b Args are optional in BrokerResponseError str kafka_error_str Dana Powers 2016-11-18 09:06:21 -0800
  • dc45935ec8 Also/continue to check for timeouts in BrokerConnection.recv() timeout_noresponse Dana Powers 2016-11-17 20:24:14 -0800
  • 0bf7ea0f67 Check for requests that timeout without causing a socket read/write event Dana Powers 2016-11-17 20:00:09 -0800
  • 57ea7e81dc typo (#883) sharego 2016-11-16 01:30:16 +0800
  • 43e0c38bf3 Update param in warning (#878) Dana Powers 2016-11-14 11:14:37 -0800
  • eb6801da35 Remove old design notes from Kafka 8 era (#876) Jeff Widman 2016-11-14 11:02:34 -0800
  • 8ac79fbe3d Fix typos (#874) Dana Powers 2016-11-14 11:01:34 -0800
  • cd74c1fe40 Fix typos Jeff Widman 2016-11-08 01:29:45 -0800
  • 13150a6151 Update param in warning Jeff Widman 2016-11-11 17:55:43 -0800
  • 77591afa78 Revert consumer iterators from max_poll_records (#856) Dana Powers 2016-10-24 11:24:16 -0700
  • d1745d8df5 Update docs 0_10_1_0 Dana Powers 2016-10-23 12:02:58 -0700
  • 221b58f3fa Move 0.10 integration testing to 0.10.1.0 Dana Powers 2016-10-23 12:01:27 -0700
  • 6fa0766584 Add resource files for 0.10.1.0 fixtures Dana Powers 2016-10-23 12:01:10 -0700
  • 45ab884a5c Revert consumer iterators from max_poll_records consumer_iterator Dana Powers 2016-10-23 11:59:40 -0700
  • 8de40a20d9 Fix murmur2 bug handling python2 bytes that do not ascii encode (#815) Dana Powers 2016-10-22 09:48:08 -0700
  • 613a402558 Update patch set 2 Gerrit User 3 2016-10-13 19:49:42 +0000
  • 49bc25e154 Update notes for submitted changes Gerrit Code Review 2016-10-13 19:49:42 +0000
  • 9bd10c4b1f Update patch set 2 Gerrit Code Review 2016-10-13 19:49:42 +0000
  • 105d922703 Update patch set 2 Gerrit User 3 2016-10-13 19:44:16 +0000
  • 0ba7742bb3 Update patch set 2 Gerrit User 6476 2016-10-13 19:44:06 +0000
  • 744b6680b3 Update patch set 2 Gerrit User 3 2016-10-13 19:32:03 +0000
  • 82a7aa0f12 Update patch set 2 Gerrit User 6476 2016-10-13 19:26:25 +0000
  • 9450a6bfff Bugfix on max_poll_records - TypeError: object of type NoneType has no len() Dana Powers 2016-10-04 10:10:10 -0700
  • c16e6b5e17 Update patch set 2 Gerrit User 3 2016-10-04 13:06:48 +0000
  • da0c67e36a Create patch set 2 Gerrit User 6476 2016-10-04 13:01:49 +0000
  • cf50bf2e36 Uploading to unstable Thomas Goirand 2016-10-04 13:29:59 +0200
  • 75899a8656 Update patch set 1 Gerrit User 3 2016-10-04 11:39:48 +0000
  • 83d55eb604 Create change Gerrit User 6476 2016-10-04 11:30:08 +0000
  • 02469d56c3 Uploading to unstable Thomas Goirand 2016-10-04 13:29:59 +0200
  • 9ee77dfdbc KAFKA-3007: KafkaConsumer max_poll_records (#831) Dana Powers 2016-09-28 12:39:34 -0700
  • b8717b4b79 Update Partitioners for use with KafkaProducer (#827) barrotsteindev 2016-09-28 20:30:32 +0300
  • 5c784890b6 Monkeypatch max_in_flight_requests_per_connection when checking broker version (#834) Dana Powers 2016-09-28 09:56:11 -0700
  • b0571957e7 Update patch set 1 Gerrit User 3 2016-09-26 18:03:21 +0000
  • f62b9dc48a Update notes for submitted changes Gerrit Code Review 2016-09-26 18:03:21 +0000
  • a3124f2d5f Update patch set 1 Gerrit Code Review 2016-09-26 18:03:21 +0000
  • de8f4eaa45 Update patch set 1 Gerrit User 3 2016-09-26 17:51:03 +0000
  • 3e6f0b55d9 Update patch set 1 Gerrit User 16896 2016-09-26 17:50:52 +0000
  • 40830c1fad Update patch set 1 Gerrit User 3 2016-09-26 17:47:49 +0000
  • 45e865e9e9 Create change Gerrit User 16896 2016-09-26 17:11:04 +0000
  • 0e192d68fa Mass changes Ondřej Nový 2016-09-26 19:10:56 +0200
  • 189ab3f197 Monkeypatch max_in_flight_requests_per_connection when checking broker version conn_check_version_max_in_flight Dana Powers 2016-09-24 13:33:54 -0700
  • db49c8fbdd Fixup iterators max_poll_records Dana Powers 2016-09-17 18:43:38 -0700
  • b05c8da262 more partial Dana Powers 2016-09-17 18:33:37 -0700
  • e70c7b271b Assert max_records > 0 Dana Powers 2016-09-17 15:22:21 -0700
  • 5b86640067 Optimizations -- use a message index instead of reslicing list; only send fetches when partition record fully consumed Dana Powers 2016-09-17 15:21:42 -0700
  • ae36423391 fix tests Dana Powers 2016-09-16 10:05:24 -0700
  • aed2750501 Greedy unpack messagesets; simplify fetch and consumer iterators -- just call poll() w/ 1 max record Dana Powers 2016-09-16 09:31:19 -0700
  • 6e3eddc267 First pass at max_poll_records Dana Powers 2016-08-21 15:03:15 -0700
  • 2a7aca1630 Fix message timestamp_type (#828) Josh Yudaken 2016-09-15 16:29:19 -0700
  • 1646edf7ff Added ssl_password config option to KafkaProducer class, identical to… (#830) kierkegaard13 2016-09-15 18:28:59 -0500
  • 91966af081 Update patch set 1 Gerrit User 3 2016-09-05 16:32:38 +0000
  • 5f784fceb8 Update notes for submitted changes Gerrit Code Review 2016-09-05 16:32:38 +0000
  • 272b0d44b0 Update patch set 1 Gerrit Code Review 2016-09-05 16:32:38 +0000
  • 844307b985 Update patch set 1 Gerrit User 3 2016-09-05 16:23:42 +0000
  • 6362cac40b Update patch set 1 Gerrit User 6476 2016-09-05 16:23:32 +0000
  • e1a53cd7b5 Update patch set 1 Gerrit User 3 2016-09-05 16:18:28 +0000
  • f7f3a8e2bd Create change Gerrit User 6476 2016-09-05 16:09:25 +0000
  • 3553552a82 Add a .gitreview file Thomas Goirand 2016-09-05 18:09:05 +0200
  • 1937ce59b4 from kafka import ConsumerRebalanceListener, OffsetAndMetadata Dana Powers 2016-09-04 09:26:41 -0700
  • 0cb1f1be70 Drop bytearray / str / unicode MurmurPartitioner tests -- no longer supported murmur2_ascii Dana Powers 2016-08-24 12:33:10 -0700
  • 546f4f530a Fix murmur2 handling of python2 bytes Dana Powers 2016-08-24 10:24:33 -0700
  • a60e71af16 Add test for murmur2 py2 bytes bug Dana Powers 2016-08-24 10:01:45 -0700
  • 7d31aa3978 Fix quota violation exception message (#809) Dana Powers 2016-08-20 17:39:26 -0700
  • 754ff8954e Improve KafkaProducer docstring re retries config Dana Powers 2016-08-20 17:41:45 -0700
  • e50d4dde3c Add comment for round robin partitioner with different subscriptions Dana Powers 2016-08-20 16:34:51 -0700
  • 047596ad17 Fix quota violation exception message sensor_quota_message Dana Powers 2016-08-20 16:15:52 -0700
  • e5c64874b4 Use 0.10.0.1 for integration tests (#803) Dana Powers 2016-08-11 17:58:34 -0700
  • 5da7f1ca17 Use new release 0.10.0.1 for 0.10 testing 0.10.0.1 Dana Powers 2016-08-11 15:19:06 -0700
  • b871d7548b Add 0.10.0.1 fixture resources Dana Powers 2016-08-05 14:20:07 -0700
  • 1662c632c5 Bump version for development Dana Powers 2016-08-11 15:15:18 -0700
  • 824677696a Fixed debian/gbp.conf to use debian/newton as packaging branch. Thomas Goirand 2016-08-11 11:51:48 +0200
  • 221fa65ac1 Patch Release 1.3.1 1.3.1 Dana Powers 2016-08-08 17:43:21 -0700
  • a71bee57df HOTFIX: Fix BrokerConnectionMetrics when sensors already exist (i.e., on reconnects) (#799) Dana Powers 2016-08-08 17:38:26 -0700
  • b19c51b5d8 HOTFIX: Fix BrokerConnectionMetrics when sensors already exist (i.e., on reconnects) conn_metrics_fix Dana Powers 2016-08-08 16:55:15 -0700
  • 6a8f0412bc Bump version for development Dana Powers 2016-08-04 21:50:49 -0700
  • 9c44ef39f0 Release 1.3.0 1.3.0 Dana Powers 2016-08-04 17:28:16 -0700
  • 79c9968ebc Dump fixture logs on failure Dana Powers 2016-08-04 20:21:57 -0700
  • f6d216856f Drain pending requests to the coordinator before initiating group rejoin (#798) Dana Powers 2016-08-04 20:09:13 -0700
  • aa07e9ca0d Drain pending requests to the coordinator before initiating group rejoin drain_pending_coordinator_requests Dana Powers 2016-08-04 18:32:30 -0700
  • d3d3ad8b74 Send combined size and payload bytes to socket to avoid potentially split packets with TCP_NODELAY (#797) Dana Powers 2016-08-04 18:30:45 -0700
  • 289e195094 Send combined size and payload bytes to socket to avoid potentially split packets with TCP_NODELAY combine_send_bytes Dana Powers 2016-08-04 17:35:04 -0700
  • b24a5c25ae Merge pull request #796 from dpkp/fixture_auto_ports Dana Powers 2016-08-04 17:19:35 -0700
  • 8d19caeb36 Dont include kafka.vendor in coverage fixture_auto_ports Dana Powers 2016-08-04 15:39:29 -0700
  • c061b9b648 Try to bind to a new port on fixture failure retries Dana Powers 2016-08-04 15:16:10 -0700
  • bccac7bca1 Change coordinator.needs_join_prepare -> coordinator.rejoining; fix consumer group test (#795) Dana Powers 2016-08-04 15:31:41 -0700
  • 68c8fa4ad0 Merge pull request #794 from dpkp/conn_metrics Dana Powers 2016-08-04 14:22:40 -0700
  • 025b69ef4a Instrument bufferpool-wait-ratio metric in KafkaProducer Dana Powers 2016-08-04 12:54:53 -0700
  • 460f0784a3 Instrument metrics in BrokerConnection Dana Powers 2016-08-04 12:21:40 -0700
  • af08b54875 Treat metric_group_prefix as config in KafkaConsumer Dana Powers 2016-08-04 12:19:46 -0700
  • a698162dc9 Metrics instance must be passed explicitly from KafkaConsumer to KafkaClient Dana Powers 2016-08-04 12:18:54 -0700
  • 035e8f058e Remove unused import from kafka.conn Dana Powers 2016-08-04 12:16:34 -0700
  • c572e8d6e2 Add BrokerConnection docstring with configuration parameters Dana Powers 2016-08-04 12:03:36 -0700
  • 3ed27c60ec Add connection-count to KafkaClient metrics Dana Powers 2016-08-04 12:02:24 -0700
  • a6b9b13507 Add connection-creation-rate / connection-close-rate to KafkaClientMetrics Dana Powers 2016-08-04 12:01:48 -0700
  • 3c9b1b6fc4 Fix misspelling of "password" (#793) Samuel Taylor 2016-08-04 14:48:12 -0500