kafka

func CreateConnectionAndSubmitRecords ¶

func CreateConnectionAndSubmitRecords(ctx context.Context) *kgo.Client

CreateConnectionAndSubmitRecords creates a connection to Kafka and submits records

func ProduceMessages ¶

func ProduceMessages(ctx context.Context, client *kgo.Client, record []*kgo.Record) error

ProduceMessages produces messages to Kafka

func RandomString ¶

func RandomString(n int) string

func RollbackTransaction ¶

func RollbackTransaction(client *kgo.Client) error

RollbackTransaction rolls back a transaction

func SubmitRecords ¶

func SubmitRecords(ctx context.Context, client *kgo.Client, kafkaRecords []*kgo.Record) error

SubmitRecords submits records to Kafka