This is an automated email from the ASF dual-hosted git repository.
ableegoldman pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from 8a90ca05281 KAFKA-18076 Remove `isZkMigrationTest` and related code
(#17922)
add 87b902d35da KAFKA-18026: KIP-1112, ProcessorWrapper API with PAPI and
partial DSL implementation (#17892)
No new revisions were added by this update.
Summary of changes:
.../org/apache/kafka/streams/StreamsConfig.java | 11 +++
.../java/org/apache/kafka/streams/Topology.java | 6 +-
.../org/apache/kafka/streams/TopologyConfig.java | 23 +++++-
.../AbstractConfigurableStoreFactory.java | 9 ++-
.../internals/graph/ProcessorParameters.java | 27 +++++--
.../streams/processor/api/ProcessorWrapper.java | 85 ++++++++++++++++++++
.../api/WrappedFixedKeyProcessorSupplier.java | 17 ++--
.../processor/api/WrappedProcessorSupplier.java | 17 ++--
.../internals/InternalTopologyBuilder.java | 47 ++++++++++-
.../processor/internals/NoOpProcessorWrapper.java | 81 +++++++++++++++++++
.../apache/kafka/streams/StreamsBuilderTest.java | 77 ++++++++++++++++++
.../apache/kafka/streams/StreamsConfigTest.java | 21 +++++
.../org/apache/kafka/streams/TopologyTest.java | 41 ++++++++++
.../internals/InternalTopologyBuilderTest.java | 92 ++++++++++++++++++++++
.../internals/KeyValueStoreMaterializerTest.java | 12 ++-
.../org/apache/kafka/streams/utils/TestUtils.java | 57 ++++++++++++++
16 files changed, 589 insertions(+), 34 deletions(-)
create mode 100644
streams/src/main/java/org/apache/kafka/streams/processor/api/ProcessorWrapper.java
copy
clients/src/main/java/org/apache/kafka/common/metrics/MetricValueProvider.java
=>
streams/src/main/java/org/apache/kafka/streams/processor/api/WrappedFixedKeyProcessorSupplier.java
(61%)
copy
clients/src/main/java/org/apache/kafka/common/metrics/MetricValueProvider.java
=>
streams/src/main/java/org/apache/kafka/streams/processor/api/WrappedProcessorSupplier.java
(63%)
create mode 100644
streams/src/main/java/org/apache/kafka/streams/processor/internals/NoOpProcessorWrapper.java
