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/11/04 01:31:24 UTC
[kafka] branch trunk updated (b4f00d7 -> b3e77df)

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 b4f00d7  KAFKA-10679: Migrate upgrade changes from site to kafka/docs (#9551)
     add b3e77df  KAFKA-10036: Improve handling and documentation of Suppliers (#9000)

No new revisions were added by this update.

Summary of changes:
 docs/streams/developer-guide/processor-api.html    |  5 ++
 .../org/apache/kafka/streams/StreamsBuilder.java   |  7 ++
 .../java/org/apache/kafka/streams/Topology.java    | 15 ++++
 .../apache/kafka/streams/internals/ApiUtils.java   | 25 +++++++
 .../org/apache/kafka/streams/kstream/KStream.java  | 80 +++++++++++++++------
 .../kafka/streams/kstream/TransformerSupplier.java | 16 ++++-
 .../streams/kstream/ValueTransformerSupplier.java  | 14 +++-
 .../kstream/ValueTransformerWithKeySupplier.java   | 21 +++++-
 .../streams/kstream/internals/AbstractStream.java  |  2 +
 .../streams/kstream/internals/KStreamImpl.java     |  5 ++
 .../kafka/streams/processor/ProcessorSupplier.java | 18 +++--
 .../streams/processor/api/ProcessorSupplier.java   | 16 ++++-
 .../internals/InternalTopologyBuilder.java         |  3 +
 .../processor/internals/ProcessorContextImpl.java  |  8 +++
 .../apache/kafka/streams/StreamsBuilderTest.java   | 14 ++--
 .../kstream/internals/AbstractStreamTest.java      |  8 ++-
 .../streams/kstream/internals/KStreamImplTest.java | 81 ++++++++++++++++++++++
 .../internals/KStreamTransformValuesTest.java      |  4 +-
 .../internals/KTableTransformValuesTest.java       |  8 +--
 .../internals/InternalTopologyBuilderTest.java     | 31 +++++++++
 .../processor/internals/ProcessorTopologyTest.java | 22 +++---
 .../processor/internals/StreamThreadTest.java      | 14 ++--
 .../kafka/test/MockApiProcessorSupplier.java       |  7 +-
 .../apache/kafka/test/MockProcessorSupplier.java   |  7 +-
 ...va => NoOpValueTransformerWithKeySupplier.java} | 33 +++++----
 .../apache/kafka/test/NoopValueTransformer.java    | 15 ++--
 .../kafka/test/NoopValueTransformerWithKey.java    | 15 ++--
 .../org/apache/kafka/test/StreamsTestUtils.java    | 11 +++
 .../kafka/streams/TopologyTestDriverTest.java      | 34 +++++++--
 29 files changed, 434 insertions(+), 105 deletions(-)
 rename streams/src/test/java/org/apache/kafka/test/{SingletonNoOpValueTransformer.java => NoOpValueTransformerWithKeySupplier.java} (66%)
 copy clients/src/main/java/org/apache/kafka/common/security/authenticator/DefaultLogin.java => streams/src/test/java/org/apache/kafka/test/NoopValueTransformer.java (70%)
 copy clients/src/main/java/org/apache/kafka/common/security/authenticator/DefaultLogin.java => streams/src/test/java/org/apache/kafka/test/NoopValueTransformerWithKey.java (67%)