Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func InitKafkaPCS ¶
func InitKafkaPCS() (pcs []sarama.PartitionConsumer)
InitKafkaPCS returns the kafka consumer partition channels
func SemiCooKafkaMsg ¶
func SemiCooKafkaMsg(msg *sarama.ConsumerMessage) ([]byte, error)
SemiCooKafkaMsg merge the kafka metadata to message
Types ¶
This section is empty.
Source Files ¶
Click to show internal directories.
Click to hide internal directories.