Commit Graph

  • ab2f4ff984 Small cleanup for #962 Dana Powers 2017-03-06 15:16:05 -08:00
  • 9c19ea7cbe Added max_bytes option and FetchRequest_v3 usage. (#962) Taras Voinarovskyi 2017-03-07 00:59:26 +02:00
  • ff6f7bf085 Minor additional logging for consumer coordinator Dana Powers 2017-03-06 11:03:17 -08:00
  • 8ebb646be9 Add more debug-level connection logging Dana Powers 2017-03-06 11:01:49 -08:00
  • 2eb32ddc79 Do not need str(self) when formatting to %s Dana Powers 2017-03-06 11:01:07 -08:00
  • 52086f4f25 CreateTopicsRequest / Response v1 (#1012) Dana Powers 2017-03-04 10:53:00 -08:00
  • ffbfd29da0 Add new broker response errors Dana Powers 2017-03-03 17:27:54 -08:00
  • ccbdf592c1 Small style fixes in kafka.errors Dana Powers 2017-03-03 17:00:35 -08:00
  • 61eb396bba When closing a broker connection without error, fail in-flight-requests with Cancelled (#1010) Dana Powers 2017-03-03 17:51:48 -08:00
  • c741c5342e Include the node id in BrokerConnection __repr__ (#1009) Dana Powers 2017-03-03 16:53:13 -08:00
  • 46b857fbbd Mark last_attempt time during connection close to fix blackout calculation (#1008) Dana Powers 2017-03-03 16:53:01 -08:00
  • f0061624d8 Catch socket errors during ssl handshake (#1007) Dana Powers 2017-03-03 16:44:02 -08:00
  • 7b727ab92b Dont refresh metadata on failed group coordinator request unless needed (#1006) Dana Powers 2017-03-03 15:03:37 -08:00
  • 315850c877 Drop old brokers when rebuilding broker metadata (#1005) Dana Powers 2017-03-03 12:51:21 -08:00
  • a36307a4c8 Run tests in python3.6 too (#992) ms7s 2017-03-03 21:37:53 +01:00
  • 373d221613 Update vendored berkerpeksag/selectors34 to ff61b82 Dana Powers 2017-03-03 10:55:55 -08:00
  • d9283c1453 Add sphinx formatting to hyperlink methods (#898) Jeff Widman 2017-03-03 10:14:54 -08:00
  • b1f22b882a Replace %s with %r in producer debug log message (#973) Alex 2017-03-03 18:13:26 +00:00
  • 861b9e9b65 Fix sasl reconnect bug: auth future must be reset on close (#1003) Dana Powers 2017-03-03 10:07:59 -08:00
  • 3a630f2f88 Add send_list_offset_request for searching offset by timestamp (#1001) charsyam 2017-03-03 07:15:01 +09:00
  • a22ea16564 Issue 985: Clear memory wait condition before raising Exception (#999) Dana Powers 2017-03-02 11:27:07 -08:00
  • 6aabe418c3 Fix BrokerConnection api_version docs default (#909) Jeff Widman 2017-02-28 14:35:53 -08:00
  • 2c23a27483 Remove dead code (#967) Jeff Widman 2017-02-28 10:18:02 -08:00
  • 432f00eb66 Fail-fast on timeout constraint violations during KafkaConsumer creation (#986) Harel Ben-Attia 2017-02-28 20:13:28 +02:00
  • bcb4009b93 Drop bad disconnect test -- just use the mocked-socket test (#982) Dana Powers 2017-02-24 09:53:44 -08:00
  • bd6ecef5b4 Drop bad disconnect test -- just use the mocked-socket test remove_bad_test Dana Powers 2017-02-09 15:28:01 -08:00
  • 8fde79dbb5 PEP-8: Spacing & removed unused imports (#899) Jeff Widman 2017-02-09 12:27:16 -08:00
  • e825483d49 Add MetadataRequest_v2 and MetadataResponse_v2 structures for KIP-78 (#974) Taras Voinarovskyi 2017-02-09 20:56:58 +02:00
  • 8be2f248ba KIP-88 / KAFKA-3853: OffsetFetch v2 structs (#971) Jeff Widman 2017-02-08 17:23:39 -08:00
  • f93e6de513 Move BrokerConnection docstring to class (#968) Jeff Widman 2017-02-08 17:18:31 -08:00
  • 9b8ef798dd DRY-up the MetadataRequest_v1 struct (#966) Jeff Widman 2017-02-08 17:17:21 -08:00
  • d309ccbec9 Add JoinGroup v1 structs (#965) Jeff Widman 2017-02-08 17:16:10 -08:00
  • d215bd9823 DRY-up the OffsetCommitResponse Structs (#970) Jeff Widman 2017-02-03 10:10:58 -08:00
  • ff2a129bc6 DRY-up the OffsetFetch structs (#964) Jeff Widman 2017-02-03 10:08:12 -08:00
  • 4c62fb9247 time --> timestamp to match Java API (#969) Jeff Widman 2017-02-03 10:07:01 -08:00
  • d7679681d8 Use select to poll sockets for read to reduce CPU usage (#958) Jianbin Wei 2017-02-03 10:06:12 -08:00
  • ce1bdee2ec Fix raise exception from SubscriptionState.assign_from_subscribed (#960) Petr Šebek 2017-02-03 18:45:57 +01:00
  • 641b6399d8 Add support for Python built without ssl (#939) (#954) Sho Minagawa 2017-02-04 02:44:29 +09:00
  • bfd1138399 use select.select without instance bounding (#949) adamwen 2017-01-24 02:01:04 +08:00
  • 3bd51bbb9f Update to 0.10.1.1 for integration testing (#953) Dana Powers 2017-01-23 10:00:23 -08:00
  • ada9d33f4b Switch to 0.10.1.1 0_10_1_1 Dana Powers 2017-01-21 18:22:27 -08:00
  • 17f409e9d1 Update docs Dana Powers 2016-10-23 12:02:58 -07:00
  • 3c222085f5 Move 0.10 integration testing to 0.10.1.0 Dana Powers 2016-10-23 12:01:27 -07:00
  • 7377ec5590 Add resource files for 0.10.1.0 fixtures Dana Powers 2016-10-23 12:01:10 -07:00
  • 88e98da0fd Move docstring so it shows up in Sphinx/RTD (#952) Jeff Widman 2017-01-21 18:09:53 -08:00
  • 25741bdc89 Add support for offsetRequestV1 messages (#951) Julien Lafaye 2017-01-19 22:10:26 +01:00
  • 4da18a97df Do not re-close a disconnected connection Dana Powers 2016-12-17 10:40:07 -08:00
  • 3b66b403d8 Drop unused last_failure time from BrokerConnection Dana Powers 2016-12-17 10:39:34 -08:00
  • 0a8dabdf22 Use connection state functions where possible Dana Powers 2016-12-17 10:39:06 -08:00
  • d0f4abe05d Pass error to BrokerConnection.close() Dana Powers 2016-12-17 10:37:28 -08:00
  • 7df120d7ce Add FetchRequest/Response_v3 structs (#943) Jeff Widman 2017-01-18 16:52:29 -08:00
  • 2c6261a4d6 Add CreateTopics / DeleteTopics Structs (#944) Jeff Widman 2017-01-18 16:51:58 -08:00
  • 8d41f39702 Default max_poll_records to Java default of 500 (#947) Jeff Widman 2017-01-18 16:51:03 -08:00
  • c1608dda6b Remove non-pip install instructions (#940) Jeff Widman 2017-01-12 18:03:05 -08:00
  • 83081befc1 Spelling and grammar changes (#923) melissacrawford396 2017-01-11 20:19:38 -05:00
  • cb06a6b125 Update pytest fixtures to new yield syntax (#919) Jeff Widman 2017-01-11 17:18:28 -08:00
  • 9a08efbdd2 Fix typo: coorelation --> correlation (#929) Jeff Widman 2017-01-11 17:18:02 -08:00
  • 5e92a70278 Do not re-close a disconnected connection connection_error_close Dana Powers 2016-12-17 10:40:07 -08:00
  • 0a0449e2de Drop unused last_failure time from BrokerConnection Dana Powers 2016-12-17 10:39:34 -08:00
  • 48b31b4289 Use connection state functions where possible Dana Powers 2016-12-17 10:39:06 -08:00
  • cb5e7b80ba Pass error to BrokerConnection.close() Dana Powers 2016-12-17 10:37:28 -08:00
  • cfb5f0e285 Make SSL warning list the correct Python versions (#924) Jeff Widman 2017-01-04 14:49:05 -08:00
  • 9fce1701f0 Bump version for development Dana Powers 2016-12-29 09:18:31 -08:00
  • fe340516a1 Rearrange a few 1.3.2 changelog entries Dana Powers 2016-12-29 09:17:22 -08:00
  • f6bc0246e6 Patch Release 1.3.2 1.3.2 Dana Powers 2016-12-28 16:40:14 -08:00
  • 1db3dbe80c Update changelog Dana Powers 2016-12-27 15:41:10 -08:00
  • 2e80fbb0c2 Fix of exception raise in case of auto_offset_reset is set to None in KafkaConsumer (#860) Alexander Sibiryakov 2016-12-28 00:38:52 +01:00
  • 4acb7f4434 Add metadata update to pattern subscribing (#915) Dmitry Lazurkin 2016-12-28 02:36:57 +03:00
  • 0e55d9957a Add unreleased notes to changelog Dana Powers 2016-12-19 16:25:23 -08:00
  • 655953fdac Add kafka.serializer interfaces (#912) Dana Powers 2016-12-19 11:27:23 -08:00
  • f6291e655d Add docstring for max_records (#897) Jeff Widman 2016-12-19 11:26:46 -08:00
  • 46f9b1f681 Sort partitions before calling partitioner (#905) ms7s 2016-12-19 20:26:03 +01:00
  • e8283958e4 Bug fix: ret = err => ret = err.errno (#907) guojh 2016-12-18 09:10:42 +08:00
  • 103ac7eb11 Fix fetcher bug when processing offset out of range (#911) Dana Powers 2016-12-17 17:07:58 -08:00
  • 64347bd9fa Add kafka.serializer interfaces serialize_interface Dana Powers 2016-12-17 17:06:46 -08:00
  • c57a231ab0 Fix fetcher bug when processing offset out of range fetcher_offset_out_of_range Dana Powers 2016-12-17 10:40:30 -08:00
  • 07e09c1c2e Fixup doc references to max_in_flight_requests_per_connection Dana Powers 2016-09-20 17:03:38 -07:00
  • 7690b1ab32 Fix typo: passowrd --> password (#901) Jeff Widman 2016-12-12 10:17:03 -08:00
  • 010ebb53a9 Fix possible request draining in ensure_active_group (#896) Dana Powers 2016-12-02 18:25:28 -08:00
  • 229dcc89ef Fix possible request draining in ensure_active_group drain_requests_join_group Dana Powers 2016-12-01 11:39:14 -08:00
  • 9b59c5d755 DOC: Fix typo 'Defualt' -> 'Default'. (#895) Rolando (Max) Espinoza 2016-11-30 20:24:09 -03:00
  • f3231dc7ed Bumped debhelper compat version to 10 Ondřej Nový 2016-11-24 00:07:17 +01:00
  • cbe8a6a2ee When hostname lookup is necessary, do every connect (#812) Evan Bender 2016-08-23 11:47:13 -04:00
  • c4a6e1aa68 Use six.string_types for topic type check in #824 Dana Powers 2016-11-20 12:44:55 -08:00
  • 5ad6f52a80 Raise exception if given a bad topic name (#824) Samuel Taylor 2016-11-20 14:43:26 -06:00
  • 07237d9894 Added doc for max_poll_records option (#881) Taras Voinarovskyi 2016-11-20 22:37:01 +02:00
  • af7f2ced1b setting proper topic value in case if it's empty (#867) Alexander Sibiryakov 2016-11-18 19:45:38 +01:00
  • 6bd1e1db57 Always include an error for logging when the coordinator is marked dead (#890) Dana Powers 2016-11-18 10:43:26 -08:00
  • ff56bdbcc6 Args are optional in BrokerResponseError str (#889) Dana Powers 2016-11-18 10:15:39 -08:00
  • 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 -08:00
  • 6c9f7280c5 :wPass timestamp into Message, not just mimic it (#875) Taras Voinarovskyi 2016-11-18 19:08:19 +02:00
  • f71cfc4607 Always check for request timeouts (#887) Dana Powers 2016-11-18 09:07:53 -08:00
  • da8d4c1e8b Args are optional in BrokerResponseError str kafka_error_str Dana Powers 2016-11-18 09:06:21 -08:00
  • dc45935ec8 Also/continue to check for timeouts in BrokerConnection.recv() timeout_noresponse Dana Powers 2016-11-17 20:24:14 -08:00
  • 0bf7ea0f67 Check for requests that timeout without causing a socket read/write event Dana Powers 2016-11-17 20:00:09 -08:00
  • 57ea7e81dc typo (#883) sharego 2016-11-16 01:30:16 +08:00
  • 43e0c38bf3 Update param in warning (#878) Dana Powers 2016-11-14 11:14:37 -08:00
  • eb6801da35 Remove old design notes from Kafka 8 era (#876) Jeff Widman 2016-11-14 11:02:34 -08:00
  • 8ac79fbe3d Fix typos (#874) Dana Powers 2016-11-14 11:01:34 -08:00
  • cd74c1fe40 Fix typos Jeff Widman 2016-11-08 01:29:45 -08:00