Add since tag to the Javadoc for SourceConnector::alterOffsets and Si…

…nkConnector::alterOffsets
apache · Jun 23, 2023 · cd4c1f2 · cd4c1f2
1 parent 4ebe51f
commit cd4c1f2
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 0 deletions.
diff --git a/connect/api/src/main/java/org/apache/kafka/connect/sink/SinkConnector.java b/connect/api/src/main/java/org/apache/kafka/connect/sink/SinkConnector.java
@@ -73,6 +73,7 @@ protected SinkConnectorContext context() {
      * @throws UnsupportedOperationException if it is impossible to alter/reset the offsets for this connector
      * @throws org.apache.kafka.connect.errors.ConnectException if the offsets for this connector cannot be
      * reset for any other reason (for example, they have failed custom validation logic specific to this connector)
+     * @since 3.6
      */
     public boolean alterOffsets(Map<String, String> connectorConfig, Map<TopicPartition, Long> offsets) {
         return false;

diff --git a/connect/api/src/main/java/org/apache/kafka/connect/source/SourceConnector.java b/connect/api/src/main/java/org/apache/kafka/connect/source/SourceConnector.java
@@ -104,6 +104,7 @@ public ConnectorTransactionBoundaries canDefineTransactionBoundaries(Map<String,
      * @throws UnsupportedOperationException if it is impossible to alter/reset the offsets for this connector
      * @throws org.apache.kafka.connect.errors.ConnectException if the offsets for this connector cannot be
      * reset for any other reason (for example, they have failed custom validation logic specific to this connector)
+     * @since 3.6
      */
     public boolean alterOffsets(Map<String, String> connectorConfig, Map<Map<String, ?>, Map<String, ?>> offsets) {
         return false;