Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewAdmin ¶
func NewAdmin(bootstrapServer []string, options ...AdminOption) (*kAdmin, error)
Types ¶
type AdminOption ¶
type AdminOption func(*adminOptions)
func WithKafkaVersion ¶
func WithKafkaVersion(version sarama.KafkaVersion) AdminOption
func WithLogger ¶
func WithLogger(logger log.Logger) AdminOption
Source Files
Click to show internal directories.
Click to hide internal directories.