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

• 7f150a2170 Optimize sending of batch messages Mahendra M 2013-06-26 17:23:57 +05:30
• 8b25625c7f Got batched mode to work properly Mahendra M 2013-06-26 14:57:20 +05:30
• c6626fe87e Make README self-containing Mahendra M 2013-06-26 13:56:22 +05:30
• 0c0e163894 Update README with examples Mahendra M 2013-06-26 13:54:12 +05:30
• efb1dabd13 Add support for batched message send Mahendra M 2013-06-26 11:41:05 +05:30
• b224f28e98 Fixing link in CHANGES.md David Arthur 2013-06-25 10:19:53 -03:00
• 7a5eed9f1f Change auto_commit to False in SimpleConsumer David Arthur 2013-06-25 09:18:31 -04:00
• 2ce3217718 Merge branch 'master' into partition Mahendra M 2013-06-25 18:33:07 +05:30
• ec251efc56 Merge branch 'master' into asyncproducer Mahendra M 2013-06-25 18:30:44 +05:30
• 64b757868a Merge pull request #31 from mahendra/lazythread David Arthur 2013-06-25 05:56:08 -07:00
• 65c8eb1f9f Got MultiProcessConsumer working Mahendra M 2013-06-25 18:17:39 +05:30
• 99da57f98a Added some comments about message state Mahendra M 2013-06-25 17:06:16 +05:30
• b022be28de Implement blocking get_messages for SimpleConsumer Mahendra M 2013-06-25 17:01:32 +05:30
• 119d4114f9 Merge branch 'master' into lazythread Mahendra M 2013-06-25 12:42:22 +05:30
• 2e38a52732 Added the modules in __init__.py Mahendra M 2013-06-25 11:54:07 +05:30
• c7dfebaa8d Added more documentation and clean up duplicate code Mahendra M 2013-06-25 11:36:34 +05:30
• e85190e6f6 Minor bug fix Mahendra M 2013-06-24 18:14:04 +05:30
• b578725fc3 Add support for multi-process consumer Mahendra M 2013-06-24 18:05:13 +05:30
• eee55aec26 Add exports in __init__ Mahendra M 2013-06-24 18:03:56 +05:30
• e690b75590 Make the default case as 'ack on local write' Mahendra M 2013-06-20 19:19:08 +05:30
• 612dea17c3 Fix import errors Mahendra M 2013-06-20 18:38:52 +05:30
• 6158e29d27 Update README with new options Mahendra M 2013-06-20 15:03:29 +05:30
• c2c555798e Add ack support for synchronous producer Mahendra M 2013-06-20 14:58:33 +05:30
• aec388474e Merge branch 'master' into partition Mahendra M 2013-06-20 12:57:38 +05:30
• 604d78bf58 Merge branch 'master' into asyncproducer Mahendra M 2013-06-13 18:50:14 +05:30
• 883eed1f8c Merge pull request #32 from mahendra/keyed David Arthur 2013-06-13 06:03:36 -07:00
• 337127a77d Support for async producer Mahendra M 2013-06-13 17:51:26 +05:30
• 0723cf8bec Better examples in README Mahendra M 2013-06-13 14:43:23 +05:30
• d3cf18a9fb Fix bugs and testing Mahendra M 2013-06-13 14:40:09 +05:30
• ac76520bf8 Fix markup in README Mahendra M 2013-06-13 14:13:32 +05:30
• b2a65033fc Implement support for Keyed producer Mahendra M 2013-06-13 14:11:33 +05:30
• ab72da3db3 Add support to consume messages from specific partitions Mahendra M 2013-06-12 14:56:58 +05:30
• 28884c80f3 Fix an issue with thread argument Mahendra M 2013-06-12 13:58:15 +05:30
• b0c87eed08 Optimize auto-commit thread Mahendra M 2013-06-12 13:42:24 +05:30
• a4601d3a1b Spawn the commit thread only if necessary Mahendra M 2013-06-11 14:44:45 +05:30
• 77b8301e25 Merge pull request #29 from mahendra/threading David Arthur 2013-06-10 06:04:20 -07:00
• 40506c2830 Merge branch 'issue-28' David Arthur 2013-06-07 21:21:03 -04:00
• dd109e2d6a Bootstrap distribute/tox with setuptools David Arthur 2013-06-07 21:17:05 -04:00
• 499038118b Use 127.0.0.1 instead of localhost Ivan Pouzyrevsky 2013-06-02 14:25:58 +04:00
• bdad6a16bb Ignore MANIFEST Ivan Pouzyrevsky 2013-06-02 14:20:04 +04:00
• 800a5125d7 Update README.md Ivan Pouzyrevsky 2013-06-02 14:19:55 +04:00
• 60200c671b toxify all the tests and use xfail marks Ivan Pouzyrevsky 2013-06-02 12:31:42 +04:00
• 2bd2dbcc9b Split fixtures out to a separate file Ivan Pouzyrevsky 2013-06-02 12:29:25 +04:00
• d7178e188e Beautify codec.py Ivan Pouzyrevsky 2013-06-02 02:04:30 +04:00
• f444caaee7 Adhere to common python naming conventions Ivan Pouzyrevsky 2013-06-02 01:32:26 +04:00
• e073b3310d Refactor and update integration tests Ivan Pouzyrevsky 2013-06-02 01:26:14 +04:00
• 6704050e50 Finish making remaining files pep8 ready Mahendra M 2013-05-31 14:57:57 +05:30
• 437889d00b Fix auto-commit issues with multi-threading Mahendra M 2013-06-03 20:23:04 +05:30
• 58288d9f86 Updating authors with links to github profiles David Arthur 2013-06-01 15:14:01 -03:00
• d0cb38cdd9 Adding authors file David Arthur 2013-06-01 00:18:21 -04:00
• 2c257eeb1f PEP8-ify most of the files Mahendra M 2013-05-29 14:20:58 +05:30
• 97962d4af3 Removing the bit about offsets David Arthur 2013-05-29 16:25:42 -04:00
• a8e423c7e7 Minor bug fixes Mahendra M 2013-05-27 13:42:47 +05:30
• 222ef82983 Merge branch 'issue-22' David Arthur 2013-05-28 10:36:55 -04:00
• f4a326f490 Closes #22 David Arthur 2013-05-28 10:35:40 -04:00
• bf8fc04a9f Adding a debug statement David Arthur 2013-04-12 14:18:29 -04:00
• 904157ba2c Merge pull request #23 from mahendra/autocommit David Arthur 2013-05-28 06:39:42 -07:00
• 8fc0407498 Auto commit timer is not periodic Mahendra M 2013-05-28 11:51:57 +05:30
• 7ab7690422 Missed a doc string Mahendra M 2013-05-27 16:47:09 +05:30
• 117c576c93 New API for getting a specified set of messages Mahendra M 2013-05-27 16:41:47 +05:30
• 38215b66eb New API for checking pending message count Mahendra M 2013-05-27 14:54:03 +05:30
• 6327ba38bc Update README.md David Arthur 2013-05-07 21:53:45 -03:00
• eff8d2b861 Fixes #14 David Arthur 2013-04-11 16:03:21 -03:00
• 94a939ac84 Making version number compatible with future versions 0.7 David Arthur 2013-04-02 21:09:07 -04:00
• 7c604697be Merge branch 'master' into 0.8 0.8 David Arthur 2013-04-02 20:38:55 -04:00
• bff6cae885 A few fixes for offset APIs in 0.8.1 David Arthur 2013-04-02 20:35:22 -04:00
• fd45ca5933 Update README and setup.py with new version David Arthur 2013-04-02 20:18:55 -04:00
• c275c023c5 Update kafka-src to latest trunk, enable 0.8.1 features David Arthur 2013-04-02 19:55:51 -04:00
• 2690a5da96 Typo in example.py David Arthur 2013-04-02 19:54:41 -04:00
• 1c5081e6b3 Update kafka-src to latest 0.8 David Arthur 2013-04-01 22:06:20 -04:00
• fa13fa88d8 Update README with new APIs David Arthur 2013-04-01 21:10:51 -04:00
• 864430c8c8 Bring acks and timeout down to the client David Arthur 2013-04-01 21:09:48 -04:00
• 0678a452ca Refactoring a bit, cleanup for 0.8 David Arthur 2013-04-01 14:56:59 -04:00
• b6d98c07b4 Big code re-org David Arthur 2013-03-30 00:28:00 -04:00
• 3499e2f6ea Some work on a simple consumer David Arthur 2013-03-19 14:03:51 -04:00
• 1b721325fe Started on a simple producer and consumer David Arthur 2013-03-08 19:56:51 -05:00
• 8fab55ad19 Removing __main__ stuff from client.py David Arthur 2013-03-01 15:32:32 -05:00
• eac51e9c68 Integration tests passing David Arthur 2013-03-01 15:12:21 -05:00
• 2a3d231aa6 Protocol and low-level client done, adding tests David Arthur 2013-02-22 23:09:25 -05:00
• e87c561723 Fix a bunch of bugs David Arthur 2013-02-20 22:05:21 -05:00
• 8b70b9cf6a First pass of cleanup/refactoring David Arthur 2013-02-20 10:34:34 -05:00
• 71fef1b155 Starting work on 0.8 compat David Arthur 2013-02-13 10:22:13 -05:00
• 0bc2afe910 Adding client_fetch_size to queue interface David Arthur 2012-11-20 10:16:15 -05:00
• 53da81c176 Typo in example.py David Arthur 2013-04-02 19:54:41 -04:00
• c13f1d8514 Update kafka-src to latest 0.8 David Arthur 2013-04-01 22:06:20 -04:00
• d71af27f5b Update README with new APIs David Arthur 2013-04-01 21:10:51 -04:00
• c04820dbca Bring acks and timeout down to the client David Arthur 2013-04-01 21:09:48 -04:00
• 8bf624e710 Refactoring a bit, cleanup for 0.8 David Arthur 2013-04-01 14:56:59 -04:00
• 4f94568496 Big code re-org David Arthur 2013-03-30 00:28:00 -04:00
• 1c4e8a53ca Some work on a simple consumer David Arthur 2013-03-19 14:03:51 -04:00
• 8325845ccb Started on a simple producer and consumer David Arthur 2013-03-08 19:56:51 -05:00
• c640e981d3 Removing __main__ stuff from client.py David Arthur 2013-03-01 15:32:32 -05:00
• efcb4a2143 Integration tests passing David Arthur 2013-03-01 15:12:21 -05:00
• d0abb076e0 Protocol and low-level client done, adding tests David Arthur 2013-02-22 23:09:25 -05:00
• 5eb79c04a1 Fix a bunch of bugs David Arthur 2013-02-20 22:05:21 -05:00
• 3f0d91883d First pass of cleanup/refactoring David Arthur 2013-02-20 10:34:34 -05:00
• 2e53ac900c Starting work on 0.8 compat David Arthur 2013-02-13 10:22:13 -05:00
• 40e49dce48 Fix some typos, closes #12 David Arthur 2013-01-26 14:26:19 -05:00
• 81ff0f5991 Merge pull request #11 from anentropic/master David Arthur 2012-11-22 06:55:32 -08:00
• 60aef76a9a fix docs: iter_messages doesn't (any longer?) take a FetchRequest anentropic 2012-11-22 13:18:34 +00:00