blob: 18870ff7d86263344eb4ee25208638d068afa561 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
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()
|
