You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by mj...@apache.org on 2024/08/29 23:38:58 UTC
(kafka) branch trunk updated: KAFKA- 12834 : Removed Deprecated method under MockProcessorContext (#16778)
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 <12...@users.noreply.github.com>
AuthorDate: Fri Aug 30 05:08:52 2024 +0530
KAFKA- 12834 : Removed Deprecated method under MockProcessorContext (#16778)
Reviewers: Josep Prat <jo...@aiven.io>, Matthias J. Sax <ma...@confluent.io>
---
.../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;
}