Documentation
¶
Index ¶
- func CreateConsumer(brokers []string, topic string, groupID string, defaultOffset int64) (eventsourcing.EventConsumer, error)
- func CreatePublisher(brokers []string, topic string, registry eventsourcing.EventRegistry) (eventsourcing.EventPublisher, error)
- func CreatePublisherWithProducer(prod sarama.SyncProducer, topic string, registry eventsourcing.EventRegistry) (eventsourcing.EventPublisher, error)
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.
Source Files
Click to show internal directories.
Click to hide internal directories.