cfg

Documentation

Index

• Constants
• Variables
• func CreateSaramaClusterConfig() *cluster.Config
• func CreateSaramaConfig() *sarama.Config

Constants

const (
	// ConsumerGroup is the name of the consumer group
	ConsumerGroup = "$Default"
)

Define you EventHubs connection details.

Variables

var (
	// Namespace is the EventHubs namespace
	Namespace = ""
	// EventHubName is the EventHubs name
	EventHubName = ""
)

Functions

func CreateSaramaClusterConfig

func CreateSaramaClusterConfig() *cluster.Config

CreateSaramaClusterConfig creates a new sarama cluster config

func CreateSaramaConfig

func CreateSaramaConfig() *sarama.Config

CreateSaramaConfig creates a new sarama config