Skip to content

Commit

Permalink
Fix javadocs in back-port
Browse files Browse the repository at this point in the history
  • Loading branch information
garyrussell committed Jul 27, 2020
1 parent 3d1cd0a commit 7a53401
Showing 1 changed file with 2 additions and 3 deletions.
Expand Up @@ -48,7 +48,6 @@
import org.springframework.kafka.support.KafkaHeaders;
import org.springframework.kafka.support.TopicPartitionOffset;
import org.springframework.kafka.support.serializer.DeserializationException;
import org.springframework.kafka.support.serializer.ErrorHandlingDeserializer;
import org.springframework.kafka.support.serializer.ErrorHandlingDeserializer2;
import org.springframework.lang.Nullable;
import org.springframework.scheduling.TaskScheduler;
Expand Down Expand Up @@ -465,8 +464,8 @@ public void onMessage(List<ConsumerRecord<K, R>> data) {
* deserialization; null otherwise. If you need to determine whether it was the key or
* value, call
* {@link ListenerUtils#getExceptionFromHeader(ConsumerRecord, String, LogAccessor)}
* with {@link ErrorHandlingDeserializer#KEY_DESERIALIZER_EXCEPTION_HEADER} and
* {@link ErrorHandlingDeserializer#VALUE_DESERIALIZER_EXCEPTION_HEADER} instead.
* with {@link ErrorHandlingDeserializer2#KEY_DESERIALIZER_EXCEPTION_HEADER} and
* {@link ErrorHandlingDeserializer2#VALUE_DESERIALIZER_EXCEPTION_HEADER} instead.
* @param record the record.
* @param logger a {@link LogAccessor}.
* @return the {@link DeserializationException} or {@code null}.
Expand Down

0 comments on commit 7a53401

Please sign in to comment.