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

	Commit message (Expand)	Author	Age	Files	Lines
*	Fix internal timeout / sleep handling in consumer iteratoriterator_timeout	Dana Powers	2016-01-29	1	-15/+16
*	Catch dns lookup errors when attempting to connect to nodes	Dana Powers	2016-01-27	1	-2/+8
*	Merge pull request #523 from dpkp/null_logger	Dana Powers	2016-01-27	1	-0/+12
\|\
\| *	Add logging NullHandler to avoid No Handlers warningsnull_logger	Dana Powers	2016-01-27	1	-0/+12
* \|	Merge pull request #522 from dpkp/lz4_fixup	Dana Powers	2016-01-27	6	-20/+77
\|\ \ \| \|/ \|/\|
\| *	Handle broken LZ4 framing; switch to lz4tools + xxhashlz4_fixup	Dana Powers	2016-01-26	6	-22/+72
\| *	Add end-to-end integration testing for all compression types	Dana Powers	2016-01-26	1	-1/+8
\|/
*	Add error 104 / Connection reset by peer to expected check_version errors	Dana Powers	2016-01-25	1	-2/+2
*	Prefer module imports (io.BytesIO)	Dana Powers	2016-01-25	1	-5/+5
*	python-snappy does not like buffer-slices on pypy...	Dana Powers	2016-01-25	1	-2/+12
*	Update docs w/ KafkaProducer; move Simple clients to separate document	Dana Powers	2016-01-25	4	-117/+288
*	Ignore pylint errors on buffer/memoryview	Dana Powers	2016-01-25	1	-0/+2
*	Python3 does not support buffer -- use memoryview in snappy_decode	Dana Powers	2016-01-25	1	-2/+8
*	Add Fetcher unit tests	Dana Powers	2016-01-25	1	-0/+101
*	Fix Fetch._create_fetch_requests docstring	Dana Powers	2016-01-25	1	-1/+1
*	Remove test_correlation_id_rollover; use daemon threads for test consumers	Dana Powers	2016-01-25	1	-44/+3
*	Ok to sleep in blocking poll for metadata update	Dana Powers	2016-01-25	2	-2/+2
*	Small KafkaClient.check_version() improvements	Dana Powers	2016-01-25	2	-3/+24
*	Log new KafkaClient under kafka.client until files are merged	Dana Powers	2016-01-25	1	-1/+1
*	Update xerial snappy tests for new xerial default	Dana Powers	2016-01-25	1	-3/+5
*	Dont need context manager for BytesIO	Dana Powers	2016-01-25	1	-22/+18
*	Write xerial-formatted snappy by default; use buffers to reduce copies	Dana Powers	2016-01-25	1	-22/+16
*	Merge pull request #518 from dpkp/lz4	Dana Powers	2016-01-25	9	-69/+126
\|\
\| *	Add lz4 to tox environment depslz4	Dana Powers	2016-01-25	1	-0/+2
\| *	Convert codec tests to pytest; add simple lz4 test	Dana Powers	2016-01-25	1	-62/+75
\| *	Add support for LZ4 compressed messages using python-lz4 module	Dana Powers	2016-01-25	7	-7/+49
\|/
*	Merge pull request #516 from dpkp/group_id_none	Dana Powers	2016-01-24	3	-28/+46
\|\
\| *	Disable auto-commit / group assignment in producer testgroup_id_none	Dana Powers	2016-01-24	1	-0/+1
\| *	Disable offset commits and auto-partition-assignment when group_id is None	Dana Powers	2016-01-24	2	-28/+45
\|/
*	Merge pull request #515 from dpkp/kafka_producer	Dana Powers	2016-01-24	17	-313/+2163
\|\
\| *	Add KafkaProducer to autodocs and READMEkafka_producer	Dana Powers	2016-01-24	2	-2/+30
\| *	Add simple KafkaProducer -> KafkaConsumer integration test	Dana Powers	2016-01-24	1	-0/+34
\| *	add DefaultPartitioner test	Dana Powers	2016-01-24	1	-22/+42
\| *	Move pytest broker/zk fixtures to test.conftest	Dana Powers	2016-01-24	3	-30/+36
\| *	Rename legacy producer tests	Dana Powers	2016-01-24	1	-0/+0
\| *	Add KafkaProducer to kafka and kafka.producer module imports	Dana Powers	2016-01-24	2	-2/+5
\| *	Implement new KafkaProducer, mimicing java client interface / design	Dana Powers	2016-01-24	1	-0/+496
\| *	Sender class to manage background IO for KafkaProducer	Dana Powers	2016-01-24	1	-0/+272
\| *	RecordAccumulator and RecordBatch, for use by async batching KafkaProducer	Dana Powers	2016-01-24	1	-0/+500
\| *	Add thread-aware futures for use with KafkaProducer	Dana Powers	2016-01-24	1	-0/+66
\| *	Add MessageSetBuffer and SimpleBufferPool to manage producer messages	Dana Powers	2016-01-24	1	-0/+388
\| *	DefaultPartitioner - implements java client logic	Dana Powers	2016-01-24	1	-0/+23
\| *	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
\|/
*	Dont need to refresh metadata on GroupCoordinatorNotAvailableErrors	Dana Powers	2016-01-24	1	-1/+4
*	Write bytes to wake_fd	Dana Powers	2016-01-24	1	-1/+1
*	Warn on 0.8.2 GroupCoordinator no-topic-quirk, dont raise exception	Dana Powers	2016-01-23	1	-2/+5
*	Ignore _socketobject errors in pylint -- v1.5.4 started throwing no-member er...	Dana Powers	2016-01-23	1	-1/+1
*	Pylint ignores to fix weird 2.7 error in new pylint version	Dana Powers	2016-01-23	1	-0/+3
*	Fix client poll tests (called with sleep=False)	Dana Powers	2016-01-23	1	-4/+5