kafkaclient

type Config struct {
	AutoCommit       bool     `json:"auto_commit"           koanf:"auto_commit"`
	AutoOffsetReset  string   `json:"auto_offset_reset"     koanf:"auto_offset_reset"`
	BootstrapServers []string `json:"bootstrap_servers"     koanf:"bootstrap_servers"`
	Debug            bool     `json:"debug"                 koanf:"debug"`
	GroupId          string   `json:"group_id"              koanf:"group_id"`
	SaslMechanisms   string   `json:"sasl_mechanisms"       koanf:"sasl_mechanisms"`
	SaslPassword     string   `json:"sasl_password"         koanf:"sasl_password"`
	SaslUsername     string   `json:"sasl_username"         koanf:"sasl_username"`
	SecurityProtocol string   `json:"security_protocol"     koanf:"security_protocol"`
	Topics           []string `json:"topics"                koanf:"topics"`
}

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

type LogEntry struct {
	Timestamp string `json:"timestamp"`
	Hostname  string `json:"hostname"`
}

type Metrics struct {
	Latency prometheus.HistogramVec
}