kafka

type Config struct {
	Brokers          []string
	Partition        int
	ConsumerGroupID  string
	OffSet           int
	BatchSize        int
	BatchBytes       int
	BatchTimeout     int
	RetryTimeout     time.Duration
	SASLMechanism    string
	SASLUser         string
	SASLPassword     string
	SecurityProtocol string
	TLS              TLSConfig
}

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

type Connection interface {
	Controller() (broker kafka.Broker, err error)
	CreateTopics(topics ...kafka.TopicConfig) error
	DeleteTopics(topics ...string) error
	RemoteAddr() net.Addr
	ReadPartitions(topics ...string) (partitions []kafka.Partition, err error)
	Close() error
}

type Metrics interface {
	IncrementCounter(ctx context.Context, name string, labels ...string)
}

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

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

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

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

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

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

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

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

type Reader interface {
	ReadMessage(ctx context.Context) (kafka.Message, error)
	FetchMessage(ctx context.Context) (kafka.Message, error)
	CommitMessages(ctx context.Context, msgs ...kafka.Message) error
	Stats() kafka.ReaderStats
	Close() error
}

type TLSConfig struct {
	CertFile           string
	KeyFile            string
	CACertFile         string
	InsecureSkipVerify bool
}

type Writer interface {
	WriteMessages(ctx context.Context, msg ...kafka.Message) error
	Close() error
	Stats() kafka.WriterStats
}