Test streams thingystreams

1 files changed, 21 insertions, 0 deletions

diff --git a/test_streams.py b/test_streams.py
new file mode 100755
index 0000000..18870ff
--- /dev/null
+++ b/test_streams.py
@@ -0,0 +1,21 @@
+#!/usr/bin/env python
+
+from kafka.streams.kafka import KafkaStreams
+from kafka.streams.processor.topology_builder import TopologyBuilder
+import logging
+logging.basicConfig(level=logging.INFO)
+
+
+def main():
+
+    builder = TopologyBuilder()
+    builder.add_source('foo', 'foo').add_sink('bar', 'bar', 'foo')
+
+    hosts = ['[::1]:56686', '[::1]:56692', '[::1]:56702']
+
+    streams = KafkaStreams(builder, application_id='dpkp-foobar', bootstrap_servers=hosts)
+    streams.start()
+
+
+if __name__ == '__main__':
+    main()