agent

type Config struct {
	*sarama.Config

	// Local broker URL to connect to
	BrokerUrl string

	// How often refresh metadata about topics in ms
	MetadataRefreshMs int64

	// Optional. Broker advertised url to figure out local broker ID
	// if not provided, will be attempted to auto discovery based on existsting network
	// interfaces
	BrokerAdvertisedUrl string

	// Optional. Whether to commit & track consumed partitions offsets. When set to 'true',
	// will periodically commit position back to kafka __consumer_offsets topic.
	// Default is 'false'.
	AutotrackOffsets bool

	// Optional. consumer group name when AutotrackOffsets set to true
	ConsumerGroup string

	// Optional. Callback to retrive partition offset information if stored outside of Kafka
	// When AutotrackOffsets if used, the value is ignored and kafka based offset management is used
	// Default is no offset tracking, will re-consume all matching topics
	FetchOffsets func(partition *PartitionInfo) int64
	// contains filtered or unexported fields
}

type KafkaPartition struct {
	Topic    string
	Metadata *sarama.PartitionMetadata
}

type MetadataChanges struct {
	Added   []PartitionInfo
	Removed []PartitionInfo
}

type PartitionInfo struct {
	Topic string
	ID    int32
}

type Server struct {
	// contains filtered or unexported fields
}

type StdLogger interface {
	Print(v ...interface{})
	Printf(format string, v ...interface{})
	Println(v ...interface{})
}