Dana Powers b1e0aef468 Skeleton tests for async kafka client

2016-01-01 12:11:32 -08:00

..

__init__.py

Use base unittest or unittest2 depending on python version

2014-09-03 09:55:44 -07:00

fixtures.py

pylint fixes

2015-12-10 18:37:03 -08:00

service.py

Start test fixtures in new session to avoid propagating signals (i.e., Ctrl-C)

2015-12-30 13:05:11 -08:00

test_client_async.py

Skeleton tests for async kafka client

2016-01-01 12:11:32 -08:00

test_client_integration.py

Drop kafka_bytestring

2015-12-10 18:37:03 -08:00

test_client.py

Rename TopicAndPartition -> TopicPartition

2015-12-28 13:44:29 -08:00

test_codec.py

random_string helper should return str not bytes

2015-06-06 16:22:27 -07:00

test_conn.py

Move Request / Response logging from KafkaClient to BrokerConnection

2015-12-10 18:38:34 -08:00

test_consumer_integration.py

Drop bytes encoding of consumer group in consumer integration test

2015-12-10 18:52:44 -08:00

test_consumer.py

Convert OffsetCommit and OffsetFetch protocol encode/decode

2015-12-10 11:25:15 -08:00

test_context.py

Fixup test_context.py unittest import

2014-09-10 22:27:40 -07:00

test_failover_integration.py

Catch and retry on RequestTimedOutError in producer failover test

2015-12-29 17:49:04 -08:00

test_package.py

Merge conflict w/ assertEqual (assertEquals deprecated)

2014-12-15 12:43:45 -08:00

test_partitioner.py

Fix translation of Java murmur2 code, fix byte encoding for Python 3.

2015-07-28 22:38:28 -07:00

test_producer_integration.py

Remove bytes encoding for topic name in producer integration test

2015-12-10 18:52:18 -08:00

test_producer.py

Rename TopicAndPartition -> TopicPartition

2015-12-28 13:44:29 -08:00

test_protocol.py

Rename TopicAndPartition -> TopicPartition

2015-12-28 13:44:29 -08:00

test_util.py

Rename TopicAndPartition -> TopicPartition

2015-12-28 13:44:29 -08:00

testutil.py

Move Request / Response logging from KafkaClient to BrokerConnection

2015-12-10 18:38:34 -08:00