kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mj...@apache.org
Subject [kafka] branch trunk updated (5d0cb14 -> deafc56)
Date Mon, 09 Dec 2019 03:23:51 GMT
This is an automated email from the ASF dual-hosted git repository.

mjsax pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.


    from 5d0cb14  KAFKA-9212; Ensure LeaderAndIsr state updated in controller context during
reassignment (#7795)
     add deafc56  KAFKA-8953: Rename UsePreviousTimeOnInvalidTimestamp to UsePartitionTimeOnInvalidTimestamp
(#7633)

No new revisions were added by this update.

Summary of changes:
 docs/streams/developer-guide/config-streams.html         |  2 +-
 docs/streams/upgrade-guide.html                          |  6 ++++++
 .../processor/ExtractRecordMetadataTimestamp.java        |  2 +-
 .../kafka/streams/processor/FailOnInvalidTimestamp.java  |  2 +-
 .../streams/processor/LogAndSkipOnInvalidTimestamp.java  |  2 +-
 ...tamp.java => UsePartitionTimeOnInvalidTimestamp.java} |  6 ++----
 .../processor/UsePreviousTimeOnInvalidTimestamp.java     |  6 ++++--
 .../streams/processor/WallclockTimestampExtractor.java   |  2 +-
 ....java => UsePartitionTimeOnInvalidTimestampTest.java} | 16 ++++++++--------
 .../processor/UsePreviousTimeOnInvalidTimestampTest.java |  2 +-
 10 files changed, 26 insertions(+), 20 deletions(-)
 copy streams/src/main/java/org/apache/kafka/streams/processor/{UsePreviousTimeOnInvalidTimestamp.java
=> UsePartitionTimeOnInvalidTimestamp.java} (96%)
 copy streams/src/test/java/org/apache/kafka/streams/processor/{UsePreviousTimeOnInvalidTimestampTest.java
=> UsePartitionTimeOnInvalidTimestampTest.java} (76%)


Mime
View raw message