wireformat

Documentation

Overview

Package wireformat deals with how to serialize/deserialize a dispatcher.Message on a Kafka topic. Currently uses a custom encoding scheme for headers, until Kafka 0.11 headers are supported by go client lib

Index

• func FromKafka(kafka *sarama.ConsumerMessage) (dispatcher.Message, error)
• func ToKafka(message dispatcher.Message) (*sarama.ProducerMessage, error)

Functions

func FromKafka

func FromKafka(kafka *sarama.ConsumerMessage) (dispatcher.Message, error)

func ToKafka

func ToKafka(message dispatcher.Message) (*sarama.ProducerMessage, error)