When we consume non-DecatonTaskRequest topic with TaskExtractor, TaskMetadata#timestampMillis could be set to 0 (i.e. long's default value) if we don't set it explicitly.
Thus, retry tasks will be produced with ProducerRecord#timestamp=0
This could cause the messages to be deleted on the broker side unexpectedly earlier, since retention-based log deletion is happened based on record's timestamp. (https://kafka.apache.org/documentation/#impl_deletes)
TaskExtractor
,TaskMetadata#timestampMillis
could be set to 0 (i.e. long's default value) if we don't set it explicitly.ProducerRecord#timestamp
fromTaskMetadata
ProducerRecord#timestamp=0
This could cause the messages to be deleted on the broker side unexpectedly earlier, since retention-based log deletion is happened based on record's timestamp. (https://kafka.apache.org/documentation/#impl_deletes)