kafka

type Config struct {
	Broker          string
	Partition       int
	ConsumerGroupID string
	OffSet          int
}

type Connection interface {
	Controller() (broker kafka.Broker, err error)
	CreateTopics(topics ...kafka.TopicConfig) error
	DeleteTopics(topics ...string) 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)
	CommitMessages(ctx context.Context, msgs ...kafka.Message) error
	Stats() kafka.ReaderStats
}

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