kafka

package

v0.9.3 Latest Latest Go to latest Published: Dec 16, 2025 License: Apache-2.0 Imports: 14 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

BatchWriter is a kafka writer that uses batches to send the data to the configured kafka topic.

func NewBatchWriter(ctx context.Context, config *Config, opts ...Option) (*BatchWriter, error)

func (w *BatchWriter) Close() error

func (w *BatchWriter) Name() string

func (w *BatchWriter) ProcessWALEvent(ctx context.Context, walEvent *wal.Event) (retErr error)

ProcessWALEvent is called on every new message from the wal. It can be called concurrently.

type Config struct {
	Kafka kafka.ConnConfig
	Batch batch.Config
}

type Option func(*BatchWriter)

func WithCheckpoint(c checkpointer.Checkpoint) Option

func WithInstrumentation(i *otel.Instrumentation) Option

func WithLogger(l loglib.Logger) Option