kafka

package
v0.0.0-...-eeebc8f Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 20, 2018 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CreateConsumer

func CreateConsumer(brokers []string, topic string, groupID string, defaultOffset int64) (eventsourcing.EventConsumer, error)

CreateConsumer creates a new consumer of kafka messages.

func CreatePublisher

func CreatePublisher(brokers []string, topic string, registry eventsourcing.EventRegistry) (eventsourcing.EventPublisher, error)

CreatePublisher creates a new kafka publisher from a set of hosts, using the default publisher settings.

func CreatePublisherWithProducer

func CreatePublisherWithProducer(prod sarama.SyncProducer, topic string, registry eventsourcing.EventRegistry) (eventsourcing.EventPublisher, error)

CreatePublisherWithProducer creates a publisher with a producer that's already been established (BYO-instance)

Types

This section is empty.

Jump to

Keyboard shortcuts

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