kafka

Documentation

Index

• Variables
• func InitConsumer(...) (*kafka.Consumer, error)
• func Initialize() (*kafka.Consumer, error)
• func ReqConsumer(c *kafka.Consumer, topic string, partition int32) (kafka.TopicPartitions, []*kafka.Message, error)

Variables

var LOGGER = logging.MustGetLogger("kafka")

Functions

func InitConsumer

func InitConsumer(brokerURL, groupId, autoOffReset, securityProtocol, caLocation, certLocation, keyLocation, keyPassword, saslUsername, saslPassword, saslMechanism string) (*kafka.Consumer, error)

func Initialize

func Initialize() (*kafka.Consumer, error)

func ReqConsumer

func ReqConsumer(c *kafka.Consumer, topic string, partition int32) (kafka.TopicPartitions, []*kafka.Message, error)