delta/python-packages/kafka-python.git/test/test_consumer_integration.py, branch commit_failed_message_fixup

Close KafkaConsumer instances during tests (#1410)

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

Introduce new fixtures to prepare for migration to pytest.

2018-02-21T21:30:12+00:00

This commits adds new pytest fixtures in prepation for the
migration of unittest.TestCases to pytest test cases. The handling
of temporary dir creation was also changed so that we can use
the pytest tmpdir fixture after the migration.

Increase some integration test timeouts (#1374)

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

KAFKA-3888 Use background thread to process consumer heartbeats (#1266)

2017-12-21T22:46:10+00:00

Refactor MessageSet and Message into LegacyRecordBatch to later support v2 message format

2017-10-11T15:09:17+00:00

remove beginning/end offsets request version limit

2017-09-04T14:27:52+00:00

Added unit tests for fetcher's `_reset_offset` and related functions.

2017-08-07T09:34:10+00:00

Added `beginning_offsets` and `end_offsets` API's and fixed @jeffwidman review issues

2017-08-07T09:34:09+00:00

Changed retrieve_offsets to allow fetching multiple offsets at once

2017-08-07T09:34:08+00:00

Fix test for older brokers

2017-08-07T09:34:08+00:00