<gh_stars>1-10
"""
Connecting to events stream, running over Kafka cluster.
"""


class KafkaClient(object):

    def __init__(self):
        raise NotImplementedError

"""
Connecting to events stream, running over Kafka cluster.
"""


class KafkaClient(object):

    def __init__(self):
        raise NotImplementedError
Connecting to events stream, running over Kafka cluster.