lucasbru opened a new pull request, #18830: URL: https://github.com/apache/kafka/pull/18830
In the streams smoke test, flush records that are appended to the input topics, to advance the stream time so that all suppressed windows are flushed in the streams smoke test. They are created with record time with current time + 2 days. caf0b67fbb changed the defaults, so that records more than one hour in the future are rejected by the broker. This breaks the flush messages. By moving all record time stamps 2 days into the past, the existing logic should work correctly with the new default broker configuration. ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ] Verify test coverage and CI build status - [ ] Verify documentation (including upgrade notes) -- 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: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
