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 bc3e6369b92 KAFKA-17931 Revise the `specifying-test-retries` section
in README (#17679)
add 069667b6b26 KAFKA-16339: [1/4 KStream#transform] Remove Deprecated
"transformer" methods and classes (#17198)
No new revisions were added by this update.
Summary of changes:
.../KStreamTransformIntegrationTest.java | 556 ---------------------
.../integration/StandbyTaskEOSIntegrationTest.java | 31 +-
.../org/apache/kafka/streams/kstream/KStream.java | 372 ++------------
.../apache/kafka/streams/kstream/Transformer.java | 4 +-
.../kafka/streams/kstream/TransformerSupplier.java | 1 -
.../streams/kstream/ValueTransformerSupplier.java | 1 -
.../kstream/ValueTransformerWithKeySupplier.java | 1 -
.../streams/kstream/internals/KStreamImpl.java | 18 -
.../internals/TransformerSupplierAdapter.java | 66 ---
.../streams/processor/ConnectedStoreProvider.java | 2 -
.../apache/kafka/streams/StreamsBuilderTest.java | 9 -
.../streams/kstream/internals/KStreamImplTest.java | 107 ----
.../kstream/internals/KStreamTransformTest.java | 168 -------
.../internals/TransformerSupplierAdapterTest.java | 149 ------
.../processor/internals/StreamThreadTest.java | 33 +-
.../kafka/streams/scala/kstream/KStream.scala | 46 --
.../apache/kafka/streams/scala/TopologyTest.scala | 32 +-
.../kafka/streams/scala/kstream/KStreamTest.scala | 69 ++-
18 files changed, 133 insertions(+), 1532 deletions(-)
delete mode 100644
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/KStreamTransformIntegrationTest.java
delete mode 100644
streams/src/main/java/org/apache/kafka/streams/kstream/internals/TransformerSupplierAdapter.java
delete mode 100644
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamTransformTest.java
delete mode 100644
streams/src/test/java/org/apache/kafka/streams/kstream/internals/TransformerSupplierAdapterTest.java
