Skip to content

Instantly share code, notes, and snippets.

@tardieu
Created September 6, 2019 19:58
Show Gist options
  • Save tardieu/67655f81d7e9e6b2d20645ff81e1e24f to your computer and use it in GitHub Desktop.
Save tardieu/67655f81d7e9e6b2d20645ff81e1e24f to your computer and use it in GitHub Desktop.
Knative Event Source
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
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment