[kafka] branch trunk updated (789fc26 -> 4fd71a7)

[mj...@apache.org]

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 789fc26  KAFKA-12964: Collect and rename snapshot files prior to async deletion. (#10896)
     add 4fd71a7  KAFKA-9559: Change default serde to be `null` (#10813)

No new revisions were added by this update.

Summary of changes:
 .../org/apache/kafka/streams/StreamsConfig.java    | 11 +++-
 .../kstream/internals/ChangedDeserializer.java     |  7 ++-
 .../kstream/internals/ChangedSerializer.java       |  7 ++-
 .../internals/WrappingNullableDeserializer.java    |  3 +-
 .../kstream/internals/WrappingNullableSerde.java   |  9 ++-
 .../internals/WrappingNullableSerializer.java      |  3 +-
 .../kstream/internals/WrappingNullableUtils.java   | 72 +++++++++++++---------
 .../SubscriptionResponseWrapperSerde.java          | 12 ++--
 .../foreignkeyjoin/SubscriptionWrapperSerde.java   | 12 ++--
 .../suppress/KTableSuppressProcessorSupplier.java  |  5 +-
 .../kafka/streams/processor/ProcessorContext.java  |  2 +-
 .../internals/AbstractProcessorContext.java        | 10 ++-
 .../processor/internals/ProcessorContextUtils.java | 24 --------
 .../streams/processor/internals/SerdeGetter.java   | 54 ++++++++++++++++
 .../streams/processor/internals/SinkNode.java      |  6 +-
 .../streams/processor/internals/SourceNode.java    |  6 +-
 .../InMemoryTimeOrderedKeyValueBuffer.java         |  8 ++-
 .../internals/KeyAndJoinSideDeserializer.java      |  9 +--
 .../state/internals/KeyAndJoinSideSerializer.java  |  9 +--
 .../internals/LeftOrRightValueDeserializer.java    | 12 ++--
 .../internals/LeftOrRightValueSerializer.java      | 12 ++--
 .../state/internals/MeteredKeyValueStore.java      | 13 ++--
 .../state/internals/MeteredSessionStore.java       |  9 +--
 .../internals/MeteredTimestampedKeyValueStore.java | 11 ++--
 .../internals/MeteredTimestampedWindowStore.java   |  7 ++-
 .../state/internals/MeteredWindowStore.java        | 13 ++--
 .../state/internals/TimeOrderedKeyValueBuffer.java |  4 +-
 .../internals/ValueAndTimestampDeserializer.java   |  5 +-
 .../internals/ValueAndTimestampSerializer.java     |  5 +-
 .../apache/kafka/streams/StreamsConfigTest.java    |  5 +-
 .../org/apache/kafka/streams/TopologyTest.java     |  6 +-
 ...ighAvailabilityTaskAssignorIntegrationTest.java |  5 +-
 ...reignKeyJoinMaterializationIntegrationTest.java |  3 +-
 .../internals/AbstractProcessorContextTest.java    | 17 +++++
 .../internals/GlobalStreamThreadTest.java          |  3 +
 .../processor/internals/ProcessorNodeTest.java     | 29 ++++++++-
 .../processor/internals/StreamThreadTest.java      |  4 +-
 .../kafka/streams/tests/StreamsUpgradeTest.java    |  3 +
 .../org/apache/kafka/test/StreamsTestUtils.java    | 16 ++++-
 39 files changed, 292 insertions(+), 159 deletions(-)
 create mode 100644 streams/src/main/java/org/apache/kafka/streams/processor/internals/SerdeGetter.java