I would like to start discussing KIP-1334: Introduce max.future.record.timestamp.difference.ms to Protect Stream-Time from Future Record Poisoning KIP: https://cwiki.apache.org/confluence/display/KAFKA/KIP-1334+%3A+Introduce+max.future.record.timestamp.difference.ms+to+Protect+Stream-Time+from+Future+Record+Poisoning
JIRA: https://issues.apache.org/jira/browse/KAFKA-20438 Any feedback is appreciated. Thanks and Regards Arpit Goyal 8861094754
