From 0b7324dc48cc6bafeb0bac2ee83a156472e20636 Mon Sep 17 00:00:00 2001 From: Ayoub Omari Date: Wed, 8 May 2024 19:11:52 +0200 Subject: [PATCH] MINOR: Fix streams javadoc links --- .../apache/kafka/streams/processor/api/RecordMetadata.java | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/streams/src/main/java/org/apache/kafka/streams/processor/api/RecordMetadata.java b/streams/src/main/java/org/apache/kafka/streams/processor/api/RecordMetadata.java index ab88b89f17679..c24b9a7ab168d 100644 --- a/streams/src/main/java/org/apache/kafka/streams/processor/api/RecordMetadata.java +++ b/streams/src/main/java/org/apache/kafka/streams/processor/api/RecordMetadata.java @@ -17,13 +17,14 @@ package org.apache.kafka.streams.processor.api; import org.apache.kafka.streams.kstream.ValueTransformerWithKeySupplier; +import org.apache.kafka.streams.processor.Punctuator; public interface RecordMetadata { /** * Return the topic name of the current input record; could be {@code null} if it is not * available. * - *

For example, if this method is invoked within a @link Punctuator#punctuate(long) + *

For example, if this method is invoked within a {@link Punctuator#punctuate(long) * punctuation callback}, or while processing a record that was forwarded by a punctuation * callback, the record won't have an associated topic. * Another example is @@ -39,7 +40,7 @@ public interface RecordMetadata { * Return the partition id of the current input record; could be {@code -1} if it is not * available. * - *

For example, if this method is invoked within a @link Punctuator#punctuate(long) + *

For example, if this method is invoked within a {@link Punctuator#punctuate(long) * punctuation callback}, or while processing a record that was forwarded by a punctuation * callback, the record won't have an associated partition id. * Another example is @@ -55,7 +56,7 @@ public interface RecordMetadata { * Return the offset of the current input record; could be {@code -1} if it is not * available. * - *

For example, if this method is invoked within a @link Punctuator#punctuate(long) + *

For example, if this method is invoked within a {@link Punctuator#punctuate(long) * punctuation callback}, or while processing a record that was forwarded by a punctuation * callback, the record won't have an associated offset. * Another example is