kafka

Documentation

Index

• func NewAsyncProducer(c Config) (sarama.AsyncProducer, error)
• func NewConsumer(c Config) error
• func NewSyncProducer(c Config) (sarama.SyncProducer, error)
• type Config

Functions

func NewAsyncProducer

func NewAsyncProducer(c Config) (sarama.AsyncProducer, error)

NewAsyncProducer 创建一个异步生产者

func NewConsumer

func NewConsumer(c Config) error

NewConsumer 创建一个消费者

func NewSyncProducer

func NewSyncProducer(c Config) (sarama.SyncProducer, error)

Types

type Config

type Config struct {
	Addrs []string
	Topic string
}