You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by gu...@apache.org on 2020/04/22 21:30:02 UTC
[kafka] branch trunk updated (a91b067 -> fbd8cf0)
This is an automated email from the ASF dual-hosted git repository.
guozhang pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from a91b067 KAFKA-9863: replace the deprecated --zookeeper options in the documentation (#8482)
add fbd8cf0 KAFKA-9388: Refactor integration tests to always use different application ids (#8530)
No new revisions were added by this update.
Summary of changes:
.../internals/InternalTopologyBuilder.java | 1 -
.../EOSUncleanShutdownIntegrationTest.java | 3 +-
.../streams/integration/ForeignKeyJoinSuite.java | 3 +-
.../GlobalKTableEOSIntegrationTest.java | 18 ++-
.../integration/GlobalKTableIntegrationTest.java | 13 +-
.../integration/GlobalThreadShutDownOrderTest.java | 7 +-
.../KStreamAggregationDedupIntegrationTest.java | 15 ++-
.../KStreamAggregationIntegrationTest.java | 19 +--
.../KStreamRepartitionIntegrationTest.java | 22 ++--
.../KTableKTableForeignKeyJoinIntegrationTest.java | 21 +++-
...reignKeyJoinMaterializationIntegrationTest.java | 16 ++-
.../KTableKTableForeignKeyJoinPseudoTopicTest.java | 138 ---------------------
.../KTableSourceTopicRestartIntegrationTest.java | 9 +-
.../integration/MetricsIntegrationTest.java | 14 ++-
.../OptimizedKTableIntegrationTest.java | 8 +-
.../integration/QueryableStateIntegrationTest.java | 25 ++--
.../ResetPartitionTimeIntegrationTest.java | 7 +-
.../integration/RestoreIntegrationTest.java | 2 +
.../integration/RocksDBMetricsIntegrationTest.java | 10 +-
.../StandbyTaskCreationIntegrationTest.java | 7 +-
.../integration/StandbyTaskEOSIntegrationTest.java | 10 +-
.../integration/StoreQueryIntegrationTest.java | 6 +-
.../integration/StoreUpgradeIntegrationTest.java | 10 +-
.../KTableKTableForeignKeyJoinScenarioTest.java} | 86 ++++++++++++-
24 files changed, 261 insertions(+), 209 deletions(-)
delete mode 100644 streams/src/test/java/org/apache/kafka/streams/integration/KTableKTableForeignKeyJoinPseudoTopicTest.java
rename streams/src/test/java/org/apache/kafka/streams/{integration/KTableKTableForeignKeyJoinDefaultSerdeTest.java => kstream/internals/KTableKTableForeignKeyJoinScenarioTest.java} (63%)