You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by mj...@apache.org on 2020/05/22 15:42:20 UTC
[kafka] branch trunk updated (d9e9a18 -> 27824ba)

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 d9e9a18  KAFKA-9980: Fix bug where alterClientQuotas could not set default client quotas (#8658)
     add 27824ba  KAFKA-10003: Mark KStream.through() as deprecated and update Scala API (#8679)

No new revisions were added by this update.

Summary of changes:
 .../main/scala/kafka/tools/StreamsResetter.java    |   4 +-
 docs/streams/developer-guide/datatypes.html        |   2 +-
 docs/streams/developer-guide/dsl-api.html          |  83 ++----------
 docs/streams/developer-guide/manage-topics.html    |   5 +-
 docs/streams/upgrade-guide.html                    |   6 +-
 .../org/apache/kafka/streams/KafkaStreams.java     |   9 +-
 .../kafka/streams/kstream/CogroupedKStream.java    |   6 +-
 .../org/apache/kafka/streams/kstream/KStream.java  | 142 ++++++++++-----------
 .../streams/kstream/internals/KStreamImpl.java     |   2 +
 .../kstream/internals/RepartitionedInternal.java   |  14 +-
 .../apache/kafka/streams/StreamsBuilderTest.java   |  24 +++-
 .../integration/AbstractResetIntegrationTest.java  |  55 +++++---
 .../streams/integration/EosIntegrationTest.java    |   3 +-
 .../streams/integration/ResetIntegrationTest.java  |   9 +-
 .../integration/ResetIntegrationWithSslTest.java   |  15 ++-
 .../streams/kstream/internals/KStreamImplTest.java |  91 ++++++++++---
 .../kstream/internals/graph/StreamsGraphTest.java  |  11 +-
 .../apache/kafka/streams/tests/EosTestClient.java  |   3 +-
 .../kafka/streams/scala/ImplicitConversions.scala  |   3 +
 .../kafka/streams/scala/kstream/KStream.scala      |  45 ++++++-
 .../streams/scala/kstream/Repartitioned.scala      |  86 +++++++++++++
 .../kafka/streams/scala/kstream/package.scala      |   1 +
 .../kafka/streams/scala/kstream/KStreamTest.scala  |  30 +++++
 .../kafka/streams/scala/kstream/ProducedTest.scala |  10 +-
 .../streams/scala/kstream/RepartitionedTest.scala  |  89 +++++++++++++
 25 files changed, 518 insertions(+), 230 deletions(-)
 create mode 100644 streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/Repartitioned.scala
 create mode 100644 streams/streams-scala/src/test/scala/org/apache/kafka/streams/scala/kstream/RepartitionedTest.scala