Categorygithub.com/kuper-tech/protokafinternalkafka
package
0.0.0-20240801101038-0fcf166d9ad5
Repository: https://github.com/kuper-tech/protokaf.git
Documentation: pkg.go.dev
Overview
Versions
1
Dependencies
7
Dependents
1
Files
223 SLOC

# Functions

No description provided by the author
NewConsumerGroup creates new ConsumerGroup.
NewProducer creates a new Producer using the given broker addresses and configuration.
NewRecordHeadersFromPointers converts []*sarama.RecordHeader -> []sarama.RecordHeader.
No description provided by the author

# Constants

AuthDSNTemplate template for auth DSN.

# Structs

No description provided by the author
Producer kafka producer.
No description provided by the author
No description provided by the author

# Type aliases

No description provided by the author