Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewTopicError ¶
func NewTopicError(kError sarama.KError, message string) *sarama.TopicError
Utility Function For Creating A Sarama TopicError With Specified Kafka Error Code (ErrNoError == Success)
func NewUnknownTopicError ¶
func NewUnknownTopicError(message string) *sarama.TopicError
Utility Function For Creating A New ErrUnknownTopicError With Specified Message
func PromoteErrorToTopicError ¶
func PromoteErrorToTopicError(err error) *sarama.TopicError
Utility Function To Up-Convert Basic Errors Into TopicErrors (With Message Matching For Pertinent Errors)
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.