produce

Documentation

Overview

Package produce implements a toy producer.

Index

• type Producer
  • func NewProducer[M proto.Message](client *kgo.Client, serializer serde.Serializer, topic string) *Producer[M]
  • func (p *Producer[M]) ProduceInvalid(ctx context.Context, key string) error
  • func (p *Producer[M]) ProduceProtobufMessage(ctx context.Context, key string, message M) error

Types

type Producer

type Producer[M proto.Message] struct {
	// contains filtered or unexported fields
}

Producer is an example producer to a given topic using given Protobuf message type.

A Producer takes a Kafka client and a topic, and sends one of two types of data:

• A Protobuf message of the given type.
• Invalid data that could not be parsed as any Protobuf message.

This is a toy example, but shows the basics you need to send Protobuf messages to Kafka using franz-go.

func NewProducer

func NewProducer[M proto.Message](
	client *kgo.Client,
	serializer serde.Serializer,
	topic string,
) *Producer[M]

NewProducer returns a new Producer.

Always use this constructor to construct Producers.

func (*Producer[M]) ProduceInvalid

func (p *Producer[M]) ProduceInvalid(ctx context.Context, key string) error

ProduceInvalid synchronously sends data to the Producer's topic that could never be intererpreted as a Protobuf message.

func (*Producer[M]) ProduceProtobufMessage

func (p *Producer[M]) ProduceProtobufMessage(ctx context.Context, key string, message M) error

ProduceProtobufMessage serializes the given Protobuf messages, and synchronously sends it to the Producer's topic with the given key.