SHARE
TWEET

Untitled




Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
- let { Bundle, EventStreams } = require('solsa')
- let bundle = new Bundle()
- bundle.kafka = new EventStreams({ name: 'kafka', plan: 'standard' })
- bundle.topic = new bundle.kafka.Topic({ name: 'topic', topicName: 'MyTopic' })
- bundle.source = new bundle.topic.Source({ name: 'source', sink: { name: 'test-sink' } })
- module.exports = bundle
RAW Paste Data
We use cookies for various purposes including analytics. By continuing to use Pastebin, you agree to our use of cookies as described in the Cookies Policy.