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

summaryrefslogtreecommitdiff

log msg author committer range