manager

var ErrBrokersRequired = errors.New("At least one broker address is required.")

ErrBrokersRequired happens when brokers flag is not set.

var ErrGroupRequired = errors.New("Consumer group name is required.")

ErrGroupRequired happens when group flag is not set.

var ErrOffsetRequired = errors.New("Offset value is required.")

ErrOffsetRequired happens when offset flag is not set.

var ErrPartitionRequired = errors.New("Kafka topic partition is required.")

ErrPartitionRequired happens when partition flag is not set.

var ErrTopicRequired = errors.New("Kafka topic name is required.")

ErrTopicRequired happens when topic flag is not set.

var SetBrokers string

SetBrokers holds the brokers flag value.

var SetGroup string

SetGroup holds the group flag value.

var SetOffset int

SetOffset holds the offset flag value.

var SetPartition int

SetPartition holds the partition flag value.

var SetTopic string

SetTopic holds the topic flag value.