kafka

Documentation

Index

• Constants
• func AddPartitionKeyFromSubject(watermillIn *message.Message, cloudEvent event.Event) (*message.Message, error)
• func NewPublisher(ctx context.Context, in PublisherOptions) (*kafka.Publisher, error)
• func NewSubscriber(in SubscriberOptions) (message.Subscriber, error)
• type AutoProvisionTopic
• type BrokerOptions
• type PublisherOptions
• type SubscriberOptions

Constants

const (
	PartitionKeyMetadataKey = watermillkafka.PartitionKeyMetadataKey
)

Functions

func AddPartitionKeyFromSubject

func AddPartitionKeyFromSubject(watermillIn *message.Message, cloudEvent event.Event) (*message.Message, error)

func NewPublisher

func NewPublisher(ctx context.Context, in PublisherOptions) (*kafka.Publisher, error)

func NewSubscriber

func NewSubscriber(in SubscriberOptions) (message.Subscriber, error)

Types

type AutoProvisionTopic

type AutoProvisionTopic = watermillkafka.AutoProvisionTopic

type BrokerOptions

type BrokerOptions = watermillkafka.BrokerOptions

type PublisherOptions

type PublisherOptions = watermillkafka.PublisherOptions

type SubscriberOptions

type SubscriberOptions = watermillkafka.SubscriberOptions