This is an automated email from the ASF dual-hosted git repository.
chia7712 pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 7071ded KAFKA-12524: Remove deprecated segments() (#10379)
add 9af8195 KAFKA-12173 Migrate streams:streams-scala module to JUnit 5
(#9858)
No new revisions were added by this update.
Summary of changes:
build.gradle | 7 +-
gradle/dependencies.gradle | 1 -
.../integration/AdjustStreamThreadCountTest.java | 15 +-
.../EOSUncleanShutdownIntegrationTest.java | 29 ++--
.../integration/EmitOnChangeIntegrationTest.java | 17 ++-
.../integration/EosBetaUpgradeIntegrationTest.java | 16 +-
.../streams/integration/EosIntegrationTest.java | 16 +-
.../FineGrainedAutoResetIntegrationTest.java | 67 ++++----
.../GlobalKTableEOSIntegrationTest.java | 16 +-
.../integration/GlobalKTableIntegrationTest.java | 16 +-
.../integration/GlobalThreadShutDownOrderTest.java | 16 +-
...ighAvailabilityTaskAssignorIntegrationTest.java | 16 +-
.../integration/InternalTopicIntegrationTest.java | 20 ++-
.../integration/JoinStoreIntegrationTest.java | 30 ++--
.../JoinWithIncompleteMetadataIntegrationTest.java | 29 ++--
.../KStreamAggregationDedupIntegrationTest.java | 15 +-
.../KStreamAggregationIntegrationTest.java | 15 +-
.../KStreamRepartitionIntegrationTest.java | 15 +-
...bleForeignKeyInnerJoinMultiIntegrationTest.java | 14 +-
.../KTableKTableForeignKeyJoinDistributedTest.java | 21 ++-
.../KTableSourceTopicRestartIntegrationTest.java | 31 ++--
.../integration/LagFetchIntegrationTest.java | 16 +-
.../integration/MetricsIntegrationTest.java | 16 +-
.../OptimizedKTableIntegrationTest.java | 25 ++-
.../PurgeRepartitionTopicIntegrationTest.java | 21 ++-
.../integration/QueryableStateIntegrationTest.java | 15 +-
.../integration/RegexSourceIntegrationTest.java | 41 ++---
.../streams/integration/ResetIntegrationTest.java | 15 +-
.../integration/ResetIntegrationWithSslTest.java | 15 +-
.../ResetPartitionTimeIntegrationTest.java | 15 +-
.../integration/RestoreIntegrationTest.java | 15 +-
.../integration/RocksDBMetricsIntegrationTest.java | 15 +-
.../SmokeTestDriverIntegrationTest.java | 15 +-
.../StandbyTaskCreationIntegrationTest.java | 20 ++-
.../integration/StandbyTaskEOSIntegrationTest.java | 16 +-
.../StateRestorationIntegrationTest.java | 16 +-
.../integration/StoreQueryIntegrationTest.java | 6 +-
.../integration/StoreUpgradeIntegrationTest.java | 15 +-
...bleJoinTopologyOptimizationIntegrationTest.java | 14 +-
...amsUncaughtExceptionHandlerIntegrationTest.java | 15 +-
.../StreamsUpgradeTestIntegrationTest.java | 13 +-
.../SuppressionDurabilityIntegrationTest.java | 15 +-
.../integration/SuppressionIntegrationTest.java | 16 +-
.../integration/TaskAssignorIntegrationTest.java | 16 +-
.../integration/utils/EmbeddedKafkaCluster.java | 15 +-
.../streams/integration/utils/KafkaEmbedded.java | 11 +-
...HandlingSourceTopicDeletionIntegrationTest.java | 15 +-
...bleJoinScalaIntegrationTestImplicitSerdes.scala | 11 +-
.../apache/kafka/streams/scala/TopologyTest.scala | 4 +-
.../apache/kafka/streams/scala/WordCountTest.scala | 38 ++---
.../kafka/streams/scala/kstream/ConsumedTest.scala | 47 +++---
.../kafka/streams/scala/kstream/GroupedTest.scala | 27 ++--
.../kafka/streams/scala/kstream/JoinedTest.scala | 26 ++--
.../streams/scala/kstream/KStreamSplitTest.scala | 33 ++--
.../kafka/streams/scala/kstream/KStreamTest.scala | 140 +++++++++--------
.../kafka/streams/scala/kstream/KTableTest.scala | 168 +++++++++++----------
.../streams/scala/kstream/MaterializedTest.scala | 59 ++++----
.../kafka/streams/scala/kstream/ProducedTest.scala | 26 ++--
.../streams/scala/kstream/RepartitionedTest.scala | 57 +++----
.../streams/scala/kstream/StreamJoinedTest.scala | 45 +++---
.../streams/scala/kstream/SuppressedTest.scala | 69 ++++-----
...StreamToTableJoinScalaIntegrationTestBase.scala | 35 +++--
.../kafka/streams/scala/utils/TestDriver.scala | 4 +-
63 files changed, 1035 insertions(+), 603 deletions(-)
