Method Handle

internal/queue/queue.go:29–29

(ctx context.Context, msg *sarama.ConsumerMessage)

// Handler defines the interface for message processing
type Handler interface {
	Handle(ctx context.Context, msg *sarama.ConsumerMessage) error
}

// NewProducer creates a new Kafka producer