Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Producer ¶
type Producer interface {
SendMessage(ctx context.Context, topic string, key string, message []byte) error
Close() error
}
Producer is the interface that wraps the basic Produce method
type SaramaKafkaConsumer ¶
type SaramaKafkaConsumer struct {
// contains filtered or unexported fields
}
func NewSaramaKafkaConsumer ¶
func NewSaramaKafkaConsumer(brokers []string, groupID string) (*SaramaKafkaConsumer, error)
func (*SaramaKafkaConsumer) Close ¶
func (sc *SaramaKafkaConsumer) Close() error
func (*SaramaKafkaConsumer) ConsumeMessages ¶
func (sc *SaramaKafkaConsumer) ConsumeMessages(ctx context.Context, topics []string) error
type SaramaKafkaProducer ¶
type SaramaKafkaProducer struct {
// contains filtered or unexported fields
}
func NewSaramaKafkaProducer ¶
func NewSaramaKafkaProducer(brokers []string) (*SaramaKafkaProducer, error)
func (*SaramaKafkaProducer) Close ¶
func (sp *SaramaKafkaProducer) Close() error
func (*SaramaKafkaProducer) SendMessage ¶
Source Files
Click to show internal directories.
Click to hide internal directories.