kconsumer

type HandleMessage ¶

type HandleMessage func(ctx context.Context, msg *kafka.Message) error

HandleMessage is the user-provided function called for each consumed message. It receives the raw *kafka.Message so the caller has access to key, headers, and partition/offset metadata.

type PartitionConsumer ¶

type PartitionConsumer struct {
	Topics   []string
	Consumer *kafka.Consumer
}

PartitionConsumer subscribes to a topic and runs a dedicated goroutine per assigned partition. Offset storage is explicit: only messages that were successfully handled are stored for auto-commit.

If you return an error from your handler, you get two retries before the consumer will quit and shutdown with an error.

func (c *PartitionConsumer) Consume(ctx context.Context, handle HandleMessage) error