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

	Commit message (Collapse)	Author	Age	Files	Lines
*	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
\| \| \| \| \| \|	* LZ4 framing fixed in 0.10 / message v1 -- retain broken lz4 code for compatibility * lz4f does not support easy incremental decompression - raise RuntimeError * Update lz4 codec tests
*	KAFKA-3025: Message v1 -- add timetamp and use relative offset in compressed ↵	Dana Powers	2016-05-22	1	-17/+61
\| \| \| \|	messagesets
*	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
\| \| \| \|	max_bytes
*	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 ↵	Dana Powers	2015-12-09	1	-6/+24
\| \| \| \|	max_bytes
*	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 ↵	Dana Powers	2015-12-04	1	-2/+4
\| \| \| \|	support tell()
*	Rework protocol type definition: AbstractType, Schema, Struct	Dana Powers	2015-12-04	1	-0/+67