kafka

func Close ¶

func Close()

func Init ¶

func Init() (err error)

func New ¶

func New(cfg config.Kafka) (sarama.Client, error)

New returns a new Kafka client instance with given configuration. It's the caller's responsibility to close the client, caller should always call Close() when it's no longer needed.

func NewAsyncProducer ¶

func NewAsyncProducer(client sarama.Client) (sarama.AsyncProducer, error)

NewAsyncProducer creates a new AsyncProducer using the given client

func NewConsumerGroup ¶

func NewConsumerGroup(client sarama.Client, groupID string) (sarama.ConsumerGroup, error)

NewConsumerGroup creates a new ConsumerGroup with the given client

func NewSyncProducer ¶

func NewSyncProducer(client sarama.Client) (sarama.SyncProducer, error)

NewSyncProducer creates a new SyncProducer using the given client