package
Version:
v0.4.22
Opens a new window with list of versions in this module.
Published: Sep 11, 2022
License: MIT
Opens a new window with license information.
Imports: 2
Opens a new window with list of imports.
Imported by: 0
Opens a new window with list of known importers.
Documentation
¶
func NewReader(cfg kafka.ReaderConfig, log logger.Logger) *kafka.Reader
func NewWriter(writer kafka.Writer, log logger.Logger) *kafka.Writer
Source Files
¶
Click to show internal directories.
Click to hide internal directories.