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;
}