kafka

Documentation

Index

• func New(attributes map[string]interface{}) machine.Subscription
• type ReaderConfig

Functions

func New

func New(attributes map[string]interface{}) machine.Subscription

New func to provide a machine.Subscription based on Kafka

Types

type ReaderConfig

type ReaderConfig struct {
	*kaf.ReaderConfig
}