package
0.0.0-20220212221830-387690a0c062
Repository: https://github.com/deechau/kafka.go-generic.git
Documentation: pkg.go.dev
# Functions
NewAvroFsaConsumer creates a consumer which can consume and returns FsaMessage messages.
NewAvroStateConsumer creates a consumer which can consume and returns StateMessage messages.
# Structs
AvroFsaConsumer kafka consumer for the Schema Type Fsa.
AvroStateConsumer kafka consumer for the Schema Type State.
FsaMessage contains Avro Key and Value encoded version of Schema Fsa.
StateMessage contains Avro Key and Value encoded version of Schema State.