[kafka] branch trunk updated (cd1e46c -> 29e08fd)

[vv...@apache.org]

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 cd1e46c  MINOR: Pass one action per unique resource name in KafkaApis.filterAuthorized (#8432)
     add 29e08fd  KAFKA-8410: Part 1: processor context bounds (#8414)

No new revisions were added by this update.

Summary of changes:
 .../examples/docs/DeveloperGuideTesting.java       |  4 +-
 .../apache/kafka/streams/kstream/Transformer.java  |  2 +-
 .../kafka/streams/kstream/ValueTransformer.java    |  2 +-
 .../streams/kstream/ValueTransformerWithKey.java   |  2 +-
 .../streams/kstream/internals/AbstractStream.java  |  2 +-
 .../kstream/internals/KStreamFlatTransform.java    |  2 +-
 .../internals/KStreamFlatTransformValues.java      |  4 +-
 .../internals/KStreamKTableJoinProcessor.java      |  5 +-
 .../kstream/internals/KStreamTransformValues.java  |  4 +-
 .../kstream/internals/KTableKTableInnerJoin.java   |  7 +--
 .../kstream/internals/KTableKTableLeftJoin.java    |  7 +--
 .../kstream/internals/KTableKTableOuterJoin.java   |  7 +--
 .../kstream/internals/KTableKTableRightJoin.java   |  7 +--
 .../streams/kstream/internals/KTableMapValues.java |  2 +-
 .../kstream/internals/KTableRepartitionMap.java    |  4 +-
 .../kstream/internals/KTableTransformValues.java   |  2 +-
 .../kstream/internals/KTableValueGetter.java       |  2 +-
 .../internals/SessionCacheFlushListener.java       | 10 ++--
 .../kstream/internals/SessionTupleForwarder.java   |  4 +-
 .../internals/TimestampedCacheFlushListener.java   | 10 ++--
 .../internals/TimestampedTupleForwarder.java       |  4 +-
 .../internals/TransformerSupplierAdapter.java      |  2 +-
 .../ForeignJoinSubscriptionProcessorSupplier.java  |  5 +-
 .../SubscriptionJoinForeignProcessorSupplier.java  |  5 +-
 .../SubscriptionStoreReceiveProcessorSupplier.java |  5 +-
 .../suppress/KTableSuppressProcessorSupplier.java  |  6 +--
 .../kafka/streams/processor/AbstractProcessor.java |  6 +--
 .../apache/kafka/streams/processor/Processor.java  |  2 +-
 .../kafka/streams/processor/ProcessorContext.java  | 16 +++---
 .../internals/AbstractProcessorContext.java        |  2 +-
 .../ForwardingDisabledProcessorContext.java        | 16 +++---
 .../internals/GlobalProcessorContextImpl.java      | 10 ++--
 .../processor/internals/GlobalStateUpdateTask.java |  4 +-
 .../processor/internals/GlobalStreamThread.java    | 12 +++--
 .../internals/InternalProcessorContext.java        |  2 +-
 .../processor/internals/ProcessorContextImpl.java  | 23 +++-----
 .../streams/processor/internals/ProcessorNode.java |  2 +-
 .../streams/processor/internals/SourceNode.java    |  2 +-
 .../processor/internals/StandbyContextImpl.java    | 16 +++---
 .../streams/processor/internals/StreamTask.java    |  8 +--
 .../kafka/streams/TopologyTestDriverWrapper.java   |  8 +--
 .../internals/KStreamFlatTransformTest.java        |  2 +-
 .../internals/KStreamFlatTransformValuesTest.java  |  2 +-
 .../kstream/internals/KStreamPrintTest.java        |  2 +-
 ...KStreamSessionWindowAggregateProcessorTest.java |  3 +-
 .../kstream/internals/KStreamTransformTest.java    |  4 +-
 .../kstream/internals/KTableFilterTest.java        |  5 +-
 .../kstream/internals/KTableMapValuesTest.java     |  5 +-
 .../kstream/internals/KTableSourceTest.java        |  3 +-
 .../internals/KTableTransformValuesTest.java       |  6 +--
 .../internals/SessionCacheFlushListenerTest.java   |  2 +-
 .../internals/SessionTupleForwarderTest.java       |  4 +-
 .../TimestampedCacheFlushListenerTest.java         |  4 +-
 .../internals/TimestampedTupleForwarderTest.java   |  4 +-
 .../internals/AbstractProcessorContextTest.java    |  2 +-
 .../ForwardingDisabledProcessorContextTest.java    | 61 ----------------------
 .../internals/GlobalProcessorContextImplTest.java  |  4 +-
 .../internals/ProcessorContextImplTest.java        |  8 +--
 .../apache/kafka/streams/tests/SmokeTestUtil.java  |  2 +-
 .../kafka/test/InternalMockProcessorContext.java   |  2 +-
 .../kafka/test/MockInternalProcessorContext.java   | 10 ++--
 .../java/org/apache/kafka/test/MockProcessor.java  |  2 +-
 .../org/apache/kafka/test/MockProcessorNode.java   |  2 +-
 .../apache/kafka/test/NoOpProcessorContext.java    |  2 +-
 .../streams/scala/FunctionsCompatConversions.scala |  6 +--
 .../apache/kafka/streams/scala/TopologyTest.scala  |  4 +-
 .../kafka/streams/scala/kstream/KStreamTest.scala  |  8 +--
 .../apache/kafka/streams/TopologyTestDriver.java   |  4 +-
 .../streams/processor/MockProcessorContext.java    |  2 +-
 .../kafka/streams/TopologyTestDriverTest.java      |  8 +--
 70 files changed, 184 insertions(+), 234 deletions(-)
 delete mode 100644 streams/src/test/java/org/apache/kafka/streams/processor/internals/ForwardingDisabledProcessorContextTest.java