openstack/deb-python-kafka
Code Issues Proposed changes

Commit Graph

  • 13150a6151 Update param in warning Jeff Widman 2016-11-11 17:55:43 -08:00
  • 77591afa78 Revert consumer iterators from max_poll_records (#856) Dana Powers 2016-10-24 11:24:16 -07:00
  • d1745d8df5 Update docs 0_10_1_0 Dana Powers 2016-10-23 12:02:58 -07:00
  • 221b58f3fa Move 0.10 integration testing to 0.10.1.0 Dana Powers 2016-10-23 12:01:27 -07:00
  • 6fa0766584 Add resource files for 0.10.1.0 fixtures Dana Powers 2016-10-23 12:01:10 -07:00
  • 45ab884a5c Revert consumer iterators from max_poll_records consumer_iterator Dana Powers 2016-10-23 11:59:40 -07:00
  • 8de40a20d9 Fix murmur2 bug handling python2 bytes that do not ascii encode (#815) Dana Powers 2016-10-22 09:48:08 -07:00
  • 9450a6bfff Bugfix on max_poll_records - TypeError: object of type NoneType has no len() Dana Powers 2016-10-04 10:10:10 -07:00
  • cf50bf2e36 Uploading to unstable Thomas Goirand 2016-10-04 13:29:59 +02:00
  • 9ee77dfdbc KAFKA-3007: KafkaConsumer max_poll_records (#831) Dana Powers 2016-09-28 12:39:34 -07:00
  • b8717b4b79 Update Partitioners for use with KafkaProducer (#827) barrotsteindev 2016-09-28 20:30:32 +03:00
  • 5c784890b6 Monkeypatch max_in_flight_requests_per_connection when checking broker version (#834) Dana Powers 2016-09-28 09:56:11 -07:00
  • 0e192d68fa Mass changes Ondřej Nový 2016-09-26 19:10:56 +02:00
  • 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 -07:00
  • db49c8fbdd Fixup iterators max_poll_records Dana Powers 2016-09-17 18:43:38 -07:00
  • b05c8da262 more partial Dana Powers 2016-09-17 18:33:37 -07:00
  • e70c7b271b Assert max_records > 0 Dana Powers 2016-09-17 15:22:21 -07:00
  • 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 -07:00
  • ae36423391 fix tests Dana Powers 2016-09-16 10:05:24 -07:00
  • aed2750501 Greedy unpack messagesets; simplify fetch and consumer iterators -- just call poll() w/ 1 max record Dana Powers 2016-09-16 09:31:19 -07:00
  • 6e3eddc267 First pass at max_poll_records Dana Powers 2016-08-21 15:03:15 -07:00
  • 2a7aca1630 Fix message timestamp_type (#828) Josh Yudaken 2016-09-15 16:29:19 -07:00
  • 1646edf7ff Added ssl_password config option to KafkaProducer class, identical to… (#830) kierkegaard13 2016-09-15 18:28:59 -05:00
  • 3553552a82 Add a .gitreview file Thomas Goirand 2016-09-05 18:09:05 +02:00
  • 1937ce59b4 from kafka import ConsumerRebalanceListener, OffsetAndMetadata Dana Powers 2016-09-04 09:26:41 -07:00
  • 0cb1f1be70 Drop bytearray / str / unicode MurmurPartitioner tests -- no longer supported murmur2_ascii Dana Powers 2016-08-24 12:33:10 -07:00
  • 546f4f530a Fix murmur2 handling of python2 bytes Dana Powers 2016-08-24 10:24:33 -07:00
  • a60e71af16 Add test for murmur2 py2 bytes bug Dana Powers 2016-08-24 10:01:45 -07:00
  • 7d31aa3978 Fix quota violation exception message (#809) Dana Powers 2016-08-20 17:39:26 -07:00
  • 754ff8954e Improve KafkaProducer docstring re retries config Dana Powers 2016-08-20 17:41:45 -07:00
  • e50d4dde3c Add comment for round robin partitioner with different subscriptions Dana Powers 2016-08-20 16:34:51 -07:00
  • 047596ad17 Fix quota violation exception message sensor_quota_message Dana Powers 2016-08-20 16:15:52 -07:00
  • e5c64874b4 Use 0.10.0.1 for integration tests (#803) Dana Powers 2016-08-11 17:58:34 -07:00
  • 5da7f1ca17 Use new release 0.10.0.1 for 0.10 testing 0.10.0.1 Dana Powers 2016-08-11 15:19:06 -07:00
  • b871d7548b Add 0.10.0.1 fixture resources Dana Powers 2016-08-05 14:20:07 -07:00
  • 1662c632c5 Bump version for development Dana Powers 2016-08-11 15:15:18 -07:00
  • 824677696a Fixed debian/gbp.conf to use debian/newton as packaging branch. Thomas Goirand 2016-08-11 11:51:48 +02:00
  • 221fa65ac1 Patch Release 1.3.1 1.3.1 Dana Powers 2016-08-08 17:43:21 -07:00
  • a71bee57df HOTFIX: Fix BrokerConnectionMetrics when sensors already exist (i.e., on reconnects) (#799) Dana Powers 2016-08-08 17:38:26 -07:00
  • b19c51b5d8 HOTFIX: Fix BrokerConnectionMetrics when sensors already exist (i.e., on reconnects) conn_metrics_fix Dana Powers 2016-08-08 16:55:15 -07:00
  • 6a8f0412bc Bump version for development Dana Powers 2016-08-04 21:50:49 -07:00
  • 9c44ef39f0 Release 1.3.0 1.3.0 Dana Powers 2016-08-04 17:28:16 -07:00
  • 79c9968ebc Dump fixture logs on failure Dana Powers 2016-08-04 20:21:57 -07:00
  • f6d216856f Drain pending requests to the coordinator before initiating group rejoin (#798) Dana Powers 2016-08-04 20:09:13 -07:00
  • aa07e9ca0d Drain pending requests to the coordinator before initiating group rejoin drain_pending_coordinator_requests Dana Powers 2016-08-04 18:32:30 -07:00
  • 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 -07:00
  • 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 -07:00
  • b24a5c25ae Merge pull request #796 from dpkp/fixture_auto_ports Dana Powers 2016-08-04 17:19:35 -07:00
  • 8d19caeb36 Dont include kafka.vendor in coverage fixture_auto_ports Dana Powers 2016-08-04 15:39:29 -07:00
  • c061b9b648 Try to bind to a new port on fixture failure retries Dana Powers 2016-08-04 15:16:10 -07:00
  • bccac7bca1 Change coordinator.needs_join_prepare -> coordinator.rejoining; fix consumer group test (#795) Dana Powers 2016-08-04 15:31:41 -07:00
  • 68c8fa4ad0 Merge pull request #794 from dpkp/conn_metrics Dana Powers 2016-08-04 14:22:40 -07:00
  • 025b69ef4a Instrument bufferpool-wait-ratio metric in KafkaProducer Dana Powers 2016-08-04 12:54:53 -07:00
  • 460f0784a3 Instrument metrics in BrokerConnection Dana Powers 2016-08-04 12:21:40 -07:00
  • af08b54875 Treat metric_group_prefix as config in KafkaConsumer Dana Powers 2016-08-04 12:19:46 -07:00
  • a698162dc9 Metrics instance must be passed explicitly from KafkaConsumer to KafkaClient Dana Powers 2016-08-04 12:18:54 -07:00
  • 035e8f058e Remove unused import from kafka.conn Dana Powers 2016-08-04 12:16:34 -07:00
  • c572e8d6e2 Add BrokerConnection docstring with configuration parameters Dana Powers 2016-08-04 12:03:36 -07:00
  • 3ed27c60ec Add connection-count to KafkaClient metrics Dana Powers 2016-08-04 12:02:24 -07:00
  • a6b9b13507 Add connection-creation-rate / connection-close-rate to KafkaClientMetrics Dana Powers 2016-08-04 12:01:48 -07:00
  • 3c9b1b6fc4 Fix misspelling of "password" (#793) Samuel Taylor 2016-08-04 14:48:12 -05:00
  • 0e753e6592 Ignore socket.error when checking for protocol out of sync prior to socket close (#792) Dana Powers 2016-08-03 16:31:38 -07:00
  • 709ee3b59a Support for PLAIN sasl authentication (PR #779) Dana Powers 2016-08-03 11:46:56 -07:00
  • 787e8b2ba0 minor tweaks to get authentication working Lars Jørgen Solberg 2016-08-03 11:42:00 +00:00
  • 2b2c72feac Use callbacks for sasl handshake request / response Dana Powers 2016-08-03 11:45:50 -07:00
  • 6b801a8d2e implement sasl PLAIN mechanism Lars Jørgen Solberg 2016-07-25 08:40:38 +00:00
  • 3baca5f306 Use callbacks for sasl handshake request / response larsjsol-sasl_plain Dana Powers 2016-08-02 23:07:34 -07:00
  • 40afc98dca rename sasl_username and sasl_password to sasl_plain_* Lars Jørgen Solberg 2016-07-26 11:21:50 +00:00
  • 354e9a9c31 fix unqualified references to exception types Lars Jørgen Solberg 2016-07-25 11:14:19 +00:00
  • f0082e42c2 add sasl support to consumer Lars Jørgen Solberg 2016-07-25 10:47:47 +00:00
  • 1cb9295027 document new params Lars Jørgen Solberg 2016-07-25 10:47:16 +00:00
  • 2ce9eed23a fix calling for_code without referencing the Errors module Lars Jørgen Solberg 2016-07-25 09:31:06 +00:00
  • 2ebf9133ef change comments in order to trigger a travis build Lars Jørgen Solberg 2016-07-25 09:06:35 +00:00
  • 2925c33799 clean up stray char Lars Jørgen Solberg 2016-07-25 08:49:42 +00:00
  • ad13ad95be remove debug-statements Lars Jørgen Solberg 2016-07-25 08:47:17 +00:00
  • 191a45a01e implement sasl PLAIN mechanism Lars Jørgen Solberg 2016-07-25 08:40:38 +00:00
  • c693709aaf Always absolute_import absolute_import Dana Powers 2016-08-02 21:36:00 -07:00
  • aed1a09401 Rename partition_assignment -> assignment in MemberMetadata for consistency Dana Powers 2016-07-31 20:34:35 -07:00
  • b87ad1eb0e Clarify api_version=str deprecation warning Dana Powers 2016-07-31 20:32:35 -07:00
  • 40e2faa9ab Metadata with_partitions() (#787) Dana Powers 2016-08-01 18:14:59 -07:00
  • 99891adfa0 Merge pull request #785 from dpkp/six Dana Powers 2016-08-01 18:14:25 -07:00
  • ec286c9fb6 Fix offset fetch when partitions are manually assigned (#786) Dana Powers 2016-08-01 16:30:03 -07:00
  • 41bed56fb9 Rename _DEFAULT_CONFIG -> DEFAULT_CONFIG in KafkaProducer (#788) Dana Powers 2016-08-01 16:29:52 -07:00
  • 51b3d311f3 Vendor six 1.10.0 six Dana Powers 2016-08-01 09:45:39 -07:00
  • 00e1c5dc7e Rename _DEFAULT_CONFIG -> DEFAULT_CONFIG in KafkaProducer producer_defaults Dana Powers 2016-07-31 20:32:03 -07:00
  • 42f158df2f Fixup ClusterMetadata __str__ metadata_with_partitions Dana Powers 2016-07-31 11:58:46 -07:00
  • 72510d5c35 add method ClusterMetadata.with_partitions Dana Powers 2016-07-31 11:56:38 -07:00
  • 006cb529f2 Fix offset fetch when partitions are manually assigned KAFKA-3960 Dana Powers 2016-07-18 21:25:29 -07:00
  • 1d23dddcd6 Move kafka.socketpair to kafka.vendor.socketpair Dana Powers 2016-08-01 09:44:31 -07:00
  • 4828e491f1 Move kafka.selectors34 to kafka.vendor.selectors34 Dana Powers 2016-08-01 09:41:07 -07:00
  • 4162989b77 Use socket_options configuration to setsockopts(). Default TCP_NODELAY (#783) Dana Powers 2016-08-01 08:53:17 -07:00
  • cf3b370da9 Use socket_options configuration to setsockopts(). Default TCP_NODELAY socket_options Dana Powers 2016-07-30 17:06:47 -07:00
  • 64d3607b87 Document the ssl_password config option (#780) Samuel Taylor 2016-07-26 10:08:29 -05:00
  • bdb0559b38 Merge pull request #772 from dpkp/more_metrics Dana Powers 2016-07-26 08:07:57 -07:00
  • 0d161f72dd change pickle_method to use python3 special attributes (#777) John Win 2016-07-26 08:06:24 -07:00
  • 0776e5a97d Fix typo in KafkaConsumer documentation (#775) Samuel Taylor 2016-07-21 16:02:19 -05:00
  • a871aa60f3 Add KafkaClient metrics more_metrics Dana Powers 2016-07-17 17:53:42 -07:00
  • f8b8904491 Record produce latency and throttling metrics Dana Powers 2016-07-17 14:42:51 -07:00
  • 3a7802d51c Add base coordinator metrics Dana Powers 2016-07-17 14:39:27 -07:00
  • 436b2b2011 Fix ProduceResponse v2 throttle_time_ms Dana Powers 2016-07-17 14:49:13 -07:00