Commit Graph

Select branches

Hide Pull Requests

0.10.0.1

0.7

0.8

0.9

0_10_1_0

0_10_1_1

0_11_0_0

709

741

KAFKA-3117

KAFKA-3196

KAFKA-3197

KAFKA-3388

KAFKA-3486

KAFKA-3960

absolute_import

at_exit_weakref

await_reserved

backoff_coordinator_retry

batch_expiration_message

benchmarks

check_version

check_version_0_10

client_api_version

combine_send_bytes

compacted_offsets

config_selector

conn_check_version_max_in_flight

conn_legacy

conn_metrics_fix

connection_error_close

consumer_iterator

coordinator_dead_error_logging

coordinator_del

coordinator_unknown_heartbeat

debian/newton

decode_errors

disconnects

double_compression

drain_pending_coordinator_requests

drain_requests_join_group

errors

exclude_internal_topics

exp_backoff

faster_validate_crc

fetcher_offset_out_of_range

fetcher_randomize_order

fix_leaks

fixture_auto_ports

kafka-0.8.0-release

kafka_error_str

larsjsol-sasl_plain

leak_z4

least_loaded_node

lz4_0_10

master

max_poll_records

message_format_v1

message_set_encode_size

metadata_refresh_backoff

metadata_v1

metadata_wait_for_connect

metadata_with_partitions

more_metrics

murmur2_ascii

no_sleep_til_brooklyn

partial_messages

produce_fetch_v2

producer_defaults

protocol_updates

pylint_fixup

receive_bytes_pipe

record_metadata_simplify

refactor

release

release-0.9.x

remove_bad_test

request_response_classes

sensor_quota_message

serialize_interface

simple

six

skip_autocommit_consumer_close

socket_options

subscription_copy

testing

timeout_idle_connections

timeout_noresponse

unrecurse_unpack_message_set

update-rtd-links

wake_socketpair_exceptions

warn_dns_error

zk_autocommit

0.1-alpha

0.9.3

0.9.5

1.0.0

1.0.1

1.0.2

1.1.0

1.1.1

1.2.0

1.2.1

1.2.2

1.2.3

1.2.4

1.2.5

1.3.0

1.3.1

1.3.2

1.3.3

debian/0.9.3-1

debian/0.9.3-2

debian/0.9.5-2

debian/0.9.5.1

v0.8.0

v0.9.0

v0.9.1

v0.9.2

v0.9.3

v0.9.4

v0.9.5

Mono Color

• 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