consumers

Documentation

Index

• func RunBulkConsumer(conn *kafka.Reader, callback func(<-chan kafka.Message))
• func RunConsumer(conn *kafka.Reader, callback func(m kafka.Message))
• func RunConsumers()

Functions

func RunBulkConsumer

func RunBulkConsumer(conn *kafka.Reader, callback func(<-chan kafka.Message))

Bulk message consumer (based on channel) for high volume message streams

func RunConsumer

func RunConsumer(conn *kafka.Reader, callback func(m kafka.Message))

Serial consumer (based on callback function) for low volume message streams

func RunConsumers

func RunConsumers()

Run all consumers