in core/src/main/java/org/apache/camel/kafkaconnector/utils/TaskHelper.java [131:155]
public static void logRecordContent(Logger logger, LoggingLevel level, ConnectRecord<?> record) {
if (level == LoggingLevel.OFF) {
return;
}
switch (level) {
case TRACE:
logger.trace(record.toString());
break;
case DEBUG:
logger.debug(record.toString());
break;
case INFO:
logger.info(record.toString());
break;
case WARN:
logger.warn(record.toString());
break;
case ERROR:
logger.error(record.toString());
break;
default:
break;
}
}