kafka

type DeadLetterRange struct {
	Brokers   []string
	Topic     string
	Partition int32
	Offset    int64
	Count     int
}

type Handler interface {
	// HandleBatch treats mutations as read-only and stops using the slice
	// before returning so the worker can reuse it for unresolved records.
	HandleBatch(ctx context.Context, mutations []queue.Mutation) []error
}

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

type PublisherOptions struct {
	Store            string
	Topics           *TopicManager
	Brokers          []string
	Topic            string
	ClientOptions    []kgo.Opt
	Metrics          *sinkmetrics.Metrics
	MaxRecordBytes   int
	MaxBufferedBytes int
}

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

type TopicOptions struct {
	Brokers             []string
	Topics              []string
	Partitions          int
	ReplicationFactor   int
	Retention           time.Duration
	DeadLetterTopic     string
	DeadLetterRetention time.Duration
	MinInSyncReplicas   int
	MaxRecordBytes      int
}

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

type WorkerOptions struct {
	Admission         *backpressure.Controller
	Memory            *capacity.Guard
	Topics            *TopicManager
	Brokers           []string
	Store             string
	Topic             string
	GroupID           string
	DeadLetterTopic   string
	Handler           Handler
	MaxPollRecords    int
	MaxRetryAttempts  int
	RetryBackoff      time.Duration
	MaxRetryBackoff   time.Duration
	ClientOptions     []kgo.Opt
	Metrics           *sinkmetrics.Metrics
	ProcessingTimeout time.Duration
	MaxRecordBytes    int
	ShutdownTimeout   time.Duration
}