This is an automated email from the ASF dual-hosted git repository.
boyang pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 72d1082 KAFKA-12620 Allocate producer ids on the controller (#10504)
add ae8b784 KAFKA-12499: add transaction timeout verification (#10482)
No new revisions were added by this update.
Summary of changes:
.../examples/pageview/PageViewTypedDemo.java | 2 +-
.../org/apache/kafka/streams/StreamsConfig.java | 24 ++++++++++++++++++-
.../apache/kafka/streams/StreamsConfigTest.java | 27 ++++++++++++++++++++++
.../integration/AbstractResetIntegrationTest.java | 2 +-
.../integration/EmitOnChangeIntegrationTest.java | 2 +-
.../streams/integration/EosIntegrationTest.java | 11 ++++++---
.../integration/EosV2UpgradeIntegrationTest.java | 5 ++--
.../FineGrainedAutoResetIntegrationTest.java | 4 ++--
.../GlobalKTableEOSIntegrationTest.java | 2 +-
.../integration/GlobalKTableIntegrationTest.java | 2 +-
.../integration/GlobalThreadShutDownOrderTest.java | 2 +-
...ighAvailabilityTaskAssignorIntegrationTest.java | 2 +-
.../integration/InternalTopicIntegrationTest.java | 2 +-
.../KStreamAggregationIntegrationTest.java | 2 +-
.../KStreamRepartitionIntegrationTest.java | 2 +-
...bleForeignKeyInnerJoinMultiIntegrationTest.java | 2 +-
.../KTableSourceTopicRestartIntegrationTest.java | 2 +-
.../integration/LagFetchIntegrationTest.java | 2 +-
.../OptimizedKTableIntegrationTest.java | 2 +-
.../integration/QueryableStateIntegrationTest.java | 2 +-
.../integration/RegexSourceIntegrationTest.java | 2 +-
.../ResetPartitionTimeIntegrationTest.java | 2 +-
.../integration/RestoreIntegrationTest.java | 2 +-
.../integration/StandbyTaskEOSIntegrationTest.java | 2 +-
.../integration/StoreQueryIntegrationTest.java | 2 +-
.../integration/StoreUpgradeIntegrationTest.java | 2 +-
...bleJoinTopologyOptimizationIntegrationTest.java | 2 +-
.../SuppressionDurabilityIntegrationTest.java | 7 +++---
.../integration/SuppressionIntegrationTest.java | 2 +-
.../internals/RepartitionOptimizingTest.java | 2 +-
.../RepartitionWithMergeOptimizingTest.java | 2 +-
.../processor/internals/StreamThreadTest.java | 2 +-
.../CachingPersistentWindowStoreTest.java | 2 +-
.../streams/tests/BrokerCompatibilityTest.java | 2 +-
.../apache/kafka/streams/tests/EosTestClient.java | 2 +-
.../kafka/streams/tests/RelationalSmokeTest.java | 24 ++++++++++---------
.../streams/tests/StaticMemberTestClient.java | 2 +-
.../tests/StreamsBrokerDownResilienceTest.java | 2 +-
.../streams/tests/StreamsStandByReplicaTest.java | 2 +-
.../kafka/streams/tests/StreamsUpgradeTest.java | 2 +-
.../StreamsUpgradeToCooperativeRebalanceTest.java | 2 +-
.../kafka/streams/tests/StreamsUpgradeTest.java | 2 +-
.../StreamsUpgradeToCooperativeRebalanceTest.java | 2 +-
.../kafka/streams/tests/StreamsUpgradeTest.java | 2 +-
.../StreamsUpgradeToCooperativeRebalanceTest.java | 2 +-
.../kafka/streams/tests/StreamsUpgradeTest.java | 2 +-
.../StreamsUpgradeToCooperativeRebalanceTest.java | 2 +-
.../kafka/streams/tests/StreamsUpgradeTest.java | 2 +-
.../StreamsUpgradeToCooperativeRebalanceTest.java | 2 +-
.../kafka/streams/tests/StreamsUpgradeTest.java | 2 +-
.../StreamsUpgradeToCooperativeRebalanceTest.java | 2 +-
.../kafka/streams/tests/StreamsUpgradeTest.java | 2 +-
.../StreamsUpgradeToCooperativeRebalanceTest.java | 2 +-
.../kafka/streams/tests/StreamsUpgradeTest.java | 2 +-
.../StreamsUpgradeToCooperativeRebalanceTest.java | 2 +-
.../kafka/streams/tests/StreamsUpgradeTest.java | 2 +-
.../StreamsUpgradeToCooperativeRebalanceTest.java | 2 +-
.../kafka/streams/tests/StreamsUpgradeTest.java | 2 +-
.../StreamsUpgradeToCooperativeRebalanceTest.java | 2 +-
.../kafka/streams/tests/StreamsUpgradeTest.java | 2 +-
.../StreamsUpgradeToCooperativeRebalanceTest.java | 2 +-
.../kafka/streams/tests/StreamsUpgradeTest.java | 2 +-
.../kafka/streams/tests/StreamsUpgradeTest.java | 2 +-
.../kafka/streams/tests/StreamsUpgradeTest.java | 2 +-
.../kafka/streams/tests/StreamsUpgradeTest.java | 2 +-
65 files changed, 138 insertions(+), 80 deletions(-)
