kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From vvcep...@apache.org
Subject [kafka] branch trunk updated (b285662 -> c347508)
Date Tue, 22 Jun 2021 14:23:42 GMT
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(-)

Mime
View raw message