summaryrefslogtreecommitdiff
path: root/kafka/producer/__init__.py
diff options
context:
space:
mode:
authorDana Powers <dana.powers@rd.io>2014-09-09 16:42:23 -0700
committerDana Powers <dana.powers@rd.io>2014-09-10 22:14:29 -0700
commit27e812e66bd04d3acf59ad6792b07d1c7056c036 (patch)
treea9960a0ec8d7fd4e1452a09f0ab7fcd69f6d0494 /kafka/producer/__init__.py
parentf806c24d849928c95342d2b82a9d2d9507ba175a (diff)
downloadkafka-python-27e812e66bd04d3acf59ad6792b07d1c7056c036.tar.gz
Separate consumers/producers/partitioners
Diffstat (limited to 'kafka/producer/__init__.py')
-rw-r--r--kafka/producer/__init__.py6
1 files changed, 6 insertions, 0 deletions
diff --git a/kafka/producer/__init__.py b/kafka/producer/__init__.py
new file mode 100644
index 0000000..bc0e7c6
--- /dev/null
+++ b/kafka/producer/__init__.py
@@ -0,0 +1,6 @@
+from .simple import SimpleProducer
+from .keyed import KeyedProducer
+
+__all__ = [
+ 'SimpleProducer', 'KeyedProducer'
+]