Documentation
¶
Overview ¶
Package v2 provides a client with included tracing capabilities.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AsyncProducer ¶
type AsyncProducer struct {
// contains filtered or unexported fields
}
AsyncProducer is an asynchronous Kafka producer.
func (*AsyncProducer) ActiveBrokers ¶
func (p *AsyncProducer) ActiveBrokers() []string
ActiveBrokers returns a list of active brokers' addresses.
func (*AsyncProducer) Close ¶
func (ap *AsyncProducer) Close() error
Close shuts down the producer and waits for any buffered messages to be flushed. You must call this function before a producer object passes out of scope, as it may otherwise leak memory.
func (*AsyncProducer) Send ¶
func (ap *AsyncProducer) Send(ctx context.Context, msg *sarama.ProducerMessage) error
Send a message to a topic, asynchronously. Producer errors are queued on the channel obtained during the AsyncProducer creation.
type Builder ¶
type Builder struct {
// contains filtered or unexported fields
}
Builder definition for creating sync and async producers.
func New ¶
New initiates the AsyncProducer/SyncProducer builder chain with the default sarama configuration.
func (*Builder) Create ¶
func (b *Builder) Create() (*SyncProducer, error)
Create a new synchronous producer.
func (Builder) CreateAsync ¶
func (b Builder) CreateAsync() (*AsyncProducer, <-chan error, error)
CreateAsync a new asynchronous producer.
type SyncProducer ¶
type SyncProducer struct {
// contains filtered or unexported fields
}
SyncProducer is a synchronous Kafka producer.
func (*SyncProducer) ActiveBrokers ¶
func (p *SyncProducer) ActiveBrokers() []string
ActiveBrokers returns a list of active brokers' addresses.
func (*SyncProducer) Close ¶
func (p *SyncProducer) Close() error
Close shuts down the producer and waits for any buffered messages to be flushed. You must call this function before a producer object passes out of scope, as it may otherwise leak memory.
func (*SyncProducer) Send ¶
func (p *SyncProducer) Send(ctx context.Context, msg *sarama.ProducerMessage) (partition int32, offset int64, err error)
Send a message to a topic.
Source Files