kafkaconsumer

Documentation

Index

• Constants
• type ConsumerConfig
  • func NewConsumerConfig() *ConsumerConfig

Constants

const (
	BootstrapServerEnvVar = "BOOTSTRAP_SERVERS"
	TopicEnvVar           = "TOPIC"
	GroupIDEnvVar         = "GROUP_ID"
	MessageCountEnvVar    = "MESSAGE_COUNT"
)

environment variables declaration

const (
	BootstrapServersDefault = "localhost:9092"
	TopicDefault            = "my-topic"
	GroupIDDefault          = "my-group"
	MessageCountDefault     = 10
)

default values for environment variables

Types

type ConsumerConfig

type ConsumerConfig struct {
	BootstrapServers string
	Topic            string
	GroupID          string
	MessageCount     int64
}

ConsumerConfig defines the producer configuration

func NewConsumerConfig

func NewConsumerConfig() *ConsumerConfig