interfaces

Documentation

Index

• Variables
• type ConsumerGroupInitialiser
• type Message
• type ProducerInitialiser
• type SaramaAsyncProducer
• type SaramaBroker
• type SaramaConsumerGroup
• type SaramaConsumerGroupClaim
• type SaramaConsumerGroupSession

Variables

var SaramaNewAsyncProducer = sarama.NewAsyncProducer

var SaramaNewConsumerGroup = sarama.NewConsumerGroup

Types

type ConsumerGroupInitialiser

type ConsumerGroupInitialiser = func(addrs []string, groupID string, config *sarama.Config) (sarama.ConsumerGroup, error)

Types for sarama initialisers

type Message

type Message interface {

	// GetData returns the message contents.
	GetData() []byte

	// Mark marks the message as consumed, but doesn't commit the offset to the backend
	Mark()

	// Commit marks the message as consumed and commits its offset to the backend
	Commit()

	// Release closes the UpstreamDone channel for this message
	Release()

	// CommitAndRelease marks a message as consumed, commits it and closes the UpstreamDone channel
	CommitAndRelease()

	// Offset returns the message offset
	Offset() int64

	// UpstreamDone returns the upstreamDone channel. Closing this channel notifies that the message has been consumed
	UpstreamDone() chan struct{}
}

Message represents a single kafka message.

type ProducerInitialiser

type ProducerInitialiser = func(addrs []string, config *sarama.Config) (sarama.AsyncProducer, error)

Types for sarama initialisers

type SaramaAsyncProducer

type SaramaAsyncProducer = sarama.AsyncProducer

SaramaAsyncProducer is a wrapper around sarama.AsyncProducer

type SaramaBroker

type SaramaBroker interface {
	Addr() string
	Connected() (bool, error)
	Open(conf *sarama.Config) error
	GetMetadata(request *sarama.MetadataRequest) (*sarama.MetadataResponse, error)
	Close() error
}

type SaramaConsumerGroup

type SaramaConsumerGroup = sarama.ConsumerGroup

SaramaConsumerGroup is a wrapper around sarama.ConsumerGroup

type SaramaConsumerGroupClaim

type SaramaConsumerGroupClaim = sarama.ConsumerGroupClaim

SaramaConsumerGroupClaim is a wrapper around sarama.ConsumerGroupClaim

type SaramaConsumerGroupSession

type SaramaConsumerGroupSession = sarama.ConsumerGroupSession

SaramaConsumerGroupSession is a wrapper around sarama.ConsumerGroupSession