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

	Commit message (Collapse)	Author	Age	Files	Lines
*	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