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

	Commit message (Collapse)	Author	Age	Files	Lines
*	Fix conn.connection_delayexp_backoff	Dana Powers	2017-06-19	1	-2/+2
\|
*	Update KafkaConsumer / KafkaProducer docstrings and defaults	Dana Powers	2017-06-18	2	-10/+18
\|
*	Update per KIP-144	Dana Powers	2017-06-18	2	-10/+22
\|
*	Use randomized exponential backoff policy for BrokerConnection	Dana Powers	2017-06-18	4	-22/+49
\|
*	Fixup for #1085 -- only check for changed metadata on disconnected nodes	Dana Powers	2017-06-18	1	-17/+23
\|
*	Deal with brokers that disappear, reappear with different IP address (#1085)	Mike Fischer	2017-06-18	1	-1/+12
\| \| \| \| \| \| \| \| \| \| \| \| \| \| \| \| \| \| \| \|	When KafkaClient connects to a broker in _maybe_connect, it inserts into self._conns a BrokerConnection configured with the current host/port for that node. The BrokerConnection remains there forever, though, so if the broker's IP or host ever changes, KafkaClient has no way to deal with this. The fix is to compare the latest metadata with the current node's connection, and if the host/IP has changed, decommission the old connection and allow a new one to be created. There's also a common race condition on broker startup where the initial metadata request sometimes returns an empty list of brokers, but subsequent requests behave normally. So, we must deal with broker being None here. This change is conservative in that it doesn't remove the connection from self._conns unless the new broker metadata contains an entry for that same node with a new IP/port.
*	Do not test fetched_size with fetch_max_bytes since 0.11 brokers will return ↵	Dana Powers	2017-06-18	1	-3/+0
\| \| \| \|	more data than 0.10
*	Increase max_buffer_size for test_large_messages	Dana Powers	2017-06-18	1	-2/+8
\|
*	Fix fetch_max_bytes=1 consumer integration test	Dana Powers	2017-06-18	1	-10/+10
\|
*	Use fixture hostname (dont assume localhost)	Dana Powers	2017-06-18	2	-2/+2
\|
*	Add 0.11.0.0 server resources (reduced offsets.topic.replication.factor=1)	Dana Powers	2017-06-18	3	-0/+188
\|
*	Describe consumer thread-safety	Linus Wallgren	2017-06-16	4	-3/+25
\|
*	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
\|
*	Follow-up: support manual py26 testing; dont advertise 3.3 support	Dana Powers	2017-06-16	2	-3/+10
\|
*	Add kafka 0.10.2.1 into integration testing version (#1096)	Jianbin Wei	2017-06-16	9	-20/+199
\| \| \| \| \|	* Add kafka 0.10.2.1 into integration testing version * Disable tests for python 2.6 and kafka 0.8.0 and 0.8.1.1 * Remove references to python 2.6 support
*	pylint 1.7.0+ supports python 3.6 and merge py36 into common tstenv (#1095)	Jianbin Wei	2017-05-03	1	-6/+1
\|
*	Improve error message when expiring batches in KafkaProducer (#1077)	Dana Powers	2017-05-03	1	-7/+11
\|
*	Warn dont raise on DNS lookup failures (#1091)	Dana Powers	2017-05-03	1	-5/+7
\|
*	Ignore not-context-manager pylint error (#1092)	Dana Powers	2017-04-29	1	-0/+3
\|
*	Follow-up to #1068: remove not-implemented comments	Dana Powers	2017-04-10	2	-2/+2
\|
*	readthedocs.io follow-up to #1074 for docs/	Dana Powers	2017-04-10	3	-3/+3
\|
*	Update RTD links with https / .io (#1074)	Jeff Widman	2017-04-10	1	-6/+6
\|
*	Timeout idle connections via connections_max_idle_ms (#1068)	Dana Powers	2017-04-10	4	-6/+135
\|
*	Avoid multiple connection attempts when refreshing metadata (#1067)	Dana Powers	2017-04-05	2	-58/+73
\|
*	Catch socket.errors when sending / recving bytes on wake socketpair (#1069)	Dana Powers	2017-04-05	1	-2/+4
\|
*	Fix poll() hyperlink in KafkaClient	Jeff Widman	2017-03-29	1	-1/+1
\| \| \|	Previously Sphinx was auto-linking to `poll()` in `KafkaConsumer`, so made the link explicit.
*	Update README: Prefer python-lz4 over lz4tools (#1057)	Kirill Ignatev	2017-03-27	1	-4/+3
\|
*	Fix typo (#1054)	Jeff Widman	2017-03-27	1	-1/+1
\|
*	Bump version for development	Dana Powers	2017-03-14	1	-1/+1
\|
*	Release 1.3.31.3.3	Dana Powers	2017-03-14	3	-3/+9
\|
*	Derive all api classes from Request / Response base classes (#1030)	Dana Powers	2017-03-14	13	-88/+146
\|
*	Alter test skips: python-lz4 works on python26, but not pypy	Dana Powers	2017-03-14	3	-7/+14
\|
*	LZ4 support in kafka 0.8/0.9 does not accept a ContentSize header	Dana Powers	2017-03-14	1	-6/+14
\|
*	Prefer python-lz4 over lz4f if available	Dana Powers	2017-03-14	4	-15/+37
\|
*	Free lz4 decompression context to avoid leak	Dana Powers	2017-03-14	1	-0/+1
\|
*	Update changelog	Dana Powers	2017-03-13	2	-0/+16
\|
*	Avoid re-encoding for message crc check (#1027)	Dana Powers	2017-03-13	2	-6/+36
\|
*	Additional docstrings for autocommit close option	Dana Powers	2017-03-13	3	-3/+17
\|
*	Optionally skip auto-commit during consumer.close (#1031)	Dana Powers	2017-03-13	2	-4/+5
\|
*	Return copy of consumer subscription set (#1029)	Dana Powers	2017-03-13	2	-1/+9
\|
*	Fix kwarg handing in kafka.protocol.struct.Struct (#1025)	Dana Powers	2017-03-09	2	-2/+21
\|
*	Short-circuit group coordinator requests when NodeNotReady (#995)	Dana Powers	2017-03-09	1	-0/+23
\|
*	Avoid unknown coordinator after client poll (#1023)	Dana Powers	2017-03-09	1	-7/+6
\|
*	Add optional kwarg to ready and is_ready to disable metadata-priority logic ↵	Dana Powers	2017-03-08	1	-7/+16
\| \| \| \|	(#1017)
*	A few Sphinx documentation updates (#1019)	Jeff Widman	2017-03-08	1	-3/+3
\|
*	Fix integration test that requires consumer group	Dana Powers	2017-03-07	1	-1/+4
\|
*	Update changelog	Dana Powers	2017-03-07	2	-0/+8
\|
*	Fixed couple of "leaks" when gc is disabled (#979)	Max Baryshnikov	2017-03-07	4	-16/+27
\|
*	Fixup :meth: sphinx documentation for use in KafkaConsumer.rst etc	Dana Powers	2017-03-07	2	-35/+49
\|