kafka

Documentation

Index

• Variables
• func KafkaRouter(consumeType string, data []byte, op *kafka.KafkaOpreations)
• func Router(w http.ResponseWriter, req *http.Request, op message_handler.PaymentOperations)

Variables

var LOGGER = logging.MustGetLogger("kafka")

Functions

func KafkaRouter

func KafkaRouter(consumeType string, data []byte, op *kafka.KafkaOpreations)

Once the RFI consumed the Payment request ProtoBuffer from the Kafka broker, it will start processing the message

func Router

func Router(w http.ResponseWriter, req *http.Request, op message_handler.PaymentOperations)