kafka/producer/__init__.py


1
2
3
4
5
6
7
8
9
10

from __future__ import absolute_import

from kafka.producer.kafka import KafkaProducer
from kafka.producer.simple import SimpleProducer
from kafka.producer.keyed import KeyedProducer

__all__ = [
    'KafkaProducer',
    'SimpleProducer', 'KeyedProducer' # deprecated
]