diff --git a/spring-kafka/src/main/java/org/springframework/kafka/support/SeekUtils.java b/spring-kafka/src/main/java/org/springframework/kafka/support/SeekUtils.java index 4b4fe288..15e43971 100644 --- a/spring-kafka/src/main/java/org/springframework/kafka/support/SeekUtils.java +++ b/spring-kafka/src/main/java/org/springframework/kafka/support/SeekUtils.java @@ -53,7 +53,7 @@ public final class SeekUtils { * @param exception the exception * @param recoverable true if skipping the first record is allowed. * @param skipper function to determine whether or not to skip seeking the first. - * @param logger a {@link Log} for seek errors. + * @param logger a {@link LogAccessor} for seek errors. * @return true if the failed record was skipped. */ public static boolean doSeeks(List> records, Consumer consumer, Exception exception,