kafka

Documentation

Overview

This is the dummy code to pass the compile when Kafka is not enabled. Cannot enable Kafka by default due to confluent-kafka-go not supporting cross-compilation. Try adding -tags=kafka to build when you need Kafka.

Index

• func NewAgentOptions(configMap *KafkaOptions, clusterName, agentID string) *options.CloudEventsAgentOptions
• func NewSourceOptions(configMap *KafkaOptions, sourceID string) *options.CloudEventsSourceOptions
• type KafkaOptions
  • func BuildKafkaOptionsFromFlags(configPath string) (*KafkaOptions, error)

Functions

func NewAgentOptions

func NewAgentOptions(configMap *KafkaOptions, clusterName, agentID string) *options.CloudEventsAgentOptions

func NewSourceOptions

func NewSourceOptions(configMap *KafkaOptions, sourceID string) *options.CloudEventsSourceOptions

Types

type KafkaOptions

type KafkaOptions struct {
	ConfigMap map[string]interface{}
}

func BuildKafkaOptionsFromFlags

func BuildKafkaOptionsFromFlags(configPath string) (*KafkaOptions, error)