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 2021/06/22 14:23:42 UTC
[kafka] branch trunk updated (b285662 -> c347508)
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 b285662 KAFKA-12904: Corrected the timeout for config validation REST API resource (#10834)
add c347508 KAFKA-10546: Deprecate old PAPI (#10869)
No new revisions were added by this update.
Summary of changes:
.../org/apache/kafka/streams/KafkaStreams.java | 2 +-
.../org/apache/kafka/streams/StreamsBuilder.java | 6 +-
.../java/org/apache/kafka/streams/Topology.java | 4 +-
.../kafka/streams/kstream/ForeachAction.java | 2 +-
.../org/apache/kafka/streams/kstream/KStream.java | 262 +++++++++++++++++++--
.../internals/CogroupedStreamAggregateBuilder.java | 4 +-
.../kstream/internals/KGroupedTableImpl.java | 13 +-
.../internals/KStreamAggProcessorSupplier.java | 5 +-
.../kstream/internals/KStreamAggregate.java | 12 +-
.../kstream/internals/KStreamFlatTransform.java | 13 +-
.../internals/KStreamFlatTransformValues.java | 13 +-
.../kstream/internals/KStreamGlobalKTableJoin.java | 7 +-
.../streams/kstream/internals/KStreamImpl.java | 43 +++-
.../kstream/internals/KStreamJoinWindow.java | 13 +-
.../kstream/internals/KStreamKStreamJoin.java | 13 +-
.../kstream/internals/KStreamKTableJoin.java | 7 +-
.../internals/KStreamKTableJoinProcessor.java | 7 +-
.../streams/kstream/internals/KStreamReduce.java | 12 +-
.../internals/KStreamSessionWindowAggregate.java | 12 +-
.../internals/KStreamSlidingWindowAggregate.java | 12 +-
.../kstream/internals/KStreamTransformValues.java | 13 +-
.../kstream/internals/KStreamWindowAggregate.java | 12 +-
.../streams/kstream/internals/KTableAggregate.java | 10 +-
.../streams/kstream/internals/KTableImpl.java | 7 +-
.../kstream/internals/KTableKTableInnerJoin.java | 12 +-
.../kstream/internals/KTableKTableJoinMerger.java | 10 +-
.../kstream/internals/KTableKTableLeftJoin.java | 12 +-
.../kstream/internals/KTableKTableOuterJoin.java | 12 +-
.../kstream/internals/KTableKTableRightJoin.java | 12 +-
.../streams/kstream/internals/KTableMapValues.java | 12 +-
.../kstream/internals/KTablePassThrough.java | 10 +-
.../kstream/internals/KTableProcessorSupplier.java | 5 +-
.../streams/kstream/internals/KTableReduce.java | 10 +-
.../kstream/internals/KTableRepartitionMap.java | 12 +-
.../streams/kstream/internals/KTableSource.java | 13 +-
.../kstream/internals/KTableTransformValues.java | 12 +-
.../ForeignJoinSubscriptionProcessorSupplier.java | 13 +-
...reignJoinSubscriptionSendProcessorSupplier.java | 13 +-
.../SubscriptionJoinForeignProcessorSupplier.java | 13 +-
.../SubscriptionResolverJoinProcessorSupplier.java | 13 +-
.../SubscriptionStoreReceiveProcessorSupplier.java | 13 +-
.../internals/graph/GraphGraceSearchUtil.java | 4 +-
.../internals/graph/ProcessorParameters.java | 3 +
.../internals/graph/StatefulProcessorNode.java | 1 +
.../suppress/KTableSuppressProcessorSupplier.java | 12 +-
.../kafka/streams/processor/AbstractProcessor.java | 3 +
.../streams/processor/ConnectedStoreProvider.java | 4 +-
.../apache/kafka/streams/processor/Processor.java | 2 +
.../kafka/streams/processor/ProcessorContext.java | 1 +
.../kafka/streams/processor/ProcessorSupplier.java | 2 +
.../kafka/streams/processor/RecordContext.java | 8 +-
.../internals/InternalTopologyBuilder.java | 1 +
.../processor/internals/ProcessorAdapter.java | 1 +
.../streams/processor/internals/ProcessorNode.java | 2 +-
.../org/apache/kafka/streams/state/Stores.java | 2 +-
.../apache/kafka/streams/StreamsBuilderTest.java | 1 +
.../integration/GlobalKTableIntegrationTest.java | 1 +
.../integration/GlobalThreadShutDownOrderTest.java | 5 +-
.../integration/RestoreIntegrationTest.java | 5 +-
.../integration/StoreUpgradeIntegrationTest.java | 14 +-
...amsUncaughtExceptionHandlerIntegrationTest.java | 3 +-
.../integration/TaskMetadataIntegrationTest.java | 5 +-
.../kstream/RepartitionTopicNamingTest.java | 5 +-
.../kstream/internals/AbstractStreamTest.java | 11 +-
.../kstream/internals/GlobalKTableJoinsTest.java | 2 +
.../kstream/internals/KGroupedStreamImplTest.java | 1 +
.../kstream/internals/KGroupedTableImplTest.java | 1 +
.../kstream/internals/KStreamBranchTest.java | 2 +-
.../kstream/internals/KStreamFilterTest.java | 2 +
.../kstream/internals/KStreamFlatMapTest.java | 1 +
.../internals/KStreamFlatMapValuesTest.java | 2 +
.../internals/KStreamFlatTransformTest.java | 4 +-
.../internals/KStreamFlatTransformValuesTest.java | 4 +-
.../internals/KStreamGlobalKTableJoinTest.java | 1 +
.../internals/KStreamGlobalKTableLeftJoinTest.java | 1 +
.../streams/kstream/internals/KStreamImplTest.java | 13 +-
.../kstream/internals/KStreamKStreamJoinTest.java | 1 +
.../internals/KStreamKStreamLeftJoinTest.java | 1 +
.../internals/KStreamKStreamOuterJoinTest.java | 1 +
.../kstream/internals/KStreamKTableJoinTest.java | 1 +
.../internals/KStreamKTableLeftJoinTest.java | 1 +
.../streams/kstream/internals/KStreamMapTest.java | 1 +
.../kstream/internals/KStreamMapValuesTest.java | 2 +
.../kstream/internals/KStreamSelectKeyTest.java | 1 +
...KStreamSessionWindowAggregateProcessorTest.java | 8 +-
.../KStreamSlidingWindowAggregateTest.java | 1 +
.../kstream/internals/KStreamTransformTest.java | 2 +
.../internals/KStreamTransformValuesTest.java | 6 +-
.../internals/KStreamWindowAggregateTest.java | 2 +
.../kstream/internals/KTableAggregateTest.java | 1 +
.../kstream/internals/KTableFilterTest.java | 1 +
.../streams/kstream/internals/KTableImplTest.java | 2 +
.../internals/KTableKTableInnerJoinTest.java | 4 +-
.../internals/KTableKTableLeftJoinTest.java | 4 +-
.../internals/KTableKTableOuterJoinTest.java | 4 +-
.../internals/KTableKTableRightJoinTest.java | 4 +-
.../kstream/internals/KTableMapKeysTest.java | 1 +
.../kstream/internals/KTableMapValuesTest.java | 2 +
.../kstream/internals/KTableReduceTest.java | 4 +-
.../kstream/internals/KTableSourceTest.java | 1 +
.../internals/KTableTransformValuesTest.java | 10 +-
.../internals/SessionWindowedKStreamImplTest.java | 1 +
.../internals/SlidingWindowedKStreamImplTest.java | 1 +
.../internals/TimeWindowedKStreamImplTest.java | 1 +
...scriptionResolverJoinProcessorSupplierTest.java | 14 +-
.../internals/graph/GraphGraceSearchUtilTest.java | 6 +-
.../internals/graph/TableProcessorNodeTest.java | 7 +-
.../KTableSuppressProcessorMetricsTest.java | 4 +-
.../suppress/KTableSuppressProcessorTest.java | 6 +-
.../internals/ProcessorContextImplTest.java | 3 +-
.../processor/internals/ProcessorNodeTest.java | 7 +-
.../processor/internals/ProcessorTopologyTest.java | 6 +-
.../processor/internals/PunctuationQueueTest.java | 4 +-
.../internals/RepartitionOptimizingTest.java | 5 +-
.../processor/internals/StreamThreadTest.java | 2 +
.../apache/kafka/streams/tests/EosTestClient.java | 1 +
.../kafka/streams/tests/SmokeTestClient.java | 1 +
.../apache/kafka/streams/tests/SmokeTestUtil.java | 14 +-
.../kafka/streams/tests/StreamsUpgradeTest.java | 1 +
.../java/org/apache/kafka/test/MockProcessor.java | 4 +-
.../apache/kafka/test/MockProcessorSupplier.java | 7 +-
.../kafka/streams/scala/kstream/KStream.scala | 53 ++++-
.../apache/kafka/streams/scala/TopologyTest.scala | 27 ++-
.../apache/kafka/streams/TopologyTestDriver.java | 2 +-
.../streams/processor/MockProcessorContext.java | 1 +
.../kafka/streams/MockProcessorContextTest.java | 16 +-
126 files changed, 696 insertions(+), 395 deletions(-)