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

	Commit message (Expand)	Author	Age	Files	Lines
...
*	Use Popen.communicate() instead of Popen.wait()	Brian Sang	2019-01-05	1	-9/+10
*	Cleanup formatting, no functional changes	Jeff Widman	2018-11-20	1	-23/+23
*	Be explicit with tuples for %s formatting	Jeff Widman	2018-11-18	4	-7/+7
*	Migrate from `Unittest` to `pytest` (#1620)	Jeff Widman	2018-11-10	6	-72/+34
*	Cleanup fixture imports	Jeff Widman	2018-10-27	7	-15/+10
*	Minor aesthetic cleanup of partitioner tests	Jeff Widman	2018-10-27	1	-11/+10
*	Remove unused ivy_root variable	Jeff Widman	2018-10-27	1	-1/+0
*	Add KafkaAdmin class	Richard Lee	2018-10-24	1	-0/+47
*	Vendor `six` consistently	Jeff Widman	2018-10-22	10	-23/+23
*	Fix typo in file name	Jeff Widman	2018-10-22	1	-0/+0
*	Support produce with Kafka record headers	Heikki Nousiainen	2018-09-27	1	-1/+9
*	Expose record headers in ConsumerRecords	Heikki Nousiainen	2018-09-27	1	-3/+3
*	Add positive tests for headers in record encode/decode	Heikki Nousiainen	2018-09-27	2	-3/+18
*	Don't use `kafka.common` internally1.3.5	Jeff Widman	2018-06-05	6	-13/+14
*	Ignore MetadataResponses with empty broker list (#1506)	Dana Powers	2018-05-26	1	-0/+22
*	Stop shadowing `ConnectionError`	Jeff Widman	2018-05-23	3	-6/+6
*	Skip flakey SimpleProducer test	Dana Powers	2018-04-18	1	-0/+1
*	Add codec validators to record parser and builder for all formats (#1447)	Taras	2018-04-18	5	-5/+96
*	Fix MemoryRecord bugs re error handling and add test coverage (#1448)	Taras	2018-04-18	1	-1/+68
*	Change SimpleProducer to use async_send (async is reserved in py37) (#1454)	Dana Powers	2018-03-23	3	-13/+13
*	Fix skipped integration tests if KAFKA_VERSION unset (#1453)	Dana Powers	2018-03-22	2	-0/+9
*	Connect with sockaddrs to support non-zero ipv6 scope ids (#1433)	Dana Powers	2018-03-09	1	-15/+12
*	Add BrokerConnection.connect_blocking() (#1411)	Dana Powers	2018-03-09	2	-3/+6
*	Make BrokerConnection .host / .port / .afi immutable, use _sock_* attributes ...	Dana Powers	2018-03-09	1	-9/+20
*	Fix BrokerConnection.connection_delay() to return milliseconds (#1414)	Dana Powers	2018-03-08	1	-0/+9
*	Close KafkaConsumer instances during tests (#1410)	Dana Powers	2018-03-08	3	-1/+11
*	Fix KafkaConsumer compacted offset handling (#1397)	Dana Powers	2018-02-26	1	-2/+19
*	Fixes racing condition when message is sent to broker before topic logs are c...	Andre Araujo	2018-02-21	1	-3/+19
*	Introduce new fixtures to prepare for migration to pytest.	Andre Araujo	2018-02-21	7	-157/+458
*	Use hardware accelerated CRC32C function if available (#1389)	Taras Voinarovskyi	2018-02-21	1	-2/+3
*	Increase some integration test timeouts (#1374)	Dana Powers	2018-02-08	4	-10/+24
*	Avoid consuming duplicate compressed messages from mid-batch (#1367)	Dana Powers	2018-02-05	1	-0/+40
*	KAFKA-3949: Avoid race condition when subscription changes during rebalance (...	Dana Powers	2018-02-02	1	-37/+21
*	Use 0.11.0.2 kafka broker for integration testing (#1357)	Dana Powers	2018-01-25	1	-1/+1
*	Minor test cleanups (#1343)	Dana Powers	2018-01-12	3	-2/+5
*	Honor reconnect_backoff in conn.connect() (#1342)	Dana Powers	2018-01-11	1	-0/+2
*	Fix coordinator join_future race condition (#1338)	Dana Powers	2018-01-11	1	-0/+13
*	KAFKA-3888 Use background thread to process consumer heartbeats (#1266)	Dana Powers	2017-12-21	5	-56/+107
*	Minor Exception cleanup	Jeff Widman	2017-12-12	3	-4/+4
*	Refactor dns lookup in BrokerConnection (#1312)	Dana Powers	2017-12-08	1	-0/+25
*	Change fixture default host to localhost (#1305)	Andre Araujo	2017-12-05	1	-15/+1
*	Revert ffc7caef13a120f69788bcdd43ffa01468f575f9 / PR #1239	Dana Powers	2017-11-16	1	-23/+0
*	Handle lookup_coordinator send failures (#1279)	Dana Powers	2017-10-24	1	-0/+8
*	Add DefaultRecordBatch implementation aka V2 message format parser/builder. (...	Taras Voinarovskyi	2017-10-25	5	-6/+315
*	Add fixture support for upcoming 1.0.0 broker release (#1275)	Dana Powers	2017-10-23	1	-2/+6
*	Fix timestamp not passed to RecordMetadata (#1273)	Taras Voinarovskyi	2017-10-22	2	-8/+139
*	Move callback processing from BrokerConnection to KafkaClientpending_completions	Dana Powers	2017-10-15	1	-1/+2
*	Merge pull request #1252 from dpkp/legacy_records_refactor	Taras Voinarovskyi	2017-10-14	7	-180/+236
\|\
\| *	Fix tests and rebase problems	Taras	2017-10-12	1	-95/+27
\| *	Refactor MessageSet and Message into LegacyRecordBatch to later support v2 me...	Taras	2017-10-11	6	-85/+209