delta/python-packages/kafka-python.git - github.com: mumrah/kafka-python.git

	Commit message (Expand)	Author	Age	Files	Lines
*	Raise non-API exceptions (#1316)	Jeff Widman	2017-12-21	1	-5/+1
*	use python standard max value (#1303)	lukeWx	2017-12-07	1	-1/+1
*	Add DefaultRecordBatch implementation aka V2 message format parser/builder. (...	Taras Voinarovskyi	2017-10-25	1	-4/+11
*	Fix overriding sasl_kerberos_service_name in KafkaConsumer / KafkaProducer (#...	Nathanael Smith	2017-10-17	1	-0/+3
*	Added minor fixes for PR review	Taras	2017-10-12	1	-1/+1
*	Remove the check for timestamp None in producer, as it's done in RecordBatch ...	Taras	2017-10-12	1	-2/+0
*	Refactor MessageSet and Message into LegacyRecordBatch to later support v2 me...	Taras	2017-10-11	1	-9/+34
*	Expand metrics docs (#1243)	Jeff Widman	2017-10-08	1	-6/+15
*	Add note, that `max_in_flight_requests_per_connection>1` may change order or ...	Taras Voinarovskyi	2017-07-17	1	-1/+4
*	producer: fix produce timeout message (#1151)	Mika Eloranta	2017-07-17	1	-1/+1
*	producer: Set exit timeout to 0 for atexit handler to match __del__ (#1126)	Hannu Valtonen	2017-06-19	1	-1/+1
*	KIP-144: Exponential backoff for broker reconnections (#1124)	Dana Powers	2017-06-19	1	-0/+9
*	Update exception docstring	Andrew Kowalik	2017-06-16	1	-1/+1
*	raise KafkaTimeoutException when flush times out	Andrew Kowalik	2017-06-16	1	-0/+4
*	Follow-up to #1068: remove not-implemented comments	Dana Powers	2017-04-10	1	-1/+1
*	Timeout idle connections via connections_max_idle_ms (#1068)	Dana Powers	2017-04-10	1	-1/+1
*	Fixup :meth: sphinx documentation for use in KafkaConsumer.rst etc	Dana Powers	2017-03-07	1	-12/+14
*	change default timeout of KafkaProducer.close() to threading.TIMEOUT_MAX	gaosheng	2017-03-06	1	-2/+6
*	Add sphinx formatting to hyperlink methods (#898)	Jeff Widman	2017-03-03	1	-8/+8
*	Replace %s with %r in producer debug log message (#973)	Alex	2017-03-03	1	-1/+1
*	Fix BrokerConnection api_version docs default (#909)	Jeff Widman	2017-02-28	1	-4/+4
*	PEP-8: Spacing & removed unused imports (#899)	Jeff Widman	2017-02-09	1	-4/+4
*	Add kafka.serializer interfaces (#912)	Dana Powers	2016-12-19	1	-12/+13
*	Sort partitions before calling partitioner (#905)	ms7s	2016-12-19	1	-1/+1
*	Fixup doc references to max_in_flight_requests_per_connection	Dana Powers	2016-12-17	1	-1/+1
*	DOC: Fix typo 'Defualt' -> 'Default'. (#895)	Rolando (Max) Espinoza	2016-11-30	1	-1/+1
*	Added ssl_password config option to KafkaProducer class, identical to… (#830)	kierkegaard13	2016-09-15	1	-0/+3
*	Improve KafkaProducer docstring re retries config	Dana Powers	2016-08-20	1	-3/+5
*	Instrument bufferpool-wait-ratio metric in KafkaProducerconn_metrics	Dana Powers	2016-08-04	1	-1/+1
*	Fix misspelling of "password" (#793)	Samuel Taylor	2016-08-04	1	-1/+1
*	implement sasl PLAIN mechanism	Lars Jørgen Solberg	2016-08-03	1	-1/+12
*	Clarify api_version=str deprecation warning	Dana Powers	2016-08-02	1	-1/+1
*	Rename _DEFAULT_CONFIG -> DEFAULT_CONFIG in KafkaProducer (#788)	Dana Powers	2016-08-01	1	-2/+2
*	Use socket_options configuration to setsockopts(). Default TCP_NODELAY (#783)	Dana Powers	2016-08-01	1	-0/+5
*	Add KafkaClient metricsmore_metrics	Dana Powers	2016-07-17	1	-1/+2
*	KAFKA-3196: Add checksum and size to RecordMetadata and ConsumerRecord (#770...	Dana Powers	2016-07-17	1	-4/+6
*	Expose selector type as config option (#764)	Dana Powers	2016-07-16	1	-1/+5
*	Update kafka configuration links -> 0.10.0.0 docs	Dana Powers	2016-07-16	1	-1/+1
*	First stab at public metrics() interface for KafkaConsumer / KafkaProducer	Dana Powers	2016-07-16	1	-0/+15
*	Add initial producer-sender metrics	Dana Powers	2016-07-16	1	-2/+23
*	Add api_version config to KafkaClient, deprecate str in favor of tuples (#761)	Dana Powers	2016-07-16	1	-12/+18
*	Avoid AttributeErrors in _unregister_cleanup (#747)	Dana Powers	2016-07-05	1	-1/+1
*	allow client.check_version timeout to be set in Producer and Consumer constru...	eastlondoner	2016-06-29	1	-1/+5
*	Clarify timeout unit (#734)	ms7s	2016-06-21	1	-1/+8
*	Use weakref when registering a producer.close atexit to fix normal gc (#728)	Dana Powers	2016-06-18	1	-3/+37
*	KAFKA-3197: when max.in.flight.request.per.connection = 1, attempt to guarant...	Dana Powers	2016-05-22	1	-0/+2
*	Use Fetch/Produce API v2 for brokers >= 0.10 (uses message format v1) (#694)	Dana Powers	2016-05-22	1	-1/+2
*	KAFKA-3025: Message v1 -- add timetamp and use relative offset in compressed ...	Dana Powers	2016-05-22	1	-4/+11
*	Add CRL support to SSL support (#683)	Vincent Bernat	2016-05-19	1	-0/+6
*	Add protocol support for ApiVersionRequest; identify 0.10 brokers in check_ve...check_version_0_10	Dana Powers	2016-05-02	1	-1/+1