This is an automated email from the ASF dual-hosted git repository.
jgus pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 0e57a39 KAFKA-9184: Redundant task creation and periodic rebalances
after zombie Connect worker rejoins the group (#7771)
add eaccb92 MINOR: Cleanup redundancies in BaseRequestTest (#7735)
No new revisions were added by this update.
Summary of changes:
.../kafka/api/AuthorizerIntegrationTest.scala | 180 +++++----------------
.../integration/kafka/api/ConsumerBounceTest.scala | 15 +-
.../kafka/api/SaslPlainPlaintextConsumerTest.scala | 4 +-
.../kafka/network/DynamicConnectionQuotaTest.scala | 25 ++-
.../scala/unit/kafka/admin/AddPartitionsTest.scala | 24 ++-
.../server/AbstractApiVersionsRequestTest.scala | 47 ++++++
.../server/AbstractCreateTopicsRequestTest.scala | 41 ++---
.../server/AddPartitionsToTxnRequestTest.scala | 11 +-
.../server/AlterReplicaLogDirsRequestTest.scala | 10 +-
.../unit/kafka/server/ApiVersionsRequestTest.scala | 39 ++---
.../scala/unit/kafka/server/BaseRequestTest.scala | 150 +++++++----------
.../kafka/server/CreateTopicsRequestTest.scala | 1 +
.../kafka/server/DeleteTopicsRequestTest.scala | 17 +-
...leteTopicsRequestWithDeletionDisabledTest.scala | 12 +-
.../kafka/server/DescribeLogDirsRequestTest.scala | 9 +-
.../FetchRequestDownConversionConfigTest.scala | 5 +-
.../kafka/server/FetchRequestMaxBytesTest.scala | 6 +-
.../scala/unit/kafka/server/FetchRequestTest.scala | 11 +-
.../KafkaMetricReporterExceptionHandlingTest.scala | 10 +-
.../unit/kafka/server/ListOffsetsRequestTest.scala | 6 +-
.../scala/unit/kafka/server/LogOffsetTest.scala | 15 +-
.../unit/kafka/server/MetadataRequestTest.scala | 5 +-
.../server/OffsetsForLeaderEpochRequestTest.scala | 4 +-
.../unit/kafka/server/ProduceRequestTest.scala | 9 +-
.../scala/unit/kafka/server/RequestQuotaTest.scala | 90 ++---------
.../kafka/server/SaslApiVersionsRequestTest.scala | 60 ++++---
.../unit/kafka/server/StopReplicaRequestTest.scala | 9 +-
27 files changed, 298 insertions(+), 517 deletions(-)
create mode 100644
core/src/test/scala/unit/kafka/server/AbstractApiVersionsRequestTest.scala