package
2.7.1+incompatible
Repository: https://github.com/streamdal/plumber.git
Documentation: pkg.go.dev
# Structs
OffsetInfo encapsulates info related to the offset count in the.
RelayMessage encapsulates a kafka message that is read by relay.Run().
RelayMessageOptions contains any additional options necessary for processing of Kafka messages by the relayer.