Advertisement
Guest User

Untitled

a guest
Sep 17th, 2019
128
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.33 KB | None | 0 0
  1. let { Bundle, EventStreams } = require('solsa')
  2.  
  3. let bundle = new Bundle()
  4. bundle.kafka = new EventStreams({ name: 'kafka', plan: 'standard' })
  5. bundle.topic = new bundle.kafka.Topic({ name: 'topic', topicName: 'MyTopic' })
  6. bundle.source = new bundle.topic.Source({ name: 'source', sink: { name: 'test-sink' } })
  7. module.exports = bundle
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement