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

	Commit message (Collapse)	Author	Age	Files	Lines
*	Expand metrics docs (#1243)	Jeff Widman	2017-10-08	1	-6/+15
\| \| \| \| \| \|	* Expand metrics docstrings * Document metrics interface in readme * Use six.iteritems(d) rather than d.items() * Use Sphinx warning syntax
*	Remove a few unused imports (#1188)	James Lamb	2017-08-29	1	-1/+1
\| \| \| \| \|	* Removed a few unused imports * Added note on socketpair monkey-path
*	Drop unused sleep kwarg to poll (#1177)	Dana Powers	2017-08-15	1	-1/+1
\|
*	Fix batch expiry messages to state seconds	Dominic Evans	2017-07-26	1	-3/+3
\| \| \| \| \|	time.time() is seconds since epoch, and the deltas are also calculated in seconds
*	Add note, that `max_in_flight_requests_per_connection>1` may change order or ↵	Taras Voinarovskyi	2017-07-17	1	-1/+4
\| \| \| \|	messages (#1149)
*	producer: fix produce timeout message (#1151)	Mika Eloranta	2017-07-17	1	-1/+1
\|
*	Use logging's built-in string interpolation	Jeff Widman	2017-07-07	1	-2/+1
\|
*	producer: Set exit timeout to 0 for atexit handler to match __del__ (#1126)	Hannu Valtonen	2017-06-19	1	-1/+1
\| \| \| \| \| \| \| \|	Hit a problem with pytest hitting the atexit handler and waiting for close() timeout forever at teardown. This commit makes atexit close() equivalent to __del__ behavior, namely using timeout of 0 for close() completion. If you need a longer timeout you should be setting it explicitly.
*	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	2	-2/+9
\|
*	Improve error message when expiring batches in KafkaProducer (#1077)	Dana Powers	2017-05-03	1	-7/+11
\|
*	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	2	-11/+13
\|
*	Replace %s with %r in producer debug log message (#973)	Alex	2017-03-03	1	-1/+1
\|
*	Issue 985: Clear memory wait condition before raising Exception (#999)	Dana Powers	2017-03-02	1	-0/+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	2	-6/+6
\|
*	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	2	-2/+2
\|
*	DOC: Fix typo 'Defualt' -> 'Default'. (#895)	Rolando (Max) Espinoza	2016-11-30	1	-1/+1
\|
*	:wPass timestamp into Message, not just mimic it (#875)	Taras Voinarovskyi	2016-11-18	1	-2/+6
\|
*	Fix typos	Jeff Widman	2016-11-14	1	-1/+1
\|
*	Added ssl_password config option to KafkaProducer class, identical to… (#830)	kierkegaard13	2016-09-15	1	-0/+3
\| \| \| \| \| \| \| \|	* Added ssl_password config option to KafkaProducer class, identical to option in KafkaConsumer class * removed non-ascii characters * changed - to : in comments
*	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	3	-8/+17
\|
*	Instrument metrics in BrokerConnection	Dana Powers	2016-08-04	1	-17/+0
\|
*	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
\|
*	Always absolute_importabsolute_import	Dana Powers	2016-08-02	1	-0/+2
\|
*	Clarify api_version=str deprecation warning	Dana Powers	2016-08-02	1	-1/+1
\|
*	Merge pull request #785 from dpkp/six	Dana Powers	2016-08-01	3	-3/+3
\|\ \| \| \| \|	Vendor python module six; move selectors34 and socketpair under kafka.vendor
\| *	Vendor six 1.10.0six	Dana Powers	2016-08-01	3	-3/+3
\| \|
* \|	Rename _DEFAULT_CONFIG -> DEFAULT_CONFIG in KafkaProducer (#788)	Dana Powers	2016-08-01	3	-6/+6
\|/ \| \|	- also update internal classes RecordAccumulator and Sender
*	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
\|
*	Record produce latency and throttling metrics	Dana Powers	2016-07-17	1	-4/+9
\|
*	Avoid buffer overread when compressing messageset in KafkaProducer	Dana Powers	2016-07-17	1	-1/+2
\|
*	KAFKA-3196: Add checksum and size to RecordMetadata and ConsumerRecord ↵	Dana Powers	2016-07-17	4	-16/+30
\| \| \| \|	(#770 / #594)
*	Simplify RecordMetadata; short circuit callbacks (#768)	Dana Powers	2016-07-17	1	-19/+7
\| \| \| \|	Simplify RecordMetadata to unaltered namedtuple -- minor speed optimization Minor optimization: inline check for no callbacks
*	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	4	-13/+250
\|
*	Add api_version config to KafkaClient, deprecate str in favor of tuples (#761)	Dana Powers	2016-07-16	1	-12/+18
\|
*	Fix bug causing KafkaProducer to double-compress message batches on retrydouble_compression	Dana Powers	2016-07-14	1	-16/+23
\|