Documentation
¶
Index ¶
- func FetchMessages(cl *kgo.Client, commit bool, numRecords int) ([]*kgo.Record, error)
- func GetClient(auth c.AuthType, brokers []string, group, topic string) (*kgo.Client, error)
- func GetDescriptorFromDescriptorSet(descSetBytes []byte, descriptorName protoreflect.FullName) (protoreflect.MessageDescriptor, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func FetchMessages ¶
func GetDescriptorFromDescriptorSet ¶
func GetDescriptorFromDescriptorSet(descSetBytes []byte, descriptorName protoreflect.FullName) (protoreflect.MessageDescriptor, error)
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.