"""Init tests."""

import os

os.environ['KAFKA_BOOTSTRAP_SERVERS'] = 'test'
os.environ['KAFKA_DLQ_HEADER_PREFIX'] = ''