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

	Commit message (Expand)	Author	Age	Files	Lines
*	Be explicit with tuples for %s formattinguse-explicit-tuples-for-strings	Jeff Widman	2018-11-17	1	-2/+2
*	use absolute imports everywhere (#1362)	Kevin Tindall	2018-02-06	1	-5/+5
*	Added minor fixes for PR review	Taras	2017-10-12	1	-1/+2
*	Refactor MessageSet and Message into LegacyRecordBatch to later support v2 me...	Taras	2017-10-11	1	-4/+8
*	BrokerConnection receive bytes pipe (#1032)	Dana Powers	2017-08-15	1	-3/+4
*	Avoid re-encoding for message crc check (#1027)	Dana Powers	2017-03-13	1	-6/+12
*	Fixed couple of "leaks" when gc is disabled (#979)	Max Baryshnikov	2017-03-07	1	-2/+2
*	PEP-8: Spacing & removed unused imports (#899)	Jeff Widman	2017-02-09	1	-4/+3
*	Fix message timestamp_type (#828)	Josh Yudaken	2016-09-15	1	-1/+4
*	Always absolute_importabsolute_import	Dana Powers	2016-08-02	1	-0/+2
*	Always encode size with MessageSet (#771)	Dana Powers	2016-07-17	1	-3/+1
*	Fix regression in MessageSet decoding wrt PartialMessages (#716)	Dana Powers	2016-06-01	1	-3/+6
*	Use standard LZ4 framing for v1 messages / kafka 0.10 (#695)	Dana Powers	2016-05-22	1	-2/+6
*	KAFKA-3025: Message v1 -- add timetamp and use relative offset in compressed ...	Dana Powers	2016-05-22	1	-17/+61
*	Always pass encoded message bytes to MessageSet.encode()	Dana Powers	2016-05-22	1	-37/+17
*	Add support for LZ4 compressed messages using python-lz4 module	Dana Powers	2016-01-25	1	-3/+12
*	Support encode and repr on raw BytesIO MessageSets (used in new producer)	Dana Powers	2016-01-24	1	-0/+12
*	Add Message and MessageSet HEADER_SIZE bytes	Dana Powers	2016-01-24	1	-0/+2
*	Message value can be None	Dana Powers	2016-01-03	1	-1/+1
*	Override Message __hash__ to use _encode_self and not recalc crcs	Dana Powers	2016-01-03	1	-0/+3
*	Assert Message value and (optional) key are bytes	Dana Powers	2016-01-03	1	-0/+2
*	Support message decompression	Dana Powers	2015-12-31	1	-2/+25
*	Add Message.validate_crc() method	Dana Powers	2015-12-28	1	-0/+7
*	Support pickling of Structs -- _encode_self instance method needs some magic	Dana Powers	2015-12-09	1	-0/+1
*	Return PartialMessage object in MessageSet.decode if message is truncated by ...	Dana Powers	2015-12-09	1	-3/+10
*	Fix BytesIO import in kafka.protocol.message	Dana Powers	2015-12-09	1	-1/+3
*	Handle special __init__ signature in Message decode()	Dana Powers	2015-12-09	1	-0/+8
*	Handle decoding partial messages in MessageSet - caused by FetchRequest max_b...	Dana Powers	2015-12-09	1	-6/+24
*	Add comment re bytes offset tracking in MessageSet decode()	Dana Powers	2015-12-04	1	-1/+1
*	Recursive repr, display all field names and values for Structs	Dana Powers	2015-12-04	1	-1/+5
*	Use simply counting instead of buffer.tell() -- socket.makefile does not supp...	Dana Powers	2015-12-04	1	-2/+4
*	Rework protocol type definition: AbstractType, Schema, Struct	Dana Powers	2015-12-04	1	-0/+67