You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by vv...@apache.org on 2020/09/01 21:49:54 UTC
[kafka] branch trunk updated (85b6545 -> d0111d3)
This is an automated email from the ASF dual-hosted git repository.
vvcephei pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 85b6545 KAFKA-5636: SlidingWindows (KIP-450) (#9039)
add d0111d3 KAFKA-10020: Create a new version of a scala Serdes without name clash (KIP-616) (#8955)
No new revisions were added by this update.
Summary of changes:
docs/streams/developer-guide/dsl-api.html | 12 +++---
.../org/apache/kafka/streams/scala/Serdes.scala | 4 ++
.../streams/scala/kstream/KGroupedStream.scala | 3 +-
.../scala/kstream/SessionWindowedKStream.scala | 3 +-
.../scala/kstream/TimeWindowedKStream.scala | 3 +-
.../streams/scala/{ => serialization}/Serdes.scala | 50 ++++++++++++++--------
...bleJoinScalaIntegrationTestImplicitSerdes.scala | 19 ++++----
.../apache/kafka/streams/scala/TopologyTest.scala | 43 ++++++++++---------
.../apache/kafka/streams/scala/WordCountTest.scala | 11 ++---
.../kafka/streams/scala/kstream/ConsumedTest.scala | 20 ++++-----
.../kafka/streams/scala/kstream/GroupedTest.scala | 12 +++---
.../kafka/streams/scala/kstream/JoinedTest.scala | 16 +++----
.../kafka/streams/scala/kstream/KStreamTest.scala | 2 +-
.../kafka/streams/scala/kstream/KTableTest.scala | 2 +-
.../streams/scala/kstream/MaterializedTest.scala | 23 +++++-----
.../kafka/streams/scala/kstream/ProducedTest.scala | 12 +++---
.../streams/scala/kstream/RepartitionedTest.scala | 24 +++++------
.../streams/scala/kstream/StreamJoinedTest.scala | 22 +++++-----
18 files changed, 154 insertions(+), 127 deletions(-)
copy streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/{ => serialization}/Serdes.scala (63%)