kafka

type Config struct {
	Config *sarama.Config
}

type KafkaWriteInfo struct {
	RemoteAddr          string
	TunnelKafkaSecurity string
	KafkaClientCer      string
	KafkaClientKey      string
	KafkaServerCer      string
	KafkaSaslUser       string
	KafkaSaslPassword   string
}

type Message struct {
	Key       []byte
	Value     []byte
	Offset    int64
	TimeStamp time.Time
}

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

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