package mq

type kafkaMsgHandlerFunc func(data []byte, msgKey string)