kafkasource

Documentation

Index

• func DataPlaneDelivery() []*feature.Feature
• func KafkaSourceGoesReady(name string, cfg ...kafkasource.CfgFn) *feature.Feature
• func MtDataPlaneDelivery() *feature.Feature

Functions

func DataPlaneDelivery

func DataPlaneDelivery() []*feature.Feature

DataPlaneDelivery returns a feature testing given a KafkaSource installed before sending events to Kafka when an event is sent to Kafka then it is received by the sink

func KafkaSourceGoesReady

func KafkaSourceGoesReady(name string, cfg ...kafkasource.CfgFn) *feature.Feature

KafkaSourceGoesReady returns a feature testing if a KafkaSourceGoesReady becomes ready.

func MtDataPlaneDelivery

func MtDataPlaneDelivery() *feature.Feature