gkpcs

package module
v0.0.3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 1, 2021 License: Apache-2.0 Imports: 5 Imported by: 0

README

Go Kafka Protobuf Confluent Serializer

Small library to serialize and deserialized protobuf messages into confluent

Documentation

Index

Constants

View Source
const MagicByte = 0

Variables

This section is empty.

Functions

func Deserialize added in v0.0.2

func Deserialize(data []byte, msg proto.Message) (int, error)

func Serialize

func Serialize(msg proto.Message) ([]byte, error)

Serialize recibes a protobuf message and serialized based on the confluent specification for kafka https://docs.confluent.io/platform/current/schema-registry/serdes-develop/index.html

Types

This section is empty.

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL