You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ab...@apache.org on 2022/10/21 00:04:12 UTC
[kafka] branch trunk updated (b525ddc9f1f -> 9a793897ec4)
This is an automated email from the ASF dual-hosted git repository.
ableegoldman pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from b525ddc9f1f MINOR: Fix PartitionRegistration.hashCode (#12774)
add 9a793897ec4 KAFKA-13152: KIP-770, cache size config deprecation (#12758)
No new revisions were added by this update.
Summary of changes:
checkstyle/suppressions.xml | 2 +-
.../examples/pageview/PageViewTypedDemo.java | 2 +-
.../examples/pageview/PageViewUntypedDemo.java | 2 +-
.../examples/temperature/TemperatureDemo.java | 2 +-
.../streams/examples/wordcount/WordCountDemo.java | 2 +-
.../examples/wordcount/WordCountProcessorDemo.java | 2 +-
.../wordcount/WordCountTransformerDemo.java | 2 +-
.../org/apache/kafka/streams/KafkaStreams.java | 9 ++--
.../org/apache/kafka/streams/StreamsConfig.java | 12 +++++
.../org/apache/kafka/streams/TopologyConfig.java | 51 +++++++++++++++++++---
.../streams/internals/StreamsConfigUtils.java | 31 +++++++++++++
.../kafka/streams/kstream/CogroupedKStream.java | 8 ++--
.../kafka/streams/kstream/KGroupedStream.java | 20 ++++-----
.../kafka/streams/kstream/KGroupedTable.java | 22 +++++-----
.../kstream/SessionWindowedCogroupedKStream.java | 8 ++--
.../streams/kstream/SessionWindowedKStream.java | 24 +++++-----
.../kstream/TimeWindowedCogroupedKStream.java | 8 ++--
.../kafka/streams/kstream/TimeWindowedKStream.java | 24 +++++-----
.../org/apache/kafka/streams/KafkaStreamsTest.java | 1 +
.../apache/kafka/streams/StreamsConfigTest.java | 31 +++++++++++++
.../integration/AbstractJoinIntegrationTest.java | 2 +-
.../integration/AbstractResetIntegrationTest.java | 2 +-
.../integration/AdjustStreamThreadCountTest.java | 4 +-
.../integration/EmitOnChangeIntegrationTest.java | 2 +-
.../streams/integration/EosIntegrationTest.java | 6 +--
.../integration/EosV2UpgradeIntegrationTest.java | 2 +-
.../FineGrainedAutoResetIntegrationTest.java | 4 +-
.../GlobalKTableEOSIntegrationTest.java | 2 +-
.../integration/GlobalKTableIntegrationTest.java | 2 +-
.../integration/GlobalThreadShutDownOrderTest.java | 2 +-
.../integration/InternalTopicIntegrationTest.java | 2 +-
.../KStreamAggregationDedupIntegrationTest.java | 2 +-
.../KStreamAggregationIntegrationTest.java | 2 +-
.../KStreamRepartitionIntegrationTest.java | 2 +-
...yInnerJoinCustomPartitionerIntegrationTest.java | 2 +-
...bleForeignKeyInnerJoinMultiIntegrationTest.java | 2 +-
.../KTableSourceTopicRestartIntegrationTest.java | 2 +-
.../KafkaStreamsCloseOptionsIntegrationTest.java | 2 +-
.../integration/MetricsIntegrationTest.java | 2 +-
.../integration/NamedTopologyIntegrationTest.java | 2 +-
.../OptimizedKTableIntegrationTest.java | 2 +-
.../integration/PauseResumeIntegrationTest.java | 2 +-
.../integration/QueryableStateIntegrationTest.java | 2 +-
.../integration/RegexSourceIntegrationTest.java | 2 +-
.../integration/RestoreIntegrationTest.java | 2 +-
.../integration/RocksDBMetricsIntegrationTest.java | 2 +-
.../SelfJoinUpgradeIntegrationTest.java | 2 +-
.../SlidingWindowedKStreamIntegrationTest.java | 2 +-
.../integration/StandbyTaskEOSIntegrationTest.java | 2 +-
.../integration/StoreUpgradeIntegrationTest.java | 2 +-
...bleJoinTopologyOptimizationIntegrationTest.java | 2 +-
.../TimeWindowedKStreamIntegrationTest.java | 2 +-
.../kstream/internals/KTableFilterTest.java | 2 +-
.../internals/SessionWindowedKStreamImplTest.java | 2 +-
.../internals/InternalTopologyBuilderTest.java | 16 ++++++-
.../internals/RepartitionOptimizingTest.java | 2 +-
.../RepartitionWithMergeOptimizingTest.java | 2 +-
.../internals/metrics/TaskMetricsTest.java | 1 -
.../streams/tests/BrokerCompatibilityTest.java | 2 +-
.../apache/kafka/streams/tests/EosTestClient.java | 2 +-
.../streams/tests/StreamsNamedRepartitionTest.java | 2 +-
.../kafka/streams/tests/StreamsOptimizedTest.java | 2 +-
.../streams/tests/StreamsStandByReplicaTest.java | 2 +-
.../apache/kafka/streams/TopologyTestDriver.java | 4 +-
64 files changed, 251 insertions(+), 123 deletions(-)