MINOR: Log kafka exceptions for debugging
@@ -112,9 +112,11 @@ public class KafkaExceptionMapper extends GenericExceptionMapper {
} else if (HANDLED.containsKey(exception.getClass())) {
return getResponse(exception);
} else if (exception instanceof RetriableException) {
+ log.debug("Kafka retriable exception", exception);
return getResponse(exception, Status.INTERNAL_SERVER_ERROR,
KAFKA_RETRIABLE_ERROR_ERROR_CODE);
} else if (exception instanceof KafkaException) {
+ log.error("Kafka exception", exception);
return getResponse(exception, Status.INTERNAL_SERVER_ERROR,
KAFKA_ERROR_ERROR_CODE);
} else {
