kafka

package

v0.0.11 Latest Latest Go to latest Published: Nov 27, 2023 License: MIT Imports: 14 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/purposeinplay/go-commons

Links

Open Source Insights

Documentation ¶

Index ¶

func NewSASLPublisherConfig(username, password string) *sarama.Config
func NewSASLSubscriberConfig(username, password string) *sarama.Config
type Publisher
- func NewPublisher(logger *zap.Logger, saramaConfig *sarama.Config, brokers []string) (*Publisher, error)
- func (p Publisher) Close() error
- func (p Publisher) Publish(event pubsub.Event[[]byte], channels ...string) error
type Subscriber
- func NewSubscriber(logger *zap.Logger, saramaConfig *sarama.Config, brokers []string, ...) (*Subscriber, error)
- func (s Subscriber) Close() error
- func (s Subscriber) Subscribe(channels ...string) (pubsub.Subscription[[]byte], error)
type Subscription
- func (s Subscription) C() <-chan pubsub.Event[[]byte]
- func (s Subscription) Close() error

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func NewSASLPublisherConfig ¶ added in v0.0.4

func NewSASLPublisherConfig(username, password string) *sarama.Config

NewSASLPublisherConfig creates a new kafka publisher config with SASL authentication.

func NewSASLSubscriberConfig ¶ added in v0.0.4

func NewSASLSubscriberConfig(username, password string) *sarama.Config

NewSASLSubscriberConfig creates a new kafka subscriber config with SASL authentication.

Types ¶

type Publisher ¶

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

Publisher represents a kafka publisher.

func NewPublisher ¶

func NewPublisher(
	logger *zap.Logger,
	saramaConfig *sarama.Config,
	brokers []string,
) (*Publisher, error)

NewPublisher creates a new kafka publisher.

func (Publisher) Close ¶

func (p Publisher) Close() error

Close closes the kafka publisher.

func (Publisher) Publish ¶

func (p Publisher) Publish(event pubsub.Event[[]byte], channels ...string) error

Publish publishes an event to a kafka topic.

type Subscriber ¶

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

Subscriber represents a kafka subscriber.

func NewSubscriber ¶

func NewSubscriber(
	logger *zap.Logger,
	saramaConfig *sarama.Config,
	brokers []string,
	consumerGroup string,
) (*Subscriber, error)

NewSubscriber creates a new kafka subscriber.

func (Subscriber) Close ¶

func (s Subscriber) Close() error

Close closes the kafka subscriber.

func (s Subscriber) Subscribe(channels ...string) (pubsub.Subscription[[]byte], error)

Subscribe subscribes to a kafka topic.

type Subscription ¶

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

Subscription represents a stream of events published to a kafka topic.

func (Subscription) C ¶

func (s Subscription) C() <-chan pubsub.Event[[]byte]

C returns a receive-only go channel of events published.

func (Subscription) Close ¶

func (s Subscription) Close() error

Close closes the subscription.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL