delta/python-packages/kafka-python.git/test/test_producer.py, branch benchmark_fixups

Use test.fixtures.version not test.conftest.version to avoid warnings (#1731)

2019-03-07T03:10:29+00:00

Be explicit with tuples for %s formatting

2018-11-18T08:21:18+00:00

Fix #1633

Cleanup fixture imports

2018-10-27T09:17:23+00:00

`random_string` now comes from `test.fixtures` and was being
transparently imported via `test.testutil` so this bypasses the
pointless indirect import.

Similarly, `kafka_version` was transparently imported by `test.testutil`
from `test.fixtures`.

Also removed `random_port()` in `test.testutil` because its unused as its been replaced
by the one in `test.fixtures`.

This is part of the pytest migration that was started back in
a1869c4be5f47b4f6433610249aaf29af4ec95e5.

Support produce with Kafka record headers

2018-09-27T22:22:03+00:00

Close KafkaConsumer instances during tests (#1410)

2018-03-08T15:50:13+00:00

Increase some integration test timeouts (#1374)

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

Minor test cleanups (#1343)

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

Add DefaultRecordBatch implementation aka V2 message format parser/builder. (#1185)

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

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

* 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