This is an automated email from the ASF dual-hosted git repository.

mjsax pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new 865cdfc1cdc KAFKA- 12834 : Removed Deprecated method under 
MockProcessorContext (#16778)
865cdfc1cdc is described below

commit 865cdfc1cdc5c623702890bc71de366aacdcb1d6
Author: Nancy <[email protected]>
AuthorDate: Fri Aug 30 05:08:52 2024 +0530

    KAFKA- 12834 : Removed Deprecated method under MockProcessorContext (#16778)
    
    Reviewers: Josep Prat <[email protected]>, Matthias J. Sax 
<[email protected]>
---
 .../kafka/streams/processor/MockProcessorContext.java      | 14 +-------------
 1 file changed, 1 insertion(+), 13 deletions(-)

diff --git 
a/streams/test-utils/src/main/java/org/apache/kafka/streams/processor/MockProcessorContext.java
 
b/streams/test-utils/src/main/java/org/apache/kafka/streams/processor/MockProcessorContext.java
index 6d3419a8d83..e535dbbd8ca 100644
--- 
a/streams/test-utils/src/main/java/org/apache/kafka/streams/processor/MockProcessorContext.java
+++ 
b/streams/test-utils/src/main/java/org/apache/kafka/streams/processor/MockProcessorContext.java
@@ -375,18 +375,6 @@ public class MockProcessorContext implements 
ProcessorContext, RecordCollector.S
         this.headers = headers;
     }
 
-    /**
-     * The context exposes this metadata for use in the processor. Normally, 
they are set by the Kafka Streams framework,
-     * but for the purpose of driving unit tests, you can set it directly. 
Setting this attribute doesn't affect the others.
-     *
-     * @param timestamp A record timestamp
-     * @deprecated Since 3.0.0; use {@link 
MockProcessorContext#setRecordTimestamp(long)} instead.
-     */
-    @Deprecated
-    @SuppressWarnings({"WeakerAccess", "unused"})
-    public void setTimestamp(final long timestamp) {
-        this.recordTimestamp = timestamp;
-    }
 
     /**
      * The context exposes this metadata for use in the processor. Normally, 
they are set by the Kafka Streams framework,
@@ -451,7 +439,7 @@ public class MockProcessorContext implements 
ProcessorContext, RecordCollector.S
     @Override
     public long timestamp() {
         if (recordTimestamp == null) {
-            throw new IllegalStateException("Timestamp must be set before use 
via setRecordMetadata() or setTimestamp().");
+            throw new IllegalStateException("Timestamp must be set before use 
via setRecordMetadata() or setRecordTimestamp().");
         }
         return recordTimestamp;
     }

Reply via email to