From 19fc23c7d1682729b12083dac7d87e3db8b524cd Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Fri, 16 Feb 2018 12:07:18 -0800 Subject: Test streams thingy --- test_streams.py | 21 +++++++++++++++++++++ 1 file changed, 21 insertions(+) create mode 100755 test_streams.py (limited to 'test_streams.py') 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() -- cgit v1.2.1