index
:
delta/python-packages/kafka-python.git
0.10.0.1
0.7
0.8
0.9
0_10_1_0
0_10_1_1
0_11_0_0
0_11_0_1
0_11_0_2
0_8_2_protocol_parser_too
1.3.5
1.4.7
1193-remove-old-simple-clients
1212-stop-using-mutable-types-for-default-arg-values
1274-producer-raise-non-api-exceptions
1_0_1
1_4_0
709
741
KAFKA-3117
KAFKA-3196
KAFKA-3197
KAFKA-3388
KAFKA-3486
KAFKA-3960
KAFKA-8962-use-least-loaded-node-for-admin-describe-topics
KAFKA_3888_heartbeat_thread
KAFKA_3949_subscription_metadata_race
KAFKA_3977_defer_fetch_parsing
KAFKA_4034_coordinator_lookup
KAFKA_4160_rebalance_listener_lock
KAFKA_4160_rebalance_listener_without_lock
KAFKA_5512_notify_heartbeat_thread
Remove-deprecated-ConnectionError
Remove-deprecated-smallest-largest
Remove-support-for-api_version-strings
Remove-weird-comment-line
Stop-shadowing-native-python-ConnectionError-exception
Update-docs-api_version_auto_timeout_ms
absolute_import
accumulator_bugfix
add-a-snappy-dose-of-https
add-group-coordinator-lookup
add-license-to-wheel
add-list-consumer-groups-offsets
add-lz4-and-snappy-to-extras_require
add-python-37-support
add_makefile
add_new_api_versions
admin_client_unpack_errors
any_api_version
appveyor
async_connect_send
async_producer_connect_errors
async_producer_stop
at_exit_weakref
auth_recv
authenticate_future_handling
await_reserved
backoff_conn_reconnect
backoff_coordinator_retry
batch_expiration_message
batch_size_zero
be-explicit-with-validate_only
benchmark_fixups
benchmarks
better-struct-errors
blackout_timer
bootstrap_cluster
bootstrap_cluster_metadata
bootstrap_dns_lookup
bootstrap_select
break-consumer-operations-into-request-response-methods
break-find-group-coordinator-into-request-response-methods
bump-lz4
bump-vendored-six-to-1.11.0
bump_versions
cancel_in_flight
catch_socket_error
check-for-none-in-on-join-complete
check-for-none-rather-than-false
check_invalid_metadata
check_version
check_version_0_10
clean_drain_coordinator_requests
cleanup-install-instructions-for-optional-libs
cleanup-kafka-admin-test-formatting
cleanup-max-bytes-tests
cleanup-testing-doc
cleanups
clear_gai_cache
client_api_version
client_send_race
close_consumer_tests
combine_send_bytes
commit_failed_message_fixup
compacted_offsets
config_selector
conn_check_version_max_in_flight
conn_close_short_circuit
conn_delay_ms
conn_immutable_host_port_afi
conn_legacy
conn_lock_async_send
conn_lock_release_gssapi_oauth
conn_logging_cleanups
conn_loop_bytes
conn_metrics
conn_metrics_fix
conn_send_buffer
conn_send_timeout
conn_state_callback
conn_state_change
connect_blocking
connect_blocking_fixups
connection_delay_inf
connection_error_close
consumer_heartbeat_fixes
consumer_iterator
consumer_iterator_with_poll
consumer_poll_sleep
consumer_rejoin_fixes
convert-remaining-unittests-to-pytest
coordinator_client_deadlock
coordinator_dead_error_logging
coordinator_del
coordinator_lock_order
coordinator_tests
coordinator_unknown_heartbeat
create_topics_v1
decode_errors
default_no_consumer_group
defer_version_check
delay-units-conversion-til-last-possiblepoint
deprecation_warnings
differentiate-between-client-and-broker-version-errors
disconnects
docstring-pep8-cleanup
document-methods-returning-none
dont-support-api-version-strings
dont-use-broker-errors-for-client-side-problems
dont-use-kafka.common-internally
double_compression
drain_pending_coordinator_requests
drain_requests_join_group
drop_pytest_sugar
empty_broker_list_metadata
errors
except_timeout
exclude_internal_topics
exp_backoff
expand-metrics-docs
fast_lookup_coordinator_reset
faster_validate_crc
fetch
fetch_compacted_offset
fetch_partition_compressed_offset
fetch_poll_backoff
fetchable_key_error
fetcher_offset_out_of_range
fetcher_randomize_order
fetcher_send_no_wakeup
finish-bumping-lz4
fix-describe-groups
fix-list-groups-to-query-all-brokers
fix-minor-bug-with-printing-bytes-instance
fix-send-to-controller
fix-sphinx-docs
fix-sphinx-url
fix-typod-test-file-name
fix_close_socket_attribute_error
fix_fixture_version_warning
fix_leaks
fix_memory_records_typo
fix_records
fix_sasl_reconnect
fix_tests_1_4_7
fixture_auto_ports
french_connection
fresh_brokers
gc_debug
gen_ssl_resource
get_api_versions_fix
group_id_none
gssapi_authentication_complete
handle_api_versions
handle_disconnect
heartbeat_cleanups
heartbeat_logging
heartbeat_wait_brokers_down
hw_crc32c
idle_sleep
initial_metadata_snapshot
ipv6_scope_id
issue-1082-offset-and-metadata
issue-1088-full-topic-metadata-skip-error-logging
issue-1219-closed-consumer
issue-1931-logging-producer-deadlock
issue-1943-coordinator-node-not-ready-debug
issue-1963-reset-override-configs
issue-26
issue1036_offset_by_time
issue1155
issue_1399
issue_619
iterator_fetches
iterator_timeout
jeffwidman-patch-1
join_future_race
kafka-0.8.0-release
kafka-2136
kafka-2978
kafka-3318
kafka-snake
kafka_1_0_0
kafka_conn_locking_too
kafka_conn_with_lock
kafka_error_str
kafka_producer
kafka_version_tests
larsjsol-sasl_plain
leak_z4
least_loaded_node
legacy_records_refactor
lock_client_check_version
log_check_version
lower_consumer_timeout
lz4
lz4_0_10
lz4_fixup
master
max_poll_records
max_records_int
maybe_refreh_metadata_reconnect_delay
maybe_refresh_metadata_no_wakeup
merge-_find_coordinator_ids-methods
message_format_v1
message_set_encode_size
metadata_refresh_backoff
metadata_v1
metadata_wait_for_connect
metadata_with_partitions
migrate-from-unittest-to-pytest
minor-exception-cleanup
mock_dns_test_conn
more_errors
more_gssapi_fixes
more_metrics
more_sasl_fixes
murmur2_ascii
name_node
no_ifrs_short_poll
no_sleep
no_sleep_til_brooklyn
node_not_ready
nonblocking_wake_sockets
none_least_loaded_node
null_logger
old_ssl_exception
partial_messages
pending_completions
pin_deps
popped_conn_close
produce_fetch_v2
producer_defaults
producer_new_topic
protocol_1_0_0
protocol_parser
protocol_updates
protocol_versions
pylint_1_8_2
pylint_fixup
queue-fixup
range_assignor
ready_metadata_kwarg
receive_bytes_pipe
reconnect_backoff_gai
reconnect_backoff_max_ms_doc_update
record_metadata_simplify
reduce_client_locks
refactor
reference_cleanup_close
release
release-0.9.x
remove-pylint-hack
remove-some-unused-code
remove-unused-import
remove-unused-skip_double_compressed_messages
remove_bad_test
request_response_classes
request_timeout_docs
reset_reconnect_backoff_connected
return_state_conn_fix
revert-1345-heartbeat_cleanups
sansio
sasl_fixes
selector_close
selectors
send_first_poll
sender_dont_wakeup
sensor_quota_message
separate_coordinator_conn
serialize_interface
short_circuit_node_not_ready
simple
simple_producer_async_send
simplify-version-checking-using-pytest-skipif
six
skip_autocommit_consumer_close
skip_integration_tests
sock_send_bytes
socket_buffer_size_optional
socket_options
ssl_handshake_errors
ssl_set_ciphers
ssl_support
state_change_callback_no_lock_close
stop-pinning-pylint
streams
struct-pre-compilation
struct_kwargs
subscription_copy
task_poll_timeout
test_cleanups
testing
threadsafe_pending_responses
timeout_idle_connections
timeout_noresponse
timeout_ssl_conn
topic_partition_type_error
travis_upgrade
truncate_buffer
unrecurse_unpack_message_set
update-rtd-links
use-TypeError
use-explicit-tuples-for-strings
use-raw-in-case-string-overriden
v2_records
validate_serialized_bytes
vendor-enum34
vendor-six-consistently
verify-timeouts-set-correctly
wait_for_it_1_0_0
waiting_on_godot
wake_socketpair_exceptions
warn_dns_error
windows
workaround-pylint-bug
wrap_ssl_after_connect
zk_autocommit
github.com: mumrah/kafka-python.git
summary
refs
log
tree
commit
diff
log msg
author
committer
range
Commit message (
Expand
)
Author
Age
Files
Lines
*
Add KafkaConsumer.close() PR to CHANGES
Dana Powers
2015-12-06
1
-0
/
+1
*
Merge pull request #426 from ucarion/ucarion-kafkaconsumer-close
Dana Powers
2015-12-06
1
-0
/
+4
|
\
|
*
Add KafkaConsumer#close
Ulysse Carion
2015-07-07
1
-0
/
+4
*
|
Update Changelog in preparation for 0.9.5 release
Dana Powers
2015-12-06
1
-0
/
+37
*
|
Log deprecation warning for timeout argument in Producer.stop()
Dana Powers
2015-12-06
1
-3
/
+7
*
|
Merge pull request #485 from dpkp/async_producer_stop
Dana Powers
2015-12-05
3
-16
/
+15
|
\
\
|
*
|
Producer.stop() now blocks until async thread completes (drop confusing timeo...
async_producer_stop
Dana Powers
2015-12-05
1
-7
/
+12
|
*
|
Revert broken send_produce_request try/except from PR 467 (resps=None)
Dana Powers
2015-12-05
1
-5
/
+1
|
*
|
Use producer.stop() to flush messages in async producer test
Dana Powers
2015-12-05
1
-4
/
+2
|
/
/
*
|
Fix requestId handling in send_broker_aware_request
Dana Powers
2015-12-04
1
-2
/
+2
*
|
Cleanup new producer tests...
async_producer_connect_errors
Dana Powers
2015-12-04
1
-6
/
+6
*
|
client.reinit() can raise an exception; catch in async producer
Dana Powers
2015-12-04
1
-2
/
+10
*
|
Update kafka broker list for travis testing (add 0.9.0.0, bump 0.8.2.2)
Dana Powers
2015-12-04
1
-1
/
+2
*
|
Update setup.py to show python 3.5 compatibility explicitly
Dana Powers
2015-12-04
1
-0
/
+1
*
|
Add py35 to tox testing
Dana Powers
2015-12-04
2
-5
/
+9
*
|
Cache pip and servers/ for travis builds
Dana Powers
2015-12-04
1
-0
/
+5
*
|
Update travis config to use container infrastructure
Dana Powers
2015-12-04
1
-4
/
+8
*
|
Add 0.8.2.2 and 0.9.0.0 resources for integration tests; update default offic...
Dana Powers
2015-12-04
7
-1
/
+339
*
|
Update docs and links wrt maintainer change (mumrah -> dpkp)
Dana Powers
2015-12-03
5
-25
/
+55
*
|
Merge pull request #481 from zackdever/pylint-1.5-changes
Dana Powers
2015-12-03
3
-3
/
+3
|
\
\
|
*
|
new pylint disables for pylint 1.5.1
Zack Dever
2015-12-02
3
-3
/
+3
|
/
/
*
|
Merge pull request #420 from toddpalino/master
Dana Powers
2015-12-02
4
-7
/
+226
|
\
\
|
*
|
Fix misnamed node to nodeId in test
tpalino
2015-07-02
1
-1
/
+1
|
*
|
Add missing import for ConsumerMetadataResponse
tpalino
2015-07-01
1
-1
/
+1
|
*
|
Support consumer metadata requests
tpalino
2015-07-01
4
-6
/
+225
|
|
/
*
|
Fix python3 / python2 comments re queue/Queue
Dana Powers
2015-12-02
2
-10
/
+10
*
|
Add Murmur2Partitioner to kafka __all__ imports - fix issue 471
Dana Powers
2015-12-02
1
-1
/
+1
*
|
Merge pull request #473 from ecanzonieri/use_unblocking_io_for_aware_requests
Dana Powers
2015-12-02
3
-18
/
+52
|
\
\
|
*
|
Add tests. Bug fix. Rename socket_conn dict.
Enrico Canzonieri
2015-11-10
2
-7
/
+24
|
*
|
Unblocking broker aware request
Enrico Canzonieri
2015-11-10
2
-18
/
+35
*
|
|
Merge pull request #467 from bschopman/master
Dana Powers
2015-12-02
2
-2
/
+9
|
\
\
\
|
*
|
|
Prevents crashing communication thread of async producer
Balthasar Schopman
2015-10-22
2
-2
/
+9
|
|
/
/
*
|
|
Merge pull request #457 from saaros/block-for-number-of-messages
Dana Powers
2015-12-02
3
-11
/
+36
|
\
\
\
|
*
|
|
Consumers get_messages: allow blocking until some messages are received
Oskari Saarenmaa
2015-09-18
3
-11
/
+36
*
|
|
|
Merge pull request #446 from zackdever/consumer-class-configs
Dana Powers
2015-12-02
1
-2
/
+3
|
\
\
\
\
|
*
|
|
|
set default config on consumer class to support subclass config changes.
Zack Dever
2015-08-13
1
-2
/
+3
|
|
|
_
|
/
|
|
/
|
|
*
|
|
|
Merge pull request #456 from barricadeio/mp-retry
Dana Powers
2015-12-02
3
-46
/
+63
|
\
\
\
\
|
*
|
|
|
Support retry semantics in MultiProcessConsumer
Ross Duggan
2015-09-14
3
-46
/
+63
|
|
|
/
/
|
|
/
|
|
*
|
|
|
Merge pull request #454 from trbs/gzip_compressionlevel
Dana Powers
2015-12-02
3
-10
/
+17
|
\
\
\
\
|
*
|
|
|
allow to specify compression level for codecs which support this
trbs
2015-09-12
3
-10
/
+17
|
|
/
/
/
*
|
|
|
Merge pull request #441 from koobs/patch-1
Dana Powers
2015-12-02
1
-0
/
+1
|
\
\
\
\
|
*
|
|
|
Include LICENSE in PyPI sdist
Kubilay Kocak
2015-07-31
1
-0
/
+1
|
|
|
/
/
|
|
/
|
|
*
|
|
|
Merge pull request #439 from chrischamberlin/fix-murmur
Dana Powers
2015-12-02
2
-10
/
+35
|
\
\
\
\
|
*
|
|
|
Fix translation of Java murmur2 code, fix byte encoding for Python 3.
Chris Chamberlin
2015-07-28
2
-10
/
+35
|
|
/
/
/
*
|
|
|
Merge pull request #435 from docker-hub/fix-producer-cleanup-logic
Dana Powers
2015-12-02
2
-1
/
+15
|
\
\
\
\
|
*
|
|
|
Fixing https://github.com/mumrah/kafka-python/issues/434
toli
2015-07-24
2
-1
/
+15
*
|
|
|
|
Merge pull request #418 from scrapinghub/mp_partition_info
Dana Powers
2015-12-02
3
-8
/
+10
|
\
\
\
\
\
|
*
|
|
|
|
allow to retrieve partition info in mp consumer
Martin Olveyra
2015-06-29
3
-8
/
+10
|
|
|
/
/
/
|
|
/
|
|
|
*
|
|
|
|
Merge pull request #409 from scrapinghub/feature-allow-null-payload
Dana Powers
2015-12-02
3
-5
/
+53
|
\
\
\
\
\
|
|
_
|
_
|
_
|
/
|
/
|
|
|
|
|
*
|
|
|
Producer test fix for python3
Viktor Shlapakov
2015-06-17
1
-1
/
+1
[next]