competitor_product_analysis/sdk/KafkaSenderSDK.py

# -*- coding: utf-8 -*-
# @Time : 2021/6/18 19:58
# @Author : XuJiakai
# @File : KafkaSenderSDK
# @Software: PyCharm
from kafka import KafkaProducer

from log import get_log
from sdk.WinhcAllClient import WinhcAllClient

log = get_log('KafkaSenderSDK')


class KafkaSenderSDK:
    def __init__(self, topic_name, consumer_id):
        hosts = WinhcAllClient().get_kafka_sender()


if __name__ == '__main__':
    pass