Categorygithub.com/kaydxh/golangpkgmqkafka
package
0.0.131
Repository: https://github.com/kaydxh/golang.git
Documentation: pkg.go.dev
Overview
Versions
1
Dependencies
18
Dependents
0
Files
878 SLOC

# Functions

No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
consumer options.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
base options.
No description provided by the author
producer options.
No description provided by the author
No description provided by the author

# Variables

No description provided by the author

# Structs

No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
EmptyConfigOption does not alter the configuration.
EmptyMQUrlOption does not alter the MQuration.
https://github.com/confluentinc/librdkafka/blob/master/CONFIGURATION.md.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author

# Interfaces

A ConfigOption sets options.
A MQOption sets options.

# Type aliases

ConfigOptionFunc wraps a function that modifies Client into an implementation of the ConfigOption interface.
MQOptionFunc wraps a function that modifies MQ into an implementation of the MQOption interface.