# from .consumer.CustomKafkaConsumer import CustomKafkaConsumer
# from .producer.CustomKafkaProducer import CustomKafkaProducer
-import sys
-import os, threading
-import traceback
import json
import concurrent.futures
import logging
if __name__ == '__main__':
- main()
\ No newline at end of file
+ main()