package
1.9.27
Repository: https://github.com/gzorm/common.git
Documentation: pkg.go.dev

# Functions

No description provided by the author
NewPusher returns a Pusher with the given Kafka addresses and topic.
No description provided by the author
WithAllowAutoTopicCreation allows the Pusher to create the given topic if it does not exist.
WithChunkSize customizes the Pusher with the given chunk size.
No description provided by the author
No description provided by the author
WithFlushInterval customizes the Pusher with the given flush interval.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author

# Structs

No description provided by the author
No description provided by the author

# Interfaces

No description provided by the author

# Type aliases

No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author