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(-)