Tweaked Error to expose the underlying error (as Err) and added Error() string {...} to satisfy the error interface. This would be helpful for reacting to specific error cases (e.g. on sarama.ErrOutOfBrokers connect to a secondary cluster). Currently, you would need to do a string comparison on Error().
Tweaked
Errorto expose the underlying error (as Err) and addedError() string {...}to satisfy the error interface. This would be helpful for reacting to specific error cases (e.g. on sarama.ErrOutOfBrokers connect to a secondary cluster). Currently, you would need to do a string comparison onError().