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

• 9c8cb7dea1 Add BrokerConnection.disconnected() method; update tests Dana Powers 2016-04-07 16:11:25 -07:00
• 2527ff30ce Drop timeout param from BrokerConnection.recv() Dana Powers 2016-04-07 16:09:07 -07:00
• e86b6d21be Raise ConnectionError immediately on disconnect in SimpleClient._get_conn Dana Powers 2016-04-07 21:53:52 -07:00
• eff668e9ad Add state_change_callback to BrokerConnection refactor Dana Powers 2016-04-07 21:54:49 -07:00
• 1f5ed3816c Apply new _get_conn connect logic in KafkaClient.check_version Dana Powers 2016-04-07 23:53:22 -07:00
• 2f1aee387e Raise ConnectionError immediately on disconnect in SimpleClient._get_conn Dana Powers 2016-04-07 21:53:52 -07:00
• ee21f095f9 Split test_ready to test_is_ready Dana Powers 2016-04-07 22:13:00 -07:00
• 622b853f4c Speedup some failover tests w/ shorter SimpleClient timeout Dana Powers 2016-04-07 21:31:57 -07:00
• d05f6aa113 Reduce batch time in producer integration test (speedup test) Dana Powers 2016-04-07 21:30:35 -07:00
• e78959a8ca Default sleep=True in client.poll Dana Powers 2016-04-07 16:13:50 -07:00
• 12c8f0cd30 Make _wake_r socket non-blocking; drop select from _clear_wake_fd Dana Powers 2016-04-07 16:23:24 -07:00
• bb40619cba More _maybe_connect refactoring -- preparing for selectors Dana Powers 2016-04-07 16:22:32 -07:00
• 88105af1f6 Can no longer have coordinator_id if coordinator_unknown() Dana Powers 2016-04-07 16:20:07 -07:00
• 3b26839e90 Add BrokerConnection.disconnected() method; update tests Dana Powers 2016-04-07 16:11:25 -07:00
• 8b592cda91 Drop timeout param from BrokerConnection.recv() Dana Powers 2016-04-07 16:09:07 -07:00
• 116e634e4b Merge pull request #636 from dpkp/french_connection Dana Powers 2016-04-07 11:23:39 -07:00
• c1ab194647 Cleanup AF_INET import in conn fixture Dana Powers 2016-04-04 18:58:16 -07:00
• d61e861b0d Consolidate conn fixture definitions Dana Powers 2016-04-04 18:57:32 -07:00
• 931373478e Use conn.connecting() checks to support multiple connecting states Dana Powers 2016-04-04 18:55:17 -07:00
• 7f042327c8 Refactor SimpleClient connect logic to support multiple connecting states Dana Powers 2016-04-04 18:53:46 -07:00
• 19973cf884 Track last_failure in BrokerConnection.close() Dana Powers 2016-04-07 08:08:19 -07:00
• 5ed59a95e7 Simplify connect logic further Dana Powers 2016-04-04 16:27:18 -07:00
• 71b0d05c16 Update 0.9.0.0 configuration defaults so they are consistent with official release Dana Powers 2016-04-07 08:16:15 -07:00
• 89f8302494 Merge updates from PR 573 into README (serializer/deserializer examples) Dana Powers 2016-04-07 08:02:37 -07:00
• adc6a93f3d Merge pull request #628 from dpkp/kafka-2136 Dana Powers 2016-04-06 17:03:12 -07:00
• 734cb28afe Catch more producer exceptions in failover tests Dana Powers 2016-04-06 16:24:35 -07:00
• 3d16f2ff5f KAFKA-2136: support Fetch and Produce v1 (throttle_time_ms) Dana Powers 2016-04-05 13:04:24 -07:00
• 331442ee0f Merge pull request #634 from dpkp/fetch Dana Powers 2016-04-06 14:00:28 -07:00
• 4c965133df Merge pull request #630 from dpkp/protocol_versions Dana Powers 2016-04-06 11:58:59 -07:00
• 78ad43600c Dont send FetchRequest for (obviously) pending data Dana Powers 2016-04-06 11:47:41 -07:00
• 3ef15f9d60 Increase coverage of StopIteration check in _unpack_message_set Dana Powers 2016-04-06 11:47:07 -07:00
• 358b482074 Log debug messages when skipping fetched messages due to offset checks Dana Powers 2016-04-06 11:46:20 -07:00
• 90c729438a Use version-indexed lists for request/response protocol structs Dana Powers 2016-04-05 22:54:28 -07:00
• 452e7c2190 Merge pull request #623 from dpkp/kafka-3318 Dana Powers 2016-04-05 12:40:44 -07:00
• c478d0c15a Remove unused imports Dana Powers 2016-04-05 00:35:30 -07:00
• ee43e3a66a KAFKA-3013: Include topic-partition in exception for expired batches Dana Powers 2016-04-05 00:35:13 -07:00
• 145ac227cb KAFKA-3318: clean up consumer logging and error messages Dana Powers 2016-04-05 00:07:15 -07:00
• 5a14bd8c94 Update imports from kafka.common -> kafka.errors / kafka.structs Dana Powers 2016-04-05 09:34:48 -07:00
• 221f56d8a0 Split kafka.common into kafka.structs and kafka.errors Dana Powers 2016-04-05 08:59:02 -07:00
• 679d7485b1 Merge pull request #611 from dpkp/sock_send_bytes Dana Powers 2016-04-05 08:10:00 -07:00
• bb25469fda Handle partial socket send() Dana Powers 2016-03-23 09:59:52 -07:00
• 4a04a09ef1 Coerce exceptions to bool in Future.succeeded() and Future.failed() Dana Powers 2016-04-04 22:51:33 -07:00
• 87da3f0080 Add BrokerConnection.send tests Dana Powers 2016-04-04 22:52:00 -07:00
• d81963a919 Update max.block.ms docstring Dana Powers 2016-04-04 23:09:46 -07:00
• ff10ccf3ce Merge pull request #589 from dpkp/node_not_ready Dana Powers 2016-04-04 16:09:10 -07:00
• e83443126a Improve KafkaClient connect and ready handling Dana Powers 2016-03-14 00:02:15 -07:00
• 08e30cb500 Improve Coordinator Error handling Dana Powers 2016-03-14 00:14:48 -07:00
• ee7114cebb Drop now-redundant ready() check in Fetcher._handle_offset_response Dana Powers 2016-03-14 00:10:50 -07:00
• c7bbec07e9 Add basic unit test coverage for BrokerConnection Dana Powers 2016-03-14 00:11:26 -07:00
• 0a942176a6 Improve Broker connection handling of not-ready nodes Dana Powers 2016-03-24 10:23:28 -07:00
• 51fc3e428b Merge pull request #620 from dpkp/issue_619 Dana Powers 2016-04-04 09:36:27 -07:00
• 6188b7bd4b Move old KafkaConnection tests to test_conn_legacy Dana Powers 2016-03-12 15:14:26 -08:00
• 3d1c3521db Improve auto-commit task handling when group_id is None Dana Powers 2016-04-03 09:29:36 -07:00
• 05bd03dcc5 Test _maybe_auto_commit_offsets_sync when group_id is None Dana Powers 2016-04-03 09:28:21 -07:00
• b96f4ccf07 Merge pull request #615 from TimEvens/master Dana Powers 2016-03-30 17:21:20 -07:00
• f456ffc8d9 Changed transltae to replace to support python 3 Tim Evens 2016-03-30 16:27:47 -07:00
• 0f78d57c60 Kafka IPv6 Support. Tim Evens 2016-03-30 15:32:05 -07:00
• c6c862ad29 Merge pull request #603 from dpkp/windows Dana Powers 2016-03-24 10:19:29 -07:00
• 41caf50f58 Ignore more kafka-bin rcs -- useful during release testing Dana Powers 2016-03-23 09:46:55 -07:00
• 53b6bf2731 Remove errant next(consumer) from consumer documentation Dana Powers 2016-03-22 16:53:53 -07:00
• 33c7a9a374 Add 0.10.0.0 test fixture properties files Dana Powers 2016-03-21 17:05:52 -07:00
• 4f8d9fa9dc Add producer.flush() to usage docs Dana Powers 2016-03-18 11:25:59 -07:00
• 2f534c177f Merge pull request #606 from zackdever/partition-leader-errors Dana Powers 2016-03-17 16:32:30 -07:00
• 4915942b07 catch all errors thrown by _get_leader_for_partition in SimpleClient Zack Dever 2016-03-17 12:17:03 -07:00
• ab03296b65 Merge pull request #602 from zackdever/KAFKA-2698 Dana Powers 2016-03-17 11:22:36 -07:00
• f83e27168f Add default_offset_commit_callback to KafkaConsumer DEFAULT_CONFIGS Dana Powers 2016-03-17 11:21:48 -07:00
• ced2220747 Skip test that fails on windows Dana Powers 2016-03-17 11:05:10 -07:00
• f39f461918 Handle windows socket error codes in BrokerConnection Dana Powers 2016-03-17 11:04:26 -07:00
• 16a013e207 Use socketpair for KafkaClient wake pipe windows compatibility Dana Powers 2016-03-17 11:04:01 -07:00
• 82c3e371c9 Fallback to curl if wget is not available Dana Powers 2016-03-17 11:02:53 -07:00
• 2dc8c3cffa Bump version for development Dana Powers 2016-03-17 10:54:41 -07:00
• 2b6d063085 KAFKA-2698: add paused API Zack Dever 2016-03-16 16:21:37 -07:00
• ab7c80db8f Release 1.0.2 1.0.2 Dana Powers 2016-03-14 21:03:44 -07:00
• 68b7dc3c76 Update changelog for 1.0.2 release Dana Powers 2016-03-14 21:03:18 -07:00
• d3743a0cdd Merge pull request #599 from zackdever/travis-master-deploy Dana Powers 2016-03-14 20:57:50 -07:00
• 584e5ec740 Attempt to clarify error message on consumer subscribe/assign assert failure Dana Powers 2016-03-14 12:36:11 -07:00
• 00599b6306 Merge pull request #598 from zackdever/producer-optimization Dana Powers 2016-03-14 18:24:00 -07:00
• e7547db049 Only deploy master branch now that travis bug is fixed. Zack Dever 2016-03-14 17:53:03 -07:00
• 1b1bd55d03 remove unused import. needed a change to kick travis. Zack Dever 2016-03-14 16:29:13 -07:00
• 8847dbbb0d make Sender._topics_to_add a set instead of a list Zack Dever 2016-03-14 16:14:48 -07:00
• 3bf75c53bf only make a metadata event if we don't know the partitions Zack Dever 2016-03-14 16:03:06 -07:00
• 3d80a79855 Merge pull request #597 from dpkp/consumer_poll_sleep Dana Powers 2016-03-14 12:23:39 -07:00
• 0ae0e21955 join consumer threads in test_consumer_group cleanup Dana Powers 2016-03-14 12:23:50 -07:00
• dc7a21151b KafkaConsumer.poll should sleep to prevent tight-loops Dana Powers 2016-03-14 10:52:04 -07:00
• c902baafbe Re-render fixture config in restart loop if necessary Dana Powers 2016-03-14 09:28:43 -07:00
• 98ca3a6ab5 Merge pull request #587 from dpkp/topic_partition_type_error Dana Powers 2016-03-14 08:38:48 -07:00
• ba06e68bed Merge pull request #588 from dpkp/none_least_loaded_node Dana Powers 2016-03-14 08:23:41 -07:00
• 6e68ccd716 Merge pull request #590 from dpkp/accumulator_bugfix Dana Powers 2016-03-14 08:21:27 -07:00
• c3bc541a69 More fixture logging improvements Dana Powers 2016-03-14 08:07:54 -07:00
• 479e70872e Raise TypeError in KafkaConsumer when partition is not a TopicPartition Dana Powers 2016-03-13 23:52:58 -07:00
• 6ded42f3c4 Fix producer threading bug that could crash sender (dict changing during iteration) Dana Powers 2016-03-14 00:29:08 -07:00
• 8303780259 Check for None returned from least_loaded_node when no brokers are available Dana Powers 2016-03-13 23:49:55 -07:00
• 0330036bef Fixup test fixtures for pylint Dana Powers 2016-03-13 23:31:09 -07:00
• 0c272a05b3 Merge pull request #585 from dpkp/truncate_buffer Dana Powers 2016-03-13 23:19:53 -07:00
• a45cd4d17b Improve Fixture logging - remove double console appenders from log4j.properties - also log to server.log file for interactive uses - drop internal _spawn from SpawnedService loop - write captured stdout/stderr directly to avoid logger re-formatting Dana Powers 2016-03-13 23:16:17 -07:00
• 4ffd4e94e0 Always truncate deallocated produce message buffers Dana Powers 2016-03-13 14:12:27 -07:00
• f989852639 Reduce end-to-end test to 100 messages; raise produce future exceptions immediately Dana Powers 2016-03-13 13:41:56 -07:00
• a03c7ace89 Add SimpleBufferPool test to verify reallocated buffers are empty Dana Powers 2016-03-13 13:40:41 -07:00
• bd5bd62b09 Add ignore_leadernotavailable kwarg to SimpleClient.load_metadata_for_topics Dana Powers 2016-03-13 00:09:03 -08:00
• 5d28581b40 Use producer retries and flush timeout in producer end-to-end test Dana Powers 2016-03-12 23:51:34 -08:00