Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewReaderWithTopic ¶
func NewReaderWithTopic(app *configx.Application, topic string) (*kafka.Reader, error)
NewReaderWithTopic returns a new Reader instance with the specified topic.
func NewWriterWithTopic ¶
func NewWriterWithTopic(app *configx.Application, topic string) (*kafka.Writer, error)
NewWriterWithTopic will create a new kafka writer with topic
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.