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
