Documentation
¶
Overview ¶
process package contains Kafka message processing functions for media-docker-kafka-consumer.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ProcessMessage ¶
func ProcessMessage(msg kafka.Message, workerName string)
ProcessMessage processes Kafka messages based on the topic and the associated handler. It sends the appropriate success or error response after processing.
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.