confluent

Documentation

Index

• type RefWalkFn
• type SchemaInfo
• type SchemaReference

Types

type RefWalkFn

type RefWalkFn func(ctx context.Context, name string, info SchemaInfo) error

type SchemaInfo

type SchemaInfo struct {
	ID         int               `json:"id"`
	Type       string            `json:"schemaType"`
	Schema     string            `json:"schema"`
	References []SchemaReference `json:"references"`
}

type SchemaReference

type SchemaReference struct {
	Name    string `json:"name"`
	Subject string `json:"subject"`
	Version int    `json:"version"`
}

TODO: Further reading: https://www.confluent.io/blog/multiple-event-types-in-the-same-kafka-topic/