diff --git a/clients/src/main/java/org/apache/kafka/clients/admin/ConsumerGroupDescription.java b/clients/src/main/java/org/apache/kafka/clients/admin/ConsumerGroupDescription.java index ed4eb2fa94939..b2c44d4fbeb63 100644 --- a/clients/src/main/java/org/apache/kafka/clients/admin/ConsumerGroupDescription.java +++ b/clients/src/main/java/org/apache/kafka/clients/admin/ConsumerGroupDescription.java @@ -47,7 +47,7 @@ public class ConsumerGroupDescription { private final Optional targetAssignmentEpoch; /** - * @deprecated Since 4.0. Use {@link #ConsumerGroupDescription(String, boolean, Collection, String, GroupType, GroupState, Node, Set, Optional, Optional)}. + * @deprecated Since 4.0. Use {@link #ConsumerGroupDescription(String, boolean, Collection, String, GroupType, GroupState, Node, Set, Optional, Optional)} instead. */ @Deprecated public ConsumerGroupDescription(String groupId, @@ -60,7 +60,7 @@ public ConsumerGroupDescription(String groupId, } /** - * @deprecated Since 4.0. Use {@link #ConsumerGroupDescription(String, boolean, Collection, String, GroupType, GroupState, Node, Set, Optional, Optional)}. + * @deprecated Since 4.0. Use {@link #ConsumerGroupDescription(String, boolean, Collection, String, GroupType, GroupState, Node, Set, Optional, Optional)} instead. */ @Deprecated public ConsumerGroupDescription(String groupId, @@ -74,7 +74,7 @@ public ConsumerGroupDescription(String groupId, } /** - * @deprecated Since 4.0. Use {@link #ConsumerGroupDescription(String, boolean, Collection, String, GroupType, GroupState, Node, Set, Optional, Optional)}. + * @deprecated Since 4.0. Use {@link #ConsumerGroupDescription(String, boolean, Collection, String, GroupType, GroupState, Node, Set, Optional, Optional)} instead. */ @Deprecated public ConsumerGroupDescription(String groupId, diff --git a/clients/src/main/java/org/apache/kafka/clients/admin/ConsumerGroupListing.java b/clients/src/main/java/org/apache/kafka/clients/admin/ConsumerGroupListing.java index 7081811a2395c..34b9f08f10e06 100644 --- a/clients/src/main/java/org/apache/kafka/clients/admin/ConsumerGroupListing.java +++ b/clients/src/main/java/org/apache/kafka/clients/admin/ConsumerGroupListing.java @@ -49,7 +49,7 @@ public ConsumerGroupListing(String groupId, boolean isSimpleConsumerGroup) { * @param groupId Group Id. * @param isSimpleConsumerGroup If consumer group is simple or not. * @param state The state of the consumer group. - * @deprecated Since 4.0. Use {@link #ConsumerGroupListing(String, Optional, boolean)}. + * @deprecated Since 4.0. Use {@link #ConsumerGroupListing(String, Optional, boolean)} instead. */ @Deprecated public ConsumerGroupListing(String groupId, boolean isSimpleConsumerGroup, Optional state) { @@ -63,7 +63,7 @@ public ConsumerGroupListing(String groupId, boolean isSimpleConsumerGroup, Optio * @param isSimpleConsumerGroup If consumer group is simple or not. * @param state The state of the consumer group. * @param type The type of the consumer group. - * @deprecated Since 4.0. Use {@link #ConsumerGroupListing(String, Optional, Optional, boolean)}. + * @deprecated Since 4.0. Use {@link #ConsumerGroupListing(String, Optional, Optional, boolean)} instead. */ @Deprecated public ConsumerGroupListing( @@ -133,7 +133,7 @@ public Optional groupState() { /** * Consumer Group state - * @deprecated Since 4.0. Use {@link #groupState()}. + * @deprecated Since 4.0. Use {@link #groupState()} instead. */ @Deprecated public Optional state() { diff --git a/clients/src/main/java/org/apache/kafka/clients/admin/CreateDelegationTokenOptions.java b/clients/src/main/java/org/apache/kafka/clients/admin/CreateDelegationTokenOptions.java index c3899b5bd1ea7..8e5c24aa6fc1f 100644 --- a/clients/src/main/java/org/apache/kafka/clients/admin/CreateDelegationTokenOptions.java +++ b/clients/src/main/java/org/apache/kafka/clients/admin/CreateDelegationTokenOptions.java @@ -54,7 +54,7 @@ public Optional owner() { } /** - * @deprecated since 4.0 and should not be used any longer. + * @deprecated Since 4.0 and should not be used any longer. */ @Deprecated public CreateDelegationTokenOptions maxlifeTimeMs(long maxLifetimeMs) { @@ -68,7 +68,7 @@ public CreateDelegationTokenOptions maxLifetimeMs(long maxLifetimeMs) { } /** - * @deprecated since 4.0 and should not be used any longer. + * @deprecated Since 4.0 and should not be used any longer. */ @Deprecated public long maxlifeTimeMs() { diff --git a/clients/src/main/java/org/apache/kafka/clients/admin/ListConsumerGroupsOptions.java b/clients/src/main/java/org/apache/kafka/clients/admin/ListConsumerGroupsOptions.java index 3c9ea28d45f41..b63ad77c59ab4 100644 --- a/clients/src/main/java/org/apache/kafka/clients/admin/ListConsumerGroupsOptions.java +++ b/clients/src/main/java/org/apache/kafka/clients/admin/ListConsumerGroupsOptions.java @@ -52,7 +52,7 @@ public ListConsumerGroupsOptions inGroupStates(Set groupStates) { * If states is set, only groups in these states will be returned by listConsumerGroups(). * Otherwise, all groups are returned. * This operation is supported by brokers with version 2.6.0 or later. - * @deprecated Since 4.0. Use {@link #inGroupStates(Set)}. + * @deprecated Since 4.0. Use {@link #inGroupStates(Set)} instead. */ @Deprecated public ListConsumerGroupsOptions inStates(Set states) { @@ -80,7 +80,7 @@ public Set groupStates() { /** * Returns the list of States that are requested or empty if no states have been specified. - * @deprecated Since 4.0. Use {@link #inGroupStates(Set)}. + * @deprecated Since 4.0. Use {@link #inGroupStates(Set)} instead. */ @Deprecated public Set states() { diff --git a/clients/src/main/java/org/apache/kafka/clients/admin/MemberDescription.java b/clients/src/main/java/org/apache/kafka/clients/admin/MemberDescription.java index 0785f2e67155f..e72a48d8a626c 100644 --- a/clients/src/main/java/org/apache/kafka/clients/admin/MemberDescription.java +++ b/clients/src/main/java/org/apache/kafka/clients/admin/MemberDescription.java @@ -57,7 +57,7 @@ public MemberDescription( } /** - * @deprecated Since 4.0. Use {@link #MemberDescription(String, Optional, String, String, MemberAssignment, Optional, Optional, Optional)}. + * @deprecated Since 4.0. Use {@link #MemberDescription(String, Optional, String, String, MemberAssignment, Optional, Optional, Optional)} instead. */ @Deprecated public MemberDescription( @@ -81,7 +81,7 @@ public MemberDescription( } /** - * @deprecated Since 4.0. Use {@link #MemberDescription(String, Optional, String, String, MemberAssignment, Optional, Optional, Optional)}. + * @deprecated Since 4.0. Use {@link #MemberDescription(String, Optional, String, String, MemberAssignment, Optional, Optional, Optional)} instead. */ @Deprecated public MemberDescription( @@ -102,7 +102,7 @@ public MemberDescription( } /** - * @deprecated Since 4.0. Use {@link #MemberDescription(String, Optional, String, String, MemberAssignment, Optional, Optional, Optional)}. + * @deprecated Since 4.0. Use {@link #MemberDescription(String, Optional, String, String, MemberAssignment, Optional, Optional, Optional)} instead. */ @Deprecated public MemberDescription(String memberId, diff --git a/clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerRecords.java b/clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerRecords.java index 535313b1f2f28..0cb3b8f967799 100644 --- a/clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerRecords.java +++ b/clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerRecords.java @@ -37,6 +37,9 @@ public class ConsumerRecords implements Iterable> { private final Map>> records; private final Map nextOffsets; + /** + * @deprecated Since 4.0. Use {@link #ConsumerRecords(Map, Map)} instead. + */ @Deprecated public ConsumerRecords(Map>> records) { this(records, Map.of()); diff --git a/clients/src/main/java/org/apache/kafka/clients/consumer/MockConsumer.java b/clients/src/main/java/org/apache/kafka/clients/consumer/MockConsumer.java index 9ee66e4f320ce..b9e69806694dd 100644 --- a/clients/src/main/java/org/apache/kafka/clients/consumer/MockConsumer.java +++ b/clients/src/main/java/org/apache/kafka/clients/consumer/MockConsumer.java @@ -82,7 +82,7 @@ public class MockConsumer implements Consumer { private final List addedMetrics = new ArrayList<>(); /** - * @deprecated Since 4.0. Use {@link #MockConsumer(String)}. + * @deprecated Since 4.0. Use {@link #MockConsumer(String)} instead. */ @Deprecated public MockConsumer(OffsetResetStrategy offsetResetStrategy) { diff --git a/clients/src/main/java/org/apache/kafka/clients/consumer/OffsetResetStrategy.java b/clients/src/main/java/org/apache/kafka/clients/consumer/OffsetResetStrategy.java index 8c84863f60ff8..42a9c268de8b4 100644 --- a/clients/src/main/java/org/apache/kafka/clients/consumer/OffsetResetStrategy.java +++ b/clients/src/main/java/org/apache/kafka/clients/consumer/OffsetResetStrategy.java @@ -19,7 +19,7 @@ import java.util.Locale; /** - * @deprecated Since 4.0. Use {@link org.apache.kafka.clients.consumer.internals.AutoOffsetResetStrategy instead.} + * @deprecated Since 4.0. Use {@link org.apache.kafka.clients.consumer.internals.AutoOffsetResetStrategy} instead. */ @Deprecated public enum OffsetResetStrategy { diff --git a/clients/src/main/java/org/apache/kafka/common/errors/RecordDeserializationException.java b/clients/src/main/java/org/apache/kafka/common/errors/RecordDeserializationException.java index aee57c47d28de..6ed441d444b9b 100644 --- a/clients/src/main/java/org/apache/kafka/common/errors/RecordDeserializationException.java +++ b/clients/src/main/java/org/apache/kafka/common/errors/RecordDeserializationException.java @@ -45,6 +45,9 @@ public enum DeserializationExceptionOrigin { private final ByteBuffer valueBuffer; private final Headers headers; + /** + * @deprecated Since 3.9. Use {@link #RecordDeserializationException(DeserializationExceptionOrigin, TopicPartition, long, long, TimestampType, ByteBuffer, ByteBuffer, Headers, String, Throwable)} instead. + */ @Deprecated public RecordDeserializationException(TopicPartition partition, long offset, diff --git a/streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java b/streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java index 11dc049958e8c..7f1e460c711fa 100644 --- a/streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java +++ b/streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java @@ -165,6 +165,7 @@ public class StreamsConfig extends AbstractConfig { @Deprecated @SuppressWarnings("unused") public static final int DUMMY_THREAD_INDEX = 1; + public static final long MAX_TASK_IDLE_MS_DISABLED = -1; // We impose these limitations because client tags are encoded into the subscription info, @@ -486,7 +487,7 @@ public class StreamsConfig extends AbstractConfig { private static final String BUILT_IN_METRICS_VERSION_DOC = "Version of the built-in metrics to use."; /** {@code cache.max.bytes.buffering} - * @deprecated since 3.4.0 Use {@link #STATESTORE_CACHE_MAX_BYTES_CONFIG "statestore.cache.max.bytes"} instead. */ + * @deprecated Since 3.4. Use {@link #STATESTORE_CACHE_MAX_BYTES_CONFIG "statestore.cache.max.bytes"} instead. */ @SuppressWarnings("WeakerAccess") @Deprecated public static final String CACHE_MAX_BYTES_BUFFERING_CONFIG = "cache.max.bytes.buffering"; @@ -520,7 +521,7 @@ public class StreamsConfig extends AbstractConfig { /** * {@code default.deserialization.exception.handler} - * @deprecated since 4.0; use {@link #DESERIALIZATION_EXCEPTION_HANDLER_CLASS_CONFIG} instead + * @deprecated Since 4.0. Use {@link #DESERIALIZATION_EXCEPTION_HANDLER_CLASS_CONFIG} instead. */ @SuppressWarnings("WeakerAccess") @Deprecated @@ -535,7 +536,7 @@ public class StreamsConfig extends AbstractConfig { /** * {@code default.production.exception.handler} - * @deprecated since 4.0; Use {@link #PRODUCTION_EXCEPTION_HANDLER_CLASS_CONFIG} instead + * @deprecated Since 4.0. Use {@link #PRODUCTION_EXCEPTION_HANDLER_CLASS_CONFIG} instead. */ @SuppressWarnings("WeakerAccess") @Deprecated @@ -546,7 +547,10 @@ public class StreamsConfig extends AbstractConfig { public static final String PRODUCTION_EXCEPTION_HANDLER_CLASS_CONFIG = "production.exception.handler"; private static final String PRODUCTION_EXCEPTION_HANDLER_CLASS_DOC = "Exception handling class that implements the org.apache.kafka.streams.errors.ProductionExceptionHandler interface."; - /** {@code default.dsl.store} */ + /** + * {@code default.dsl.store} + * @deprecated Since 3.7. Use {@link #DSL_STORE_SUPPLIERS_CLASS_CONFIG} instead. + */ @Deprecated @SuppressWarnings("WeakerAccess") public static final String DEFAULT_DSL_STORE_CONFIG = "default.dsl.store"; @@ -2032,7 +2036,7 @@ public DeserializationExceptionHandler deserializationExceptionHandler() { } /** - * @deprecated since kafka 4.0; use {@link #deserializationExceptionHandler()} instead + * @deprecated Since 4.0. Use {@link #deserializationExceptionHandler()} instead. */ @Deprecated @SuppressWarnings("WeakerAccess") @@ -2054,7 +2058,7 @@ public ProductionExceptionHandler productionExceptionHandler() { } /** - * @deprecated since kafka 4.0; use {@link #productionExceptionHandler()} instead + * @deprecated Since 4.0. Use {@link #productionExceptionHandler()} instead. */ @Deprecated @SuppressWarnings("WeakerAccess") diff --git a/streams/src/main/java/org/apache/kafka/streams/errors/DefaultProductionExceptionHandler.java b/streams/src/main/java/org/apache/kafka/streams/errors/DefaultProductionExceptionHandler.java index 8b1562861c4c7..5994326770c89 100644 --- a/streams/src/main/java/org/apache/kafka/streams/errors/DefaultProductionExceptionHandler.java +++ b/streams/src/main/java/org/apache/kafka/streams/errors/DefaultProductionExceptionHandler.java @@ -26,6 +26,9 @@ * happens while attempting to produce result records. */ public class DefaultProductionExceptionHandler implements ProductionExceptionHandler { + /** + * @deprecated Since 3.9. Use {@link #handle(ErrorHandlerContext, ProducerRecord, Exception)} instead. + */ @SuppressWarnings("deprecation") @Deprecated @Override diff --git a/streams/src/main/java/org/apache/kafka/streams/errors/LogAndContinueExceptionHandler.java b/streams/src/main/java/org/apache/kafka/streams/errors/LogAndContinueExceptionHandler.java index 3622da137c16e..6de997be98653 100644 --- a/streams/src/main/java/org/apache/kafka/streams/errors/LogAndContinueExceptionHandler.java +++ b/streams/src/main/java/org/apache/kafka/streams/errors/LogAndContinueExceptionHandler.java @@ -31,6 +31,9 @@ public class LogAndContinueExceptionHandler implements DeserializationExceptionHandler { private static final Logger log = LoggerFactory.getLogger(LogAndContinueExceptionHandler.class); + /** + * @deprecated Since 3.9. Use {@link #handle(ErrorHandlerContext, ConsumerRecord, Exception)} instead. + */ @SuppressWarnings("deprecation") @Deprecated @Override diff --git a/streams/src/main/java/org/apache/kafka/streams/errors/LogAndFailExceptionHandler.java b/streams/src/main/java/org/apache/kafka/streams/errors/LogAndFailExceptionHandler.java index aaef5ca050b78..20e6b9414de27 100644 --- a/streams/src/main/java/org/apache/kafka/streams/errors/LogAndFailExceptionHandler.java +++ b/streams/src/main/java/org/apache/kafka/streams/errors/LogAndFailExceptionHandler.java @@ -31,6 +31,9 @@ public class LogAndFailExceptionHandler implements DeserializationExceptionHandler { private static final Logger log = LoggerFactory.getLogger(LogAndFailExceptionHandler.class); + /** + * @deprecated Since 3.9. Use {@link #handle(ErrorHandlerContext, ConsumerRecord, Exception)} instead. + */ @SuppressWarnings("deprecation") @Deprecated @Override diff --git a/streams/src/main/java/org/apache/kafka/streams/kstream/ForeachProcessor.java b/streams/src/main/java/org/apache/kafka/streams/kstream/ForeachProcessor.java index 1555fbd7d05e3..da25edae6517b 100644 --- a/streams/src/main/java/org/apache/kafka/streams/kstream/ForeachProcessor.java +++ b/streams/src/main/java/org/apache/kafka/streams/kstream/ForeachProcessor.java @@ -20,7 +20,7 @@ import org.apache.kafka.streams.processor.api.Record; /** - * @deprecated since 4.0 and should not be used any longer. + * @deprecated Since 4.0 and should not be used any longer. */ @Deprecated public class ForeachProcessor implements Processor { diff --git a/streams/src/main/java/org/apache/kafka/streams/kstream/JoinWindows.java b/streams/src/main/java/org/apache/kafka/streams/kstream/JoinWindows.java index f26aee5a4a41d..4690ffdfe7c47 100644 --- a/streams/src/main/java/org/apache/kafka/streams/kstream/JoinWindows.java +++ b/streams/src/main/java/org/apache/kafka/streams/kstream/JoinWindows.java @@ -154,7 +154,7 @@ public static JoinWindows ofTimeDifferenceWithNoGrace(final Duration timeDiffere * @param timeDifference join window interval * @return a new JoinWindows object with the window definition with and grace period (default to 24 hours minus {@code timeDifference}) * @throws IllegalArgumentException if {@code timeDifference} is negative or can't be represented as {@code long milliseconds} - * @deprecated since 3.0. Use {@link #ofTimeDifferenceWithNoGrace(Duration)}} instead + * @deprecated Since 3.0. Use {@link #ofTimeDifferenceWithNoGrace(Duration)}} instead. */ @Deprecated public static JoinWindows of(final Duration timeDifference) throws IllegalArgumentException { @@ -221,7 +221,7 @@ public long size() { * @return this updated builder * @throws IllegalArgumentException if the {@code afterWindowEnd} is negative or can't be represented as {@code long milliseconds} * @throws IllegalStateException if {@link #grace(Duration)} is called after {@link #ofTimeDifferenceAndGrace(Duration, Duration)} or {@link #ofTimeDifferenceWithNoGrace(Duration)} - * @deprecated since 3.0. Use {@link #ofTimeDifferenceAndGrace(Duration, Duration)} instead + * @deprecated Since 3.0. Use {@link #ofTimeDifferenceAndGrace(Duration, Duration)} instead. */ @Deprecated public JoinWindows grace(final Duration afterWindowEnd) throws IllegalArgumentException { diff --git a/streams/src/main/java/org/apache/kafka/streams/kstream/Joined.java b/streams/src/main/java/org/apache/kafka/streams/kstream/Joined.java index 109879579a6fb..f1df05fe2e525 100644 --- a/streams/src/main/java/org/apache/kafka/streams/kstream/Joined.java +++ b/streams/src/main/java/org/apache/kafka/streams/kstream/Joined.java @@ -273,7 +273,7 @@ public Joined withGracePeriod(final Duration gracePeriod) { /** - * @deprecated since 4.0 and should not be used any longer. + * @deprecated Since 4.0 and should not be used any longer. */ @Deprecated public Duration gracePeriod() { @@ -281,7 +281,7 @@ public Duration gracePeriod() { } /** - * @deprecated since 4.0 and should not be used any longer. + * @deprecated Since 4.0 and should not be used any longer. */ @Deprecated public Serde keySerde() { @@ -289,7 +289,7 @@ public Serde keySerde() { } /** - * @deprecated since 4.0 and should not be used any longer. + * @deprecated Since 4.0 and should not be used any longer. */ @Deprecated public Serde valueSerde() { @@ -297,7 +297,7 @@ public Serde valueSerde() { } /** - * @deprecated since 4.0 and should not be used any longer. + * @deprecated Since 4.0 and should not be used any longer. */ @Deprecated public Serde otherValueSerde() { diff --git a/tools/src/main/java/org/apache/kafka/tools/TopicCommand.java b/tools/src/main/java/org/apache/kafka/tools/TopicCommand.java index d225749fa79f1..e5171057c6cc0 100644 --- a/tools/src/main/java/org/apache/kafka/tools/TopicCommand.java +++ b/tools/src/main/java/org/apache/kafka/tools/TopicCommand.java @@ -709,7 +709,7 @@ public static final class TopicCommandOptions extends CommandDefaultOptions { private final ArgumentAcceptingOptionSpec configOpt; /** - * @deprecated since 4.0 and should not be used any longer. + * @deprecated Since 4.0 and should not be used any longer. */ @Deprecated private final ArgumentAcceptingOptionSpec deleteConfigOpt;