delta/python-packages/kafka-python.git/test/test_producer.py, branch commit_failed_message_fixup github.com: mumrah/kafka-python.git Close KafkaConsumer instances during tests (#1410) 2018-03-08T15:50:13+00:00 Dana Powers dana.powers@gmail.com 2018-03-08T15:50:13+00:00 4c383daf8a9d7aaa5049a98d7d6da19c85793d2d 






Increase some integration test timeouts (#1374)
2018-02-09T07:39:37+00:00

Dana Powers
dana.powers@gmail.com

2018-02-09T07:39:37+00:00

8655c75e6a147080235d3458ec82edb9e1ff78a6












Minor test cleanups (#1343)
2018-01-12T20:49:01+00:00

Dana Powers
dana.powers@gmail.com

2018-01-12T20:49:01+00:00

34fea654c0136490bb5f2785ddc4e7f37ebf7ab2












Add DefaultRecordBatch implementation aka V2 message format parser/builder. (#1185)
2017-10-24T22:28:35+00:00

Taras Voinarovskyi
voyn1991@gmail.com

2017-10-24T22:28:35+00:00

8b05ee8da50b4c7b832676f4e38f9d92a86639cc

Added bytecode optimization for varint and append/read_msg functions. Mostly based on avoiding LOAD_GLOBAL calls.




Added bytecode optimization for varint and append/read_msg functions. Mostly based on avoiding LOAD_GLOBAL calls.






Fix timestamp not passed to RecordMetadata (#1273)
2017-10-22T07:56:28+00:00

Taras Voinarovskyi
voyn1991@gmail.com

2017-10-22T07:56:28+00:00

a345dcd2ca1b0f8934864c512a4a78c65034dd36

* Fix timestamp not being passed to RecordMetadata properly

* Add more tests for LegacyBatch

* Fix producer test for recordmetadata





* Fix timestamp not being passed to RecordMetadata properly

* Add more tests for LegacyBatch

* Fix producer test for recordmetadata







Use fixture hostname (dont assume localhost)
2017-06-19T05:43:21+00:00

Dana Powers
dana.powers@gmail.com

2017-06-17T14:10:03+00:00

d127928e44113f645649775174f751ebc470cd88












Alter test skips: python-lz4 works on python26, but not pypy
2017-03-14T20:30:35+00:00

Dana Powers
dana.powers@gmail.com

2017-03-14T18:38:49+00:00

a00f9ead161e8b05ac953b460950e42fa0e0b7d6












Fix typos
2016-11-14T11:16:41+00:00

Jeff Widman
jeff@jeffwidman.com

2016-11-08T09:29:45+00:00

cd74c1fe4053385151175b5100cb0a0d43bc31f6












Use weakref when registering a producer.close atexit to fix normal gc (#728)
2016-06-18T21:51:23+00:00

Dana Powers
dana.powers@gmail.com

2016-06-18T21:51:23+00:00

6271c02c6eebf52a6d368416db49bfa57b09ef04

* Use weakref when registering a producer.close atexit to fix normal gc
* Test that del(producer) terminates async thread




* Use weakref when registering a producer.close atexit to fix normal gc
* Test that del(producer) terminates async thread






Reduce end-to-end test to 100 messages; raise produce future exceptions immediately
2016-03-13T22:08:13+00:00

Dana Powers
dana.powers@gmail.com

2016-03-13T20:41:56+00:00

f98985263908665ae5a0891ad1ee4eeacc39367a