kafka

type ConnConfig struct {
	Servers []string
	Topic   TopicConfig
	TLS     tlslib.Config
	SASL    SASLConfig
}

type Message kafka.Message

type MessageReader interface {
	FetchMessage(ctx context.Context) (*Message, error)
	CommitOffsets(ctx context.Context, offsets ...*Offset) error
	Close() error
}

type MessageWriter interface {
	WriteMessages(context.Context, ...Message) error
	Close() error
}

type Offset struct {
	Topic     string
	Partition int
	Offset    int64
}

type OffsetParser interface {
	ToString(o *Offset) string
	FromString(s string) (*Offset, error)
}

type Parser struct{}

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

type ReaderConfig struct {
	Conn ConnConfig
	// ConsumerGroupID is the ID of the consumer group to use. If not set,
	// defaults to "pgstream-consumer-group".
	ConsumerGroupID string
	// ConsumerGroupStartOffset is the offset to start consuming from. If not
	// set, defaults to "earliest".
	ConsumerGroupStartOffset string
}

type SASLConfig struct {
	// Enabled defines if the connection uses SASL authentication. Defaults to
	// false.
	Enabled bool
	// Mechanism is the SASL mechanism to use. It must be one of "plain",
	// "scram-sha-256" or "scram-sha-512". It is required when SASL is enabled.
	Mechanism string
	// Username is the user for the SASL authentication. It is required when
	// SASL is enabled.
	Username string
	// Password is the password for the SASL authentication. It is required when
	// SASL is enabled.
	Password string
}

type TopicConfig struct {
	Name string
	// Number of partitions to be created for the topic. Defaults to 1.
	NumPartitions int
	// Replication factor for the topic. Defaults to 1.
	ReplicationFactor int
	// AutoCreate defines if the topic should be created if it doesn't exist.
	// Defaults to false.
	AutoCreate bool
}

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

type WriterConfig struct {
	Conn ConnConfig
	// BatchTimeout is the time limit on how often incomplete message batches
	// will be flushed to kafka. Defaults to 1s.
	BatchTimeout time.Duration
	// BatchBytes limits the maximum size of a request in bytes before being
	// sent to a partition. Defaults to 1048576 bytes.
	BatchBytes int64
	// BatchSize limits how many messages will be buffered before being sent to
	// a partition. Defaults to 100 messages.
	BatchSize int
}