mjsax commented on code in PR #17198:
URL: https://github.com/apache/kafka/pull/17198#discussion_r1828379738
##########
streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamThreadTest.java:
##########
@@ -2289,34 +2289,29 @@ public void process(final Record<Object, Object>
record) {}
}
@ParameterizedTest
- @MethodSource("data")
- @SuppressWarnings("deprecation")
+ @MethodSource("data")
public void shouldPunctuateWithTimestampPreservedInProcessorContext(final
boolean stateUpdaterEnabled, final boolean processingThreadsEnabled) {
assumeFalse(processingThreadsEnabled);
- final org.apache.kafka.streams.kstream.TransformerSupplier<Object,
Object, KeyValue<Object, Object>> punctuateProcessor =
- () -> new org.apache.kafka.streams.kstream.Transformer<Object,
Object, KeyValue<Object, Object>>() {
- @Override
- public void init(final
org.apache.kafka.streams.processor.ProcessorContext context) {
- context.schedule(Duration.ofMillis(100L),
PunctuationType.WALL_CLOCK_TIME, timestamp -> context.forward("key", "value"));
- context.schedule(Duration.ofMillis(100L),
PunctuationType.STREAM_TIME, timestamp -> context.forward("key", "value"));
- }
-
- @Override
- public KeyValue<Object, Object> transform(final Object key,
final Object value) {
- return null;
- }
+ final ProcessorSupplier<Object, Object, Object, Object>
punctuateProcessor = () -> new Processor<>() {
+ @Override
+ public void init(final ProcessorContext<Object, Object> context) {
+ final var duration = Duration.ofMillis(100L);
Review Comment:
```suggestion
final Duration duration = Duration.ofMillis(100L);
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
