package kafkaclient

import (
	"context"

	"github.com/twmb/franz-go/pkg/kgo"
)

type Record = kgo.Record
type Header = kgo.RecordHeader

type Partition int32
type Offset int64

type Pinger interface {
	Ping(ctx context.Context) error
}

type Producer interface {
	Pinger
	Produce(ctx context.Context, records ...*kgo.Record) error
	ReProduce(ctx context.Context, records ...*kgo.Record) error
}

type Consumer interface {
	Pinger
	Read(ctx context.Context) ([]*Record, error)
	Ack(ctx context.Context, record ...*Record) error
	Stop()
}