Skip to content

Commit

Permalink
MINOR: Fix streams javadoc links (#15900)
Browse files Browse the repository at this point in the history
Reviewers: Chia-Ping Tsai <chia7712@gmail.com>
  • Loading branch information
AyoubOm committed May 9, 2024
1 parent c64a315 commit 29f3260
Showing 1 changed file with 4 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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.
*
* <p> For example, if this method is invoked within a @link Punctuator#punctuate(long)
* <p> 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
Expand All @@ -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.
*
* <p> For example, if this method is invoked within a @link Punctuator#punctuate(long)
* <p> 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
Expand All @@ -55,7 +56,7 @@ public interface RecordMetadata {
* Return the offset of the current input record; could be {@code -1} if it is not
* available.
*
* <p> For example, if this method is invoked within a @link Punctuator#punctuate(long)
* <p> 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
Expand Down

0 comments on commit 29f3260

Please sign in to comment.