pkg

type ChangesProvider interface {
	Changes(
		ctx context.Context,
		topic libkafka.Topic,
		partition libkafka.Partition,
		offset libkafka.Offset,
		limit uint64,
	) (Records, error)
}

type Converter interface {
	Convert(ctx context.Context, msg *sarama.ConsumerMessage) (*Record, error)
}

type Page struct {
	NextOffset *libkafka.Offset `json:"nextOffset,omitempty"`
	Records    Records          `json:"records"`
}

type Record struct {
	Key       string             `json:"key"`
	Value     interface{}        `json:"value"`
	Offset    libkafka.Offset    `json:"offset"`
	Partition libkafka.Partition `json:"partition"`
	Topic     libkafka.Topic     `json:"topic"`
	Header    libkafka.Header    `json:"header"`
}

type Records []Record