diff options
| author | Dana Powers <dana.powers@gmail.com> | 2018-02-08 23:39:37 -0800 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2018-02-08 23:39:37 -0800 |
| commit | 8655c75e6a147080235d3458ec82edb9e1ff78a6 (patch) | |
| tree | ec9c607a83f74962d557117ab5f561b146332999 /test/test_producer.py | |
| parent | 7d8f9a41e0b7a83624e6ebab368de68b87f71997 (diff) | |
| download | kafka-python-8655c75e6a147080235d3458ec82edb9e1ff78a6.tar.gz | |
Increase some integration test timeouts (#1374)
Diffstat (limited to 'test/test_producer.py')
| -rw-r--r-- | test/test_producer.py | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/test/test_producer.py b/test/test_producer.py index f7a5b68..80017a1 100644 --- a/test/test_producer.py +++ b/test/test_producer.py @@ -38,12 +38,12 @@ def test_end_to_end(kafka_broker, compression): connect_str = ':'.join([kafka_broker.host, str(kafka_broker.port)]) producer = KafkaProducer(bootstrap_servers=connect_str, retries=5, - max_block_ms=10000, + max_block_ms=30000, compression_type=compression, value_serializer=str.encode) consumer = KafkaConsumer(bootstrap_servers=connect_str, group_id=None, - consumer_timeout_ms=10000, + consumer_timeout_ms=30000, auto_offset_reset='earliest', value_deserializer=bytes.decode) @@ -87,7 +87,7 @@ def test_kafka_producer_proper_record_metadata(kafka_broker, compression): connect_str = ':'.join([kafka_broker.host, str(kafka_broker.port)]) producer = KafkaProducer(bootstrap_servers=connect_str, retries=5, - max_block_ms=10000, + max_block_ms=30000, compression_type=compression) magic = producer._max_usable_produce_magic() |