Versions in this module Expand all Collapse all v1 v1.0.3 Sep 29, 2022 Changes in this version + func LoadKafkaConfig() ([]kgo.Opt, error) + type Credentials struct + Password string + User string + func SchemaRegistryEndpoint() (string, Credentials, error) + type Flags struct + Format string + Namespace string + Topic string + func (f *Flags) SetFlags(fs *flag.FlagSet) + type LakeFlags struct + func (l *LakeFlags) SetFlags(fs *flag.FlagSet) + type ShaperFlags struct + Path string + func (s *ShaperFlags) Load() (string, error) + func (s *ShaperFlags) SetFlags(fs *flag.FlagSet)
Go to main page