"""Tests initialization."""

import os

os.environ['Environment'] = 'test'
os.environ['TOPIC_NAME'] = 'test_topic'
os.environ['BOOTSTRAP_SERVERS'] = 'server1,server2'
os.environ['KAFKA_API_VERSION'] = '2.6.0'
os.environ['SALESFORCE_RECORD_TYPE_ID'] = 'sf_record_type'