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

• 385f2d80f9 Refactor away _get_conn_for_broker. Fix bug in _get_conn Mark Roberts 2014-04-09 11:19:32 -07:00
• 12fae12ef2 Add final tests for 100% coverage of protocol.py from test/test_protocol.py Mark Roberts 2014-04-09 10:33:40 -07:00
• 8f179d8607 Add encode_offset_fetch_request test Mark Roberts 2014-04-09 02:58:36 -07:00
• 58b4d0ff7a Add commit offset request test Mark Roberts 2014-04-09 02:47:07 -07:00
• 1cb27f99d6 Add tests for encode_offset_request Mark Roberts 2014-04-09 02:30:43 -07:00
• 5c58151e6f Add python-snappy to tox dependencies. Fix snappy protocol test Mark Roberts 2014-04-09 02:11:39 -07:00
• 115c20ced3 Convert test_encode_fetch_request to struct.pack format, improve test reliability Mark Roberts 2014-04-09 01:54:01 -07:00
• 853d45247e Update more tests, fix intermittent failure Mark Roberts 2014-04-09 01:26:18 -07:00
• a3c781fda5 Merge branch 'master' into add_tests Mark Roberts 2014-04-08 23:45:53 -07:00
• 3bde6d6b1c Convert more tests to struct.pack Mark Roberts 2014-04-08 23:33:26 -07:00
• ac9cf9e944 Convert serveral tests to struct.pack Mark Roberts 2014-04-08 22:10:06 -07:00
• d7c5bbf7d4 Reinstate test_integrate, make test_protocol more explicit, create testutil Mark Roberts 2014-04-08 11:02:57 -07:00
• f0def436c6 Explicit testing of protocol errors. Make tests more explicit, and start working on intermittent failures in test_encode_fetch_request and test_encode_produc_request Mark Roberts 2014-04-08 01:28:59 -07:00
• d59cbf6206 Comment out all of test_integration because it currently does not work Mark Roberts 2014-04-08 01:27:04 -07:00
• 80b3335ed2 Split test files, modify test_protocol Mark Roberts 2014-04-08 01:09:23 -07:00
• 6ee151427c Remove test support for py26 since it's broken Mark Roberts 2014-04-07 19:44:40 -07:00
• 13d0d445da Merge pull request #148 from wizzat/seek_commit Omar 2014-04-03 16:47:52 -07:00
• 1fd35a558f added random_start param to SimpleProducer to enable/disable randomization of the initial partition messages are published to Alex Couture-Beil 2014-04-01 18:24:39 -07:00
• 4d0722aef2 Changed randomization to simply randomize the initial starting partition of the sorted list of partition rather than completely randomizing the initial ordering before round-robin cycling the partitions Alex Couture-Beil 2014-04-01 18:07:24 -07:00
• 7d425d07c2 Commit in seek if autocommit Mark Roberts 2014-03-27 10:26:52 -07:00
• e5af3170f3 Make seek(); commit(); work without commit discarding the seek change Mark Roberts 2014-03-25 11:07:31 -07:00
• 9bed11db98 Merge pull request #134 from wizzat/conn_refactor v0.9.0 Dana Powers 2014-03-21 23:15:28 -07:00
• 220b8956eb Merge pull request #129 from wizzat/kafka-0.8.0-release kafka-0.8.0-release Dana Powers 2014-03-21 22:58:10 -07:00
• e937e3f971 Merge pull request #109 from mrtheb/develop Dana Powers 2014-03-21 22:50:53 -07:00
• 51246fb318 Merge pull request #1 from wizzat/pr109 Marc Labbé 2014-03-20 09:08:04 -04:00
• 017f484285 Fix py26 compatibility issue, add mock to tox Mark Roberts 2014-03-18 20:49:10 -07:00
• a6fc260f28 Merge branch 'master' into conn_refactor Mark Roberts 2014-03-18 20:19:25 -07:00
• 9599215bf2 Merge pull request #144 from frgtn/check_basestring_in_collect_hosts Marc Labbé 2014-03-17 22:40:37 -04:00
• 19646b1f1f Merge branch 'master' into develop mrtheb 2014-03-17 15:43:00 -04:00
• e08c718ca6 Check against basestring instead of str in collect.hosts. Saulius Zemaitaitis 2014-03-17 17:06:48 +02:00
• 32edabdaaf Merge pull request #141 from stephenarmstrong/fully-handle-broker-lists Omar 2014-03-13 18:18:58 -07:00
• c4cbe04cf1 If a broker refuses the connection, try the next stephenarmstrong 2014-03-13 15:14:32 -07:00
• a81be573b2 Modified SimpleProducer-based integration tests to work now that the initial round-robin ordering of partitions have been randomized Alex Couture-Beil 2014-03-12 10:53:06 -07:00
• 92fefb06fa Modified SimpleProducer to randomize the initial round robin ordering of partitions to prevent the first message from always being published to partition 0. Alex Couture-Beil 2014-03-11 18:09:52 -07:00
• 09c053a1be Merge pull request #138 from zever/master Omar 2014-03-04 18:02:20 -08:00
• 2eac578a5a nit: fixed misspelling Zack Dever 2014-03-03 17:48:37 -08:00
• a798c1e32b fix consumer retry logic (fixes #135) Carlo Cabanilla 2014-02-28 12:53:18 -05:00
• 888f206d54 Update load_example Mark Roberts 2014-02-26 21:38:58 -08:00
• 112158fa75 Merge branch 'master' into conn_refactor Mark Roberts 2014-02-26 21:36:22 -08:00
• ab89a44ecf Merge pull request #122 from mrtheb/multihosts Omar 2014-02-26 16:55:28 -08:00
• 3b39d9d658 Fix grammar in error string Mark Roberts 2014-02-25 16:51:36 -08:00
• 25e63cc422 Update logging config to include timestamps for better/easier debugging Mark Roberts 2014-02-25 02:18:46 -08:00
• 9732ed1670 Minor refactor in conn.py, update version in __init__.py, add ErrorString Mark Roberts 2014-02-25 01:06:17 -08:00
• ee7e86ea71 Update example.py to compile, add friendly load_example.py Mark Roberts 2014-02-25 01:02:39 -08:00
• e5fdc1c7b2 Fix version in __init__.py to match setup.py David Arthur 2014-02-25 10:46:28 -05:00
• 8811298744 Merge pull request #127 from GregBowyer/master Dana Powers 2014-02-25 00:15:58 -08:00
• f394279397 Add more repr Mark Roberts 2014-02-24 23:16:17 -08:00
• d340ad31b2 Add SimpleProducer repr Mark Roberts 2014-02-24 23:15:17 -08:00
• 976f6c0984 Add consumer repr Mark Roberts 2014-02-24 23:14:16 -08:00
• d842ced8f8 Add repr to client Mark Roberts 2014-02-24 23:10:30 -08:00
• 6850128618 Correct __version__ in init Mark Roberts 2014-02-24 23:08:03 -08:00
• 96c9ce0c4a Make it possible to read and write xerial snappy Greg Bowyer 2014-02-19 14:42:40 -08:00
• 828133cff0 fixing _get_leader_for_partition unittests mrtheb 2014-02-15 22:05:11 -05:00
• 51910f9818 clean up after comments from @rdiomar mrtheb 2014-02-15 13:43:56 -05:00
• 5e5d7097a7 Changes based on comments by @rdiomar, plus added LeaderUnavailableError for clarity mrtheb 2014-02-15 11:00:35 -05:00
• a2191e5be5 Support list (or comma-separated) of hosts (replaces host and port arguments) mrtheb 2014-02-09 13:44:47 -05:00
• 84de472a4d Merge branch 'master' into multihosts mrtheb 2014-01-31 22:43:59 -05:00
• b253166bec check for broker None in send_broker_aware_request (added test for it) mrtheb 2014-01-31 22:08:08 -05:00
• 72fdf391db Merge branch 'master' into develop mrtheb 2014-01-31 21:06:20 -05:00
• 8bcf0f0940 Handle cases for partition with leader=-1 (not defined) Marc Labbe 2014-01-31 20:06:30 -05:00
• 4abf7ee1fb Merge pull request #111 from rdiomar/multitopic_producers Dana Powers 2014-01-30 17:00:55 -08:00
• c9d9d0aad2 Resolve conflicts for #106 Omar Ghishan 2014-01-28 14:12:49 -08:00
• f6df696e0a Use TopicAndPartition when producing async messages Omar Ghishan 2014-01-27 11:16:53 -08:00
• a46898d015 Make producers take a topic argument at send rather than init time This allows a single producer to be used to send to multiple topics. See https://github.com/mumrah/kafka-python/issues/110 Omar Ghishan 2014-01-23 19:34:09 -08:00
• bcd5539cb6 Add doc string for SimpleConsumer._get_message() Omar Ghishan 2014-01-20 11:41:44 -08:00
• 9e2778efbb removed commented out lines mrtheb 2014-01-19 20:42:32 -05:00
• 6189bd4695 added mock mrtheb 2014-01-18 09:27:08 -05:00
• 6db14de167 Merge pull request #107 from rdiomar/fix_default_timeouts Marc Labbé 2014-01-16 18:21:25 -08:00
• 21e943828b Merge pull request #102 from cosbynator/master Omar 2014-01-16 16:42:59 -08:00
• ef24c117fe Change default socket timeout to 120 seconds in both the client and connection Omar Ghishan 2014-01-16 14:57:24 -08:00
• 94f4c9b3e6 Make the default connection timeout None Omar Ghishan 2014-01-16 13:52:28 -08:00
• e6c43d15e6 Merge pull request #98 from waliaashish85/dev Omar 2014-01-16 12:51:41 -08:00
• e0f726204a Make get_messages() update and commit offsets just before returning Omar Ghishan 2014-01-15 16:22:41 -08:00
• 8b3793a649 Only use timeout if it's not None Omar Ghishan 2014-01-15 15:54:06 -08:00
• 8cc36dd7a1 Store fetched offsets separately. Omar Ghishan 2014-01-15 14:28:48 -08:00
• 61a0cb6f83 0.9.0 Thomas Dimson 2014-01-15 11:29:27 -08:00
• c36cb618d2 Fix offset increments: Omar Ghishan 2014-01-15 11:13:59 -08:00
• c7733e30dc Update README.md too Thomas Dimson 2014-01-15 11:02:19 -08:00
• bfece4d939 Version bump Thomas Dimson 2014-01-15 10:59:40 -08:00
• fb4903e518 Merge branch 'repr' of https://github.com/mahendra/kafka-python into mahendra-repr mrtheb 2014-01-14 22:57:05 -05:00
• 9644166048 Merge pull request #100 from cosbynator/no_infinite_loops_real Omar 2014-01-14 15:22:05 -08:00
• 2818ddfa92 Make integration test warming more intuitive Thomas Dimson 2014-01-14 14:22:50 -08:00
• db322dae09 Add a few 9s test_multi_process_consumer, make clear what setUp is doing Thomas Dimson 2014-01-13 19:12:05 -08:00
• a3c3a15460 Throw KafkaUnavailableError when no brokers available Thomas Dimson 2014-01-13 16:39:06 -08:00
• 4e1cfc842d Merge pull request #99 from vadimg/master Omar 2014-01-13 16:14:27 -08:00
• 9c7b412838 Exception hierarchy, invalidate more md on errors Thomas Dimson 2014-01-13 15:30:51 -08:00
• b9167ca1f0 remove zero length field name in format string, to work in Python 2.6 Vadim Graboys 2014-01-13 17:43:55 -05:00
• 87c7f9dedf Merge pull request #88 from rdiomar/rdiomar_changes Omar 2014-01-13 13:52:02 -08:00
• daabc9f28d Deleting client_id from offset commit and fetch response as per Kafka trunk code Ashish Walia 2014-01-07 12:30:52 -05:00
• 55816493c7 Syncing offset commit and fetch api keys with Kafka trunk code Ashish Walia 2014-01-07 12:27:50 -05:00
• a0c7141e2c Change log.error() back to log.exception() Omar Ghishan 2014-01-08 11:46:10 -08:00
• 317c848016 Change BufferUnderflowError to ConnectionError in conn._read_bytes() Both errors are handled the same way when raised and caught, so this makes sense. Omar Ghishan 2014-01-08 11:30:15 -08:00
• 354fcdbdd9 Merge pull request #66 from jcrobak/fix-import-collision David Arthur 2014-01-08 06:33:48 -08:00
• 9cbe45d235 Some cleanup and easier to read test fixture output Omar Ghishan 2014-01-07 17:54:05 -08:00
• f333e9154d Skip snappy/gzip tests if they're not available Omar Ghishan 2014-01-07 17:46:01 -08:00
• 20776539f0 Remove unnecessary method Omar Ghishan 2014-01-07 17:27:21 -08:00
• b4c20acf24 Handle dirty flag in conn.recv() Omar Ghishan 2014-01-07 17:26:09 -08:00
• e5a5477d34 Use the same timeout when reinitializing a connection Omar Ghishan 2014-01-07 17:23:30 -08:00
• e0c45ff898 Add object type and ID to message prefix in fixtures output for easier debugging Omar Ghishan 2014-01-06 14:16:11 -08:00
• c11ff042bf Make kafka brokers per-test in failover integration tests Omar Ghishan 2014-01-06 14:09:16 -08:00