Hello,

about this code snippet starting at AbstractKafkaStreamsBinderProcessor:627 (version 4.1.0):

	if (timestampExtractor != null) {
		consumed.withTimestampExtractor(timestampExtractor);
	}

"consumed" is an Consumed-instance which is part of kafka-streams.

In kafka-streams 3.6.1 a call to consumed.withTimestampExtractor() changes the existing instance.
Since kafka-streams 3.7.0 the same call creates a new instance of "Consumed", but the code above ignores this new instance.
In the end, the timestampExtractor is not used at all since kafka 3.7.0.

Same for "consumed.withName" a couple of lines below.

IMHO this is a big change in kafka-streams inside a minor version change.

To fix this anyway the code above might be changed to

	if (timestampExtractor != null) {
		consumed = consumed.withTimestampExtractor(timestampExtractor);
	}

Regards,

Ralf