sarama/errors.go

package kafka

type kafkaError int16

const (
	NO_ERROR                    kafkaError = 0
	UNKNOWN                                = -1
	OFFSET_OUT_OF_RANGE                    = 1
	INVALID_MESSAGE                        = 2
	UNKNOWN_TOPIC_OR_PARTITION             = 3
	INVALID_MESSAGE_SIZE                   = 4
	LEADER_NOT_AVAILABLE                   = 5
	NOT_LEADER_FOR_PARTITION               = 6
	REQUEST_TIMED_OUT                      = 7
	BROKER_NOT_AVAILABLE                   = 8
	REPLICA_NOT_AVAILABLE                  = 9
	MESSAGE_SIZE_TOO_LARGE                 = 10
	STALE_CONTROLLER_EPOCH_CODE            = 11
)