Advertisement
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
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement