package
1.0.1
Repository: https://github.com/syncromatics/kafmesh.git
Documentation: pkg.go.dev

# Functions

ParseComponent will parse the yaml into a component.
ParseService the reader to a Service.

# Structs

Component is a piece of a service that provides processors that accomplish a task.
Input is an edge of a processor that will take in messages from a topic.
Join is an edge of a processor that takes in a co-partitioned topic and provides the value to the processor by the key of the message.
Lookup is an edge of a processor that takes in a whole topic into a local key value database and makes it available to the processor by key.
MessageDefinitions define where to locate the schema for the messages.
Output is an edge of a processor that outputs into a kafka topic.
OutputSettings define how the service is generated.
Persistence is where the processor stores state data.
Processor processes kafka messages backed by a consumer group and sometimes with persistence.
Service is a description of a kafmesh service.
Sink is a job that will sink a topic to an external source.
Source is a producer into kafka.
TopicCreationDefinition describe how a topic should be created.
TopicDefaults are the default kafka settings for the service.
TopicDefinition describes how to get a topic name and the type of message its record is.
View is a view into kafka.
ViewSink is a job that will sync a kafka view to an external destination.
ViewSource is a job that will sync an external source into a kafka view.