Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.