import os

from pykafka import KafkaClient
from dotenv import load_dotenv



load_dotenv()

def get_kafka_client():
    #TODO - wrap the kafka client around try-catch
    #do proper logging of errors if there is error
    return KafkaClient(os.environ.get("hosts"))



429da1329c3274074d74e924809b01ef43ecec7b
<mask token>

<mask token>


def get_kafka_client():
    return KafkaClient(os.environ.get('hosts'))

<mask token>
load_dotenv()


def get_kafka_client():
    return KafkaClient(os.environ.get('hosts'))

import os
from pykafka import KafkaClient
from dotenv import load_dotenv
load_dotenv()


def get_kafka_client():
    return KafkaClient(os.environ.get('hosts'))

import os

from pykafka import KafkaClient
from dotenv import load_dotenv



load_dotenv()

def get_kafka_client():
    #TODO - wrap the kafka client around try-catch
    #do proper logging of errors if there is error
    return KafkaClient(os.environ.get("hosts"))


