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

	Commit message (Expand)	Author	Age	Files	Lines
*	Add kafka.protocol.parser.KafkaProtocol w/ receive and sendprotocol_parser	Dana Powers	2017-09-23	3	-146/+226
*	Merge pull request #1213 from dpkp/1212-stop-using-mutable-types-for-default-...	Taras Voinarovskyi	2017-09-13	1	-9/+9
\|\
\| *	Stop using mutable types for default arg values1212-stop-using-mutable-types-for-default-arg-values	Jeff Widman	2017-09-12	1	-9/+9
* \|	Fix typo	Jeff Widman	2017-09-12	1	-1/+1
\|/
*	remove beginning/end offsets request version limit	Liao Jiayi	2017-09-04	1	-8/+0
*	Remove a few unused imports (#1188)	James Lamb	2017-08-29	4	-4/+3
*	BrokerConnection receive bytes pipe (#1032)	Dana Powers	2017-08-15	4	-93/+121
*	Drop unused sleep kwarg to poll (#1177)	Dana Powers	2017-08-15	4	-14/+9
*	bump version for development	Dana Powers	2017-08-13	1	-1/+1
*	Release 1.3.41.3.4	Dana Powers	2017-08-13	1	-1/+1
*	Initialize metadata_snapshot in group coordinator (#1174)	Dana Powers	2017-08-13	1	-6/+9
*	Select on sockets to avoid busy polling during bootstrap (#1175)	Dana Powers	2017-08-13	1	-0/+2
*	Added unit tests for fetcher's `_reset_offset` and related functions.	Taras Voinarovskiy	2017-08-07	1	-5/+16
*	Added `beginning_offsets` and `end_offsets` API's and fixed @jeffwidman revie...	Taras Voinarovskiy	2017-08-07	3	-16/+96
*	Fix test for older brokers	Taras Voinarovskiy	2017-08-07	1	-1/+1
*	Changed retrieve_offsets to allow fetching multiple offsets at once	Taras Voinarovskiy	2017-08-07	2	-96/+133
*	Added basic support for offsets_for_times API. Still needs to group by nodes ...	Taras Voinarovskiy	2017-08-07	5	-20/+124
*	Add private map of api key -> min/max versions to BrokerConnection (#1169)	Dana Powers	2017-08-06	2	-11/+58
*	Fixed Issue 1033.Raise AssertionError when decompression unsupported. (#1159)	webber	2017-08-05	1	-0/+7
*	conn: Catch ssl.EOFErrors on Python3.3 so we close the failing conn (#1162)	Hannu Valtonen	2017-08-01	1	-1/+3
*	Make UnknownTopicOrPartitionError retriable errorissue1155	Taras Voinarovskiy	2017-07-30	1	-0/+1
*	Fix batch expiry messages to state seconds	Dominic Evans	2017-07-26	1	-3/+3
*	Use for join-time-max and sync-time-max metrics Max() measure function (#1146)	Alexey Pervushin	2017-07-20	1	-2/+2
*	added gssapi support (Kerberos) for SASL (#1152)	Harald	2017-07-20	1	-2/+75
*	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
*	Protocol updates for 0.11.0.0 (#1127)	Dana Powers	2017-07-09	7	-41/+508
*	Use logging's built-in string interpolation	Jeff Widman	2017-07-07	2	-6/+5
*	change_subscription called only when necessary (#1132)	Petr Šebek	2017-07-07	1	-2/+3
*	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	4	-22/+69
*	Backoff on unavailable group coordinator retry (#1125)	Dana Powers	2017-06-19	1	-0/+2
*	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
*	Describe consumer thread-safety	Linus Wallgren	2017-06-16	1	-0/+2
*	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
*	Warn dont raise on DNS lookup failures (#1091)	Dana Powers	2017-05-03	1	-5/+7
*	Follow-up to #1068: remove not-implemented comments	Dana Powers	2017-04-10	2	-2/+2
*	Timeout idle connections via connections_max_idle_ms (#1068)	Dana Powers	2017-04-10	3	-4/+99
*	Avoid multiple connection attempts when refreshing metadata (#1067)	Dana Powers	2017-04-05	1	-44/+48
*	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
*	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	1	-1/+1
*	Derive all api classes from Request / Response base classes (#1030)	Dana Powers	2017-03-14	11	-84/+140
*	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	1	-7/+32