[KAFKA-12643] Kafka Streams 2.7 with Kafka Broker 2.6.x regression: bad timestamp in transform/process (this.context.schedule function) - ASF JIRA

XML

Word

Printable

JSON

During a tranform() or a process() method:

Define a schedule tyask:

this.context.schedule(Duration.ofSeconds(1), PunctuationType.WALL_CLOCK_TIME, timestamp -> {...}

store.put(...) or context.forward(...) produce a record with an invalid timestamp.

For the forward, a workaround is define the timestamp:

context.forward(entry.key, entry.value.toString(), To.all().withTimestamp(timestamp));

But for state.put(...) or state.delete(...) functions there is no workaround.

Is it mandatory to have the Kafka broker version aligned with the Kafka Streams version?

duplicates

KAFKA-12323 Record timestamps not populated in event