nohup: ignoring input Exception in thread "DisconnectableInputStream source reader" org.gradle.api.UncheckedIOException: java.io.IOException: Bad file descriptor at org.gradle.internal.UncheckedException.throwAsUncheckedException(UncheckedException.java:62) at org.gradle.internal.UncheckedException.throwAsUncheckedException(UncheckedException.java:41) at org.gradle.util.internal.DisconnectableInputStream$1.run(DisconnectableInputStream.java:127) at java.base/java.lang.Thread.run(Thread.java:829) Caused by: java.io.IOException: Bad file descriptor at java.base/java.io.FileInputStream.readBytes(Native Method) at java.base/java.io.FileInputStream.read(FileInputStream.java:279) at java.base/java.io.BufferedInputStream.read1(BufferedInputStream.java:290) at java.base/java.io.BufferedInputStream.read(BufferedInputStream.java:351) at org.gradle.util.internal.DisconnectableInputStream$1.run(DisconnectableInputStream.java:98) ... 1 more > Configure project : Starting build with version 3.2.0-SNAPSHOT (commit id 71f732e6) using Gradle 7.3.3, Java 11 and Scala 2.13.6 Build properties: maxParallelForks=8, maxScalacThreads=8, maxTestRetries=0 > Task :cleanTest UP-TO-DATE > Task :connect:cleanTest UP-TO-DATE > Task :jmh-benchmarks:cleanTest UP-TO-DATE > Task :generator:cleanTest > Task :examples:cleanTest UP-TO-DATE > Task :log4j-appender:cleanTest > Task :storage:cleanTest > Task :metadata:cleanTest > Task :server-common:cleanTest > Task :shell:cleanTest > Task :tools:cleanTest > Task :raft:cleanTest > Task :trogdor:cleanTest > Task :connect:basic-auth-extension:cleanTest > Task :connect:file:cleanTest > Task :connect:api:cleanTest > Task :connect:json:cleanTest > Task :connect:mirror-client:cleanTest > Task :connect:mirror:cleanTest > Task :storage:api:cleanTest > Task :streams:examples:cleanTest > Task :streams:streams-scala:cleanTest > Task :streams:upgrade-system-tests-0100:cleanTest > Task :streams:test-utils:cleanTest > Task :connect:transforms:cleanTest > Task :streams:upgrade-system-tests-0101:cleanTest > Task :streams:upgrade-system-tests-0102:cleanTest > Task :streams:upgrade-system-tests-10:cleanTest > Task :streams:upgrade-system-tests-11:cleanTest > Task :streams:upgrade-system-tests-0110:cleanTest > Task :streams:upgrade-system-tests-20:cleanTest > Task :streams:upgrade-system-tests-21:cleanTest > Task :streams:upgrade-system-tests-22:cleanTest > Task :streams:upgrade-system-tests-24:cleanTest > Task :streams:upgrade-system-tests-25:cleanTest > Task :connect:runtime:cleanTest > Task :streams:upgrade-system-tests-23:cleanTest > Task :streams:upgrade-system-tests-26:cleanTest > Task :streams:upgrade-system-tests-27:cleanTest > Task :streams:upgrade-system-tests-28:cleanTest > Task :connect:compileJava NO-SOURCE > Task :streams:upgrade-system-tests-31:cleanTest > Task :core:cleanTest > Task :connect:processResources NO-SOURCE > Task :connect:classes UP-TO-DATE > Task :connect:compileTestJava NO-SOURCE > Task :connect:processTestResources NO-SOURCE > Task :connect:testClasses UP-TO-DATE > Task :streams:upgrade-system-tests-30:cleanTest > Task :connect:integrationTest NO-SOURCE > Task :metadata:processResources UP-TO-DATE > Task :server-common:processResources NO-SOURCE > Task :core:processResources UP-TO-DATE > Task :core:processTestResources UP-TO-DATE > Task :raft:processResources UP-TO-DATE > Task :storage:processResources UP-TO-DATE > Task :storage:api:processResources NO-SOURCE > Task :metadata:processTestResources UP-TO-DATE > Task :raft:processTestResources UP-TO-DATE > Task :examples:processResources NO-SOURCE > Task :examples:processTestResources NO-SOURCE > Task :jmh-benchmarks:processResources NO-SOURCE > Task :jmh-benchmarks:processTestResources NO-SOURCE > Task :log4j-appender:processResources NO-SOURCE > Task :log4j-appender:processTestResources NO-SOURCE > Task :shell:processResources NO-SOURCE > Task :shell:processTestResources NO-SOURCE > Task :streams:test-utils:processResources NO-SOURCE > Task :streams:cleanTest > Task :tools:processResources NO-SOURCE > Task :tools:processTestResources UP-TO-DATE > Task :trogdor:processResources NO-SOURCE > Task :storage:createVersionFile > Task :storage:processTestResources UP-TO-DATE > Task :raft:createVersionFile > Task :connect:api:processResources NO-SOURCE > Task :storage:api:createVersionFile > Task :streams:processResources UP-TO-DATE > Task :clients:cleanTest > Task :trogdor:processTestResources UP-TO-DATE > Task :connect:json:processResources NO-SOURCE > Task :generator:compileJava UP-TO-DATE > Task :connect:file:processResources NO-SOURCE > Task :server-common:createVersionFile > Task :connect:api:processTestResources NO-SOURCE > Task :generator:processResources NO-SOURCE > Task :connect:basic-auth-extension:processResources UP-TO-DATE > Task :connect:mirror:processResources NO-SOURCE > Task :server-common:processTestResources NO-SOURCE > Task :connect:basic-auth-extension:processTestResources NO-SOURCE > Task :connect:mirror-client:processResources NO-SOURCE > Task :connect:transforms:processResources NO-SOURCE > Task :streams:createStreamsVersionFile > Task :connect:file:processTestResources NO-SOURCE > Task :connect:mirror-client:processTestResources NO-SOURCE > Task :connect:mirror:processTestResources UP-TO-DATE > Task :connect:transforms:processTestResources NO-SOURCE > Task :storage:api:processTestResources NO-SOURCE > Task :streams:examples:processResources NO-SOURCE > Task :streams:examples:processTestResources NO-SOURCE > Task :streams:streams-scala:processResources NO-SOURCE > Task :generator:classes UP-TO-DATE > Task :streams:processTestResources UP-TO-DATE > Task :connect:json:processTestResources UP-TO-DATE > Task :streams:test-utils:processTestResources UP-TO-DATE > Task :connect:runtime:processResources UP-TO-DATE > Task :streams:streams-scala:processTestResources UP-TO-DATE > Task :connect:runtime:processTestResources UP-TO-DATE > Task :streams:upgrade-system-tests-0100:compileJava NO-SOURCE > Task :streams:upgrade-system-tests-0100:processResources NO-SOURCE > Task :streams:upgrade-system-tests-0100:classes UP-TO-DATE > Task :clients:processResources UP-TO-DATE > Task :generator:compileTestJava UP-TO-DATE > Task :generator:processTestResources NO-SOURCE > Task :generator:testClasses UP-TO-DATE > Task :streams:upgrade-system-tests-0100:compileTestJava UP-TO-DATE > Task :generator:integrationTest > Task :clients:processTestResources UP-TO-DATE > Task :raft:processMessages UP-TO-DATE > Task :storage:processMessages UP-TO-DATE > Task :streams:processMessages UP-TO-DATE > Task :metadata:processMessages UP-TO-DATE > Task :streams:upgrade-system-tests-0100:processTestResources NO-SOURCE > Task :core:processMessages UP-TO-DATE > Task :streams:upgrade-system-tests-0101:compileJava NO-SOURCE > Task :streams:upgrade-system-tests-0100:testClasses UP-TO-DATE > Task :streams:upgrade-system-tests-0101:processResources NO-SOURCE > Task :streams:upgrade-system-tests-0102:compileJava NO-SOURCE > Task :clients:createVersionFile > Task :streams:upgrade-system-tests-0110:compileJava NO-SOURCE > Task :streams:upgrade-system-tests-0110:processResources NO-SOURCE > Task :streams:upgrade-system-tests-10:compileJava NO-SOURCE > Task :streams:upgrade-system-tests-0101:classes UP-TO-DATE > Task :streams:upgrade-system-tests-0102:processResources NO-SOURCE > Task :streams:upgrade-system-tests-11:compileJava NO-SOURCE > Task :streams:upgrade-system-tests-0102:classes UP-TO-DATE > Task :streams:upgrade-system-tests-11:processResources NO-SOURCE > Task :streams:upgrade-system-tests-10:processResources NO-SOURCE > Task :clients:processMessages UP-TO-DATE > Task :streams:upgrade-system-tests-0110:classes UP-TO-DATE > Task :streams:upgrade-system-tests-10:classes UP-TO-DATE > Task :streams:upgrade-system-tests-11:classes UP-TO-DATE > Task :streams:upgrade-system-tests-0102:compileTestJava UP-TO-DATE > Task :streams:upgrade-system-tests-0102:processTestResources NO-SOURCE > Task :streams:upgrade-system-tests-0102:testClasses UP-TO-DATE > Task :streams:upgrade-system-tests-0101:compileTestJava UP-TO-DATE > Task :streams:upgrade-system-tests-0101:processTestResources NO-SOURCE > Task :streams:upgrade-system-tests-0101:testClasses UP-TO-DATE > Task :streams:upgrade-system-tests-0110:compileTestJava UP-TO-DATE > Task :streams:upgrade-system-tests-0110:processTestResources NO-SOURCE > Task :streams:upgrade-system-tests-0110:testClasses UP-TO-DATE > Task :streams:upgrade-system-tests-11:compileTestJava UP-TO-DATE > Task :streams:upgrade-system-tests-10:compileTestJava UP-TO-DATE > Task :streams:upgrade-system-tests-10:processTestResources NO-SOURCE > Task :streams:upgrade-system-tests-10:testClasses UP-TO-DATE > Task :streams:upgrade-system-tests-11:processTestResources NO-SOURCE > Task :streams:upgrade-system-tests-11:testClasses UP-TO-DATE > Task :clients:compileJava UP-TO-DATE > Task :clients:classes UP-TO-DATE > Task :clients:jar UP-TO-DATE > Task :server-common:compileJava UP-TO-DATE > Task :raft:compileJava UP-TO-DATE > Task :metadata:compileJava UP-TO-DATE > Task :storage:api:compileJava UP-TO-DATE > Task :storage:compileJava UP-TO-DATE > Task :core:compileJava NO-SOURCE > Task :core:compileScala UP-TO-DATE > Task :core:classes UP-TO-DATE > Task :metadata:classes UP-TO-DATE > Task :raft:classes UP-TO-DATE > Task :metadata:jar UP-TO-DATE > Task :raft:jar UP-TO-DATE > Task :server-common:classes UP-TO-DATE > Task :server-common:jar UP-TO-DATE > Task :storage:classes UP-TO-DATE > Task :storage:jar UP-TO-DATE > Task :storage:api:classes UP-TO-DATE > Task :storage:api:jar UP-TO-DATE > Task :examples:compileJava UP-TO-DATE > Task :examples:classes UP-TO-DATE > Task :examples:compileTestJava NO-SOURCE > Task :examples:testClasses UP-TO-DATE > Task :streams:compileJava UP-TO-DATE > Task :streams:classes UP-TO-DATE > Task :streams:copyDependantLibs UP-TO-DATE > Task :streams:jar UP-TO-DATE > Task :log4j-appender:compileJava UP-TO-DATE > Task :log4j-appender:classes UP-TO-DATE > Task :log4j-appender:jar UP-TO-DATE > Task :shell:compileJava UP-TO-DATE > Task :shell:classes UP-TO-DATE > Task :shell:compileTestJava UP-TO-DATE > Task :shell:testClasses UP-TO-DATE > Task :streams:test-utils:compileJava UP-TO-DATE > Task :streams:test-utils:classes UP-TO-DATE > Task :streams:test-utils:copyDependantLibs UP-TO-DATE > Task :streams:test-utils:jar UP-TO-DATE > Task :tools:compileJava UP-TO-DATE > Task :tools:classes UP-TO-DATE > Task :trogdor:compileJava UP-TO-DATE > Task :clients:processTestMessages UP-TO-DATE > Task :clients:compileTestJava UP-TO-DATE > Task :clients:testClasses UP-TO-DATE > Task :streams:upgrade-system-tests-0100:integrationTest > Task :raft:compileTestJava UP-TO-DATE > Task :raft:testClasses UP-TO-DATE > Task :metadata:compileTestJava UP-TO-DATE > Task :metadata:testClasses UP-TO-DATE > Task :core:compileTestJava NO-SOURCE > Task :log4j-appender:compileTestJava UP-TO-DATE > Task :log4j-appender:testClasses UP-TO-DATE > Task :core:compileTestScala UP-TO-DATE > Task :core:testClasses UP-TO-DATE > Task :streams:upgrade-system-tests-0102:integrationTest > Task :jmh-benchmarks:compileJava UP-TO-DATE > Task :jmh-benchmarks:classes UP-TO-DATE > Task :jmh-benchmarks:compileTestJava NO-SOURCE > Task :jmh-benchmarks:testClasses UP-TO-DATE > Task :streams:upgrade-system-tests-10:integrationTest > Task :streams:upgrade-system-tests-11:integrationTest > Task :server-common:compileTestJava UP-TO-DATE > Task :server-common:testClasses UP-TO-DATE > Task :streams:upgrade-system-tests-0101:integrationTest > Task :storage:compileTestJava UP-TO-DATE > Task :storage:testClasses UP-TO-DATE > Task :streams:upgrade-system-tests-0110:integrationTest > Task :streams:compileTestJava UP-TO-DATE > Task :streams:testClasses UP-TO-DATE > Task :tools:compileTestJava UP-TO-DATE > Task :tools:testClasses UP-TO-DATE > Task :log4j-appender:integrationTest > Task :trogdor:classes UP-TO-DATE > Task :trogdor:compileTestJava UP-TO-DATE > Task :trogdor:testClasses UP-TO-DATE > Task :server-common:integrationTest > Task :connect:api:compileJava UP-TO-DATE > Task :connect:api:classes UP-TO-DATE > Task :connect:api:compileTestJava UP-TO-DATE > Task :connect:api:testClasses UP-TO-DATE > Task :core:integrationTest ListOffsetsIntegrationTest > testMaxTimestampOffset() PASSED > Task :tools:integrationTest > Task :connect:basic-auth-extension:compileJava UP-TO-DATE > Task :connect:basic-auth-extension:classes UP-TO-DATE > Task :connect:basic-auth-extension:compileTestJava UP-TO-DATE > Task :connect:basic-auth-extension:testClasses UP-TO-DATE > Task :connect:file:compileJava UP-TO-DATE > Task :connect:file:classes UP-TO-DATE > Task :connect:file:compileTestJava UP-TO-DATE > Task :connect:file:testClasses UP-TO-DATE > Task :connect:json:compileJava UP-TO-DATE > Task :connect:json:classes UP-TO-DATE > Task :connect:json:compileTestJava UP-TO-DATE > Task :connect:json:testClasses UP-TO-DATE > Task :tools:copyDependantLibs UP-TO-DATE > Task :tools:jar UP-TO-DATE > Task :connect:mirror-client:compileJava UP-TO-DATE > Task :connect:transforms:compileJava UP-TO-DATE > Task :connect:runtime:compileJava UP-TO-DATE > Task :core:integrationTest ListOffsetsIntegrationTest > testLatestOffset() PASSED > Task :connect:mirror:compileJava UP-TO-DATE > Task :connect:mirror:classes UP-TO-DATE > Task :connect:runtime:classes UP-TO-DATE > Task :connect:runtime:compileTestJava UP-TO-DATE > Task :metadata:integrationTest > Task :connect:runtime:testClasses UP-TO-DATE > Task :connect:mirror:compileTestJava UP-TO-DATE > Task :connect:mirror:testClasses UP-TO-DATE > Task :connect:mirror-client:classes UP-TO-DATE > Task :connect:mirror-client:copyDependantLibs UP-TO-DATE > Task :connect:mirror-client:jar UP-TO-DATE > Task :connect:transforms:classes UP-TO-DATE > Task :connect:mirror-client:compileTestJava UP-TO-DATE > Task :connect:mirror-client:testClasses UP-TO-DATE > Task :core:integrationTest ListOffsetsIntegrationTest > testEarliestOffset() PASSED DeleteConsumerGroupsTest > testDeleteNonEmptyGroup() PASSED DeleteConsumerGroupsTest > testDeleteCmdWithMixOfSuccessAndError() PASSED > Task :connect:mirror-client:integrationTest > Task :connect:transforms:compileTestJava UP-TO-DATE > Task :connect:transforms:testClasses UP-TO-DATE > Task :trogdor:integrationTest CoordinatorTest > testTaskRequest() PASSED CoordinatorTest > testTaskDestruction() PASSED CoordinatorTest > testTasksRequestMatches() PASSED > Task :storage:api:compileTestJava UP-TO-DATE > Task :storage:api:testClasses UP-TO-DATE > Task :core:integrationTest DeleteConsumerGroupsTest > testDeleteWithTopicOption() PASSED DeleteConsumerGroupsTest > testDeleteNonExistingGroup() PASSED AdminZkClientTest > testMockedConcurrentTopicCreation() PASSED > Task :connect:api:integrationTest > Task :connect:api:copyDependantLibs UP-TO-DATE > Task :connect:api:jar UP-TO-DATE > Task :storage:api:integrationTest > Task :trogdor:integrationTest CoordinatorTest > testWorkersExitingAtDifferentTimes() PASSED > Task :clients:integrationTest > Task :core:integrationTest AdminZkClientTest > testGetBrokerMetadatas() PASSED DeleteConsumerGroupsTest > testDeleteCmdNonEmptyGroup() PASSED DeleteConsumerGroupsTest > testDeleteCmdNonExistingGroup() PASSED DeleteConsumerGroupsTest > testDeleteEmptyGroup() PASSED > Task :connect:basic-auth-extension:integrationTest > Task :connect:transforms:copyDependantLibs UP-TO-DATE > Task :connect:transforms:jar UP-TO-DATE > Task :trogdor:integrationTest CoordinatorTest > testAgentFailureAndTaskExpiry() PASSED > Task :raft:integrationTest > Task :connect:json:integrationTest > Task :connect:json:copyDependantLibs UP-TO-DATE > Task :connect:json:jar UP-TO-DATE > Task :streams:examples:compileJava UP-TO-DATE > Task :streams:examples:classes UP-TO-DATE > Task :streams:examples:compileTestJava UP-TO-DATE > Task :streams:examples:testClasses UP-TO-DATE > Task :core:integrationTest AdminZkClientTest > testBootstrapClientIdConfig() PASSED DeleteConsumerGroupsTest > testDeleteWithMixOfSuccessAndError() PASSED FeatureCommandTest > testDowngradeFeaturesSuccess() PASSED AdminZkClientTest > testTopicConfigChange() PASSED DeleteConsumerGroupsTest > testDeleteWithUnrecognizedNewConsumerOption() PASSED AdminZkClientTest > testManualReplicaAssignment() PASSED AdminZkClientTest > testConcurrentTopicCreation() PASSED > Task :connect:file:integrationTest > Task :streams:streams-scala:compileJava NO-SOURCE > Task :streams:streams-scala:compileScala UP-TO-DATE > Task :streams:streams-scala:classes UP-TO-DATE > Task :streams:streams-scala:compileTestJava NO-SOURCE > Task :streams:streams-scala:compileTestScala UP-TO-DATE > Task :streams:streams-scala:testClasses UP-TO-DATE > Task :trogdor:integrationTest CoordinatorTest > testTaskDistribution() PASSED CoordinatorTest > testTaskRequestWithOldStartMsGetsUpdated() PASSED > Task :streams:test-utils:compileTestJava UP-TO-DATE > Task :streams:test-utils:testClasses UP-TO-DATE > Task :core:integrationTest DeleteConsumerGroupsTest > testDeleteCmdAllGroups() PASSED FeatureCommandTest > testDescribeFeaturesSuccess() PASSED DeleteConsumerGroupsTest > testDeleteCmdEmptyGroup() PASSED AdminZkClientTest > shouldPropagateDynamicBrokerConfigs() PASSED AdminZkClientTest > testMarkedDeletionTopicCreation() PASSED AdminZkClientTest > testTopicCreationWithCollision() PASSED AdminZkClientTest > testTopicCreationInZK() PASSED FeatureCommandTest > testUpgradeAllFeaturesSuccess() PASSED FeatureCommandTest > testUpgradeFeaturesFailure() PASSED UserScramCredentialsCommandTest > testDescribeUnknownUser() PASSED ListConsumerGroupTest > testListConsumerGroupsWithStates() PASSED > Task :trogdor:integrationTest CoordinatorTest > testNetworkPartitionFault() PASSED CoordinatorTest > testTaskRequestWithFutureStartMsDoesNotGetRun() PASSED CoordinatorTest > testTaskCancellation() PASSED CoordinatorTest > testCreateTask() PASSED CoordinatorTest > testTasksRequest() PASSED CoordinatorTest > testCoordinatorStatus() PASSED CoordinatorTest > testCoordinatorUptime() PASSED > Task :streams:upgrade-system-tests-20:compileJava NO-SOURCE > Task :streams:upgrade-system-tests-20:processResources NO-SOURCE > Task :streams:upgrade-system-tests-20:classes UP-TO-DATE > Task :streams:upgrade-system-tests-20:compileTestJava UP-TO-DATE > Task :streams:upgrade-system-tests-20:processTestResources NO-SOURCE > Task :streams:upgrade-system-tests-20:testClasses UP-TO-DATE > Task :core:integrationTest ListConsumerGroupTest > testListWithUnrecognizedNewConsumerOption() PASSED UserScramCredentialsCommandTest > testUserScramCredentialsRequests() PASSED > Task :streams:examples:integrationTest > Task :streams:upgrade-system-tests-21:compileJava NO-SOURCE > Task :streams:upgrade-system-tests-21:processResources NO-SOURCE > Task :streams:upgrade-system-tests-21:classes UP-TO-DATE > Task :streams:upgrade-system-tests-21:compileTestJava UP-TO-DATE > Task :streams:upgrade-system-tests-21:processTestResources NO-SOURCE > Task :streams:upgrade-system-tests-21:testClasses UP-TO-DATE > Task :connect:transforms:integrationTest > Task :streams:upgrade-system-tests-22:compileJava NO-SOURCE > Task :streams:upgrade-system-tests-22:processResources NO-SOURCE > Task :streams:upgrade-system-tests-22:classes UP-TO-DATE > Task :streams:upgrade-system-tests-22:compileTestJava UP-TO-DATE > Task :streams:upgrade-system-tests-22:processTestResources NO-SOURCE > Task :streams:upgrade-system-tests-22:testClasses UP-TO-DATE > Task :streams:upgrade-system-tests-20:integrationTest > Task :streams:upgrade-system-tests-23:compileJava NO-SOURCE > Task :streams:upgrade-system-tests-23:processResources NO-SOURCE > Task :streams:upgrade-system-tests-23:classes UP-TO-DATE > Task :streams:upgrade-system-tests-23:compileTestJava UP-TO-DATE > Task :streams:upgrade-system-tests-23:processTestResources NO-SOURCE > Task :streams:upgrade-system-tests-23:testClasses UP-TO-DATE > Task :core:integrationTest UserScramCredentialsCommandTest > testAlterWithEmptyPassword() PASSED > Task :streams:upgrade-system-tests-21:integrationTest > Task :streams:upgrade-system-tests-24:compileJava NO-SOURCE > Task :streams:upgrade-system-tests-24:processResources NO-SOURCE > Task :streams:upgrade-system-tests-24:classes UP-TO-DATE > Task :streams:upgrade-system-tests-24:compileTestJava UP-TO-DATE > Task :streams:upgrade-system-tests-24:processTestResources NO-SOURCE > Task :streams:upgrade-system-tests-24:testClasses UP-TO-DATE > Task :streams:test-utils:integrationTest > Task :streams:upgrade-system-tests-25:compileJava NO-SOURCE > Task :streams:upgrade-system-tests-25:processResources NO-SOURCE > Task :streams:upgrade-system-tests-25:classes UP-TO-DATE > Task :streams:upgrade-system-tests-25:compileTestJava UP-TO-DATE > Task :streams:upgrade-system-tests-25:processTestResources NO-SOURCE > Task :streams:upgrade-system-tests-25:testClasses UP-TO-DATE > Task :core:integrationTest ListConsumerGroupTest > testListConsumerGroups() PASSED ListConsumerGroupTest > testConsumerGroupStatesFromString() PASSED DelegationTokenEndToEndAuthorizationTest > testNoConsumeWithoutDescribeAclViaSubscribe() PASSED ConsumerBounceTest > testCloseDuringRebalance() PASSED kafka.api.ConsumerBounceTest.testClose() failed, log available in /home/ubuntu/anant/kafka/core/build/reports/testOutput/kafka.api.ConsumerBounceTest.testClose().test.stdout ConsumerBounceTest > testClose() FAILED java.lang.NullPointerException at kafka.api.ConsumerBounceTest.checkClosedState(ConsumerBounceTest.scala:492) at kafka.api.ConsumerBounceTest.checkCloseWithCoordinatorFailure(ConsumerBounceTest.scala:258) at kafka.api.ConsumerBounceTest.testClose(ConsumerBounceTest.scala:220) ListConsumerGroupTest > testListGroupCommand() PASSED > Task :streams:upgrade-system-tests-22:integrationTest > Task :streams:upgrade-system-tests-26:compileJava NO-SOURCE > Task :streams:upgrade-system-tests-26:processResources NO-SOURCE > Task :streams:upgrade-system-tests-26:classes UP-TO-DATE > Task :streams:upgrade-system-tests-26:compileTestJava UP-TO-DATE > Task :streams:upgrade-system-tests-26:processTestResources NO-SOURCE > Task :streams:upgrade-system-tests-26:testClasses UP-TO-DATE > Task :streams:upgrade-system-tests-23:integrationTest > Task :streams:upgrade-system-tests-27:compileJava NO-SOURCE > Task :streams:upgrade-system-tests-27:processResources NO-SOURCE > Task :streams:upgrade-system-tests-27:classes UP-TO-DATE > Task :streams:upgrade-system-tests-27:compileTestJava UP-TO-DATE > Task :streams:upgrade-system-tests-27:processTestResources NO-SOURCE > Task :streams:upgrade-system-tests-27:testClasses UP-TO-DATE > Task :core:integrationTest DelegationTokenEndToEndAuthorizationTest > testProduceConsumeWithPrefixedAcls() PASSED > Task :streams:upgrade-system-tests-24:integrationTest > Task :streams:upgrade-system-tests-28:compileJava NO-SOURCE > Task :streams:upgrade-system-tests-28:processResources NO-SOURCE > Task :streams:upgrade-system-tests-28:classes UP-TO-DATE > Task :streams:upgrade-system-tests-28:compileTestJava UP-TO-DATE > Task :streams:upgrade-system-tests-28:processTestResources NO-SOURCE > Task :streams:upgrade-system-tests-28:testClasses UP-TO-DATE > Task :streams:upgrade-system-tests-25:integrationTest > Task :core:integrationTest TopicCommandIntegrationTest > testAlterPartitionCount() PASSED DelegationTokenEndToEndAuthorizationTest > testProduceConsumeViaAssign() PASSED TopicCommandIntegrationTest > testCreatePartitionsDoesNotRetryThrottlingQuotaExceededException() PASSED ConsumerBounceTest > testSeekAndCommitWithBrokerFailures() PASSED > Task :streams:upgrade-system-tests-26:integrationTest > Task :streams:upgrade-system-tests-30:compileJava NO-SOURCE > Task :streams:upgrade-system-tests-30:processResources NO-SOURCE > Task :streams:upgrade-system-tests-30:classes UP-TO-DATE > Task :streams:upgrade-system-tests-30:compileTestJava UP-TO-DATE > Task :streams:upgrade-system-tests-30:processTestResources NO-SOURCE > Task :streams:upgrade-system-tests-30:testClasses UP-TO-DATE > Task :core:integrationTest TopicCommandIntegrationTest > testAlterWhenTopicDoesntExistWithIfExists() PASSED ConsumerBounceTest > testConsumerReceivesFatalExceptionWhenGroupPassesMaxSize() PASSED > Task :streams:upgrade-system-tests-27:integrationTest > Task :streams:upgrade-system-tests-31:compileJava NO-SOURCE > Task :streams:upgrade-system-tests-31:processResources NO-SOURCE > Task :streams:upgrade-system-tests-31:classes UP-TO-DATE > Task :streams:upgrade-system-tests-31:compileTestJava UP-TO-DATE > Task :streams:upgrade-system-tests-31:processTestResources NO-SOURCE > Task :streams:upgrade-system-tests-31:testClasses UP-TO-DATE > Task :core:integrationTest BrokerApiVersionsCommandTest > checkBrokerApiVersionCommandOutput() PASSED DelegationTokenEndToEndAuthorizationTest > testNoConsumeWithDescribeAclViaAssign() PASSED > Task :streams:upgrade-system-tests-28:integrationTest > Task :core:integrationTest TopicCommandIntegrationTest > testCreateWithDefaultReplication() PASSED GroupCoordinatorIntegrationTest > testGroupCoordinatorPropagatesOffsetsTopicCompressionCodec() PASSED PlaintextAdminIntegrationTest > testCreateDeleteTopics() PASSED ConsumerBounceTest > testSubscribeWhenTopicUnavailable() PASSED TopicCommandIntegrationTest > testDescribeAtMinIsrPartitions() PASSED PlaintextAdminIntegrationTest > testAuthorizedOperations() PASSED TopicCommandIntegrationTest > testCreateWithNegativeReplicationFactor() PASSED > Task :streams:upgrade-system-tests-30:integrationTest > Task :streams:upgrade-system-tests-31:integrationTest > Task :core:integrationTest DelegationTokenEndToEndAuthorizationTest > testProduceConsumeTopicAutoCreateTopicCreateAcl() PASSED PlaintextAdminIntegrationTest > testDescribeReplicaLogDirs() PASSED PlaintextAdminIntegrationTest > testIncrementalAlterConfigsForLog4jLogLevels() SKIPPED PlaintextAdminIntegrationTest > testIncrementalAlterConfigsForLog4jLogLevelsCannotResetRootLogger() SKIPPED ConsumerBounceTest > testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup() PASSED ConsumerBounceTest > testConsumptionWithBrokerFailures() SKIPPED DynamicNumNetworkThreadsTest > testDynamicNumNetworkThreads() PASSED TopicCommandIntegrationTest > testCreateWithInvalidReplicationFactor() PASSED PlaintextAdminIntegrationTest > testInvalidAlterPartitionReassignments() PASSED DeleteOffsetsConsumerGroupCommandIntegrationTest > testDeleteOffsetsOfStableConsumerGroupWithTopicOnly() PASSED PlaintextAdminIntegrationTest > testInvalidAlterConfigs() PASSED TopicCommandIntegrationTest > testDeleteTopicDoesNotRetryThrottlingQuotaExceededException() PASSED DeleteOffsetsConsumerGroupCommandIntegrationTest > testDeleteOffsetsOfEmptyConsumerGroupWithUnknownTopicOnly() PASSED DelegationTokenEndToEndAuthorizationTest > testProduceConsumeWithWildcardAcls() PASSED DeleteOffsetsConsumerGroupCommandIntegrationTest > testDeleteOffsetsOfStableConsumerGroupWithUnknownTopicPartition() PASSED PlaintextAdminIntegrationTest > testElectUncleanLeadersNoop() PASSED DeleteOffsetsConsumerGroupCommandIntegrationTest > testDeleteOffsetsOfEmptyConsumerGroupWithUnknownTopicPartition() PASSED TopicCommandIntegrationTest > testListTopicsWithExcludeInternal() PASSED DeleteOffsetsConsumerGroupCommandIntegrationTest > testDeleteOffsetsOfEmptyConsumerGroupWithTopicPartition() PASSED PlaintextAdminIntegrationTest > testAlterLogDirsAfterDeleteRecords() PASSED DeleteOffsetsConsumerGroupCommandIntegrationTest > testDeleteOffsetsOfEmptyConsumerGroupWithTopicOnly() PASSED DeleteOffsetsConsumerGroupCommandIntegrationTest > testDeleteOffsetsOfStableConsumerGroupWithTopicPartition() PASSED PlaintextAdminIntegrationTest > testIncrementalAlterConfigsDeleteBrokerConfigs() PASSED FetchRequestTestDowngrade > testTopicIdIsRemovedFromFetcherWhenControllerDowngrades() PASSED DelegationTokenEndToEndAuthorizationTest > testNoConsumeWithDescribeAclViaSubscribe() PASSED TopicCommandIntegrationTest > testDescribeUnderReplicatedPartitionsWhenReassignmentIsInProgress() PASSED DeleteOffsetsConsumerGroupCommandIntegrationTest > testDeleteOffsetsNonExistingGroup() PASSED > Task :raft:integrationTest RaftEventSimulationTest > canMakeProgressIfMajorityIsReachable PASSED > Task :core:integrationTest DeleteOffsetsConsumerGroupCommandIntegrationTest > testDeleteOffsetsOfStableConsumerGroupWithUnknownTopicOnly() PASSED PlaintextAdminIntegrationTest > testElectUncleanLeadersAndNoop() PASSED LogDirsCommandTest > checkLogDirsCommandOutput() PASSED TopicCommandIntegrationTest > testCreateWithNegativePartitionCount() PASSED AddPartitionsTest > testReplicaPlacementAllServers() PASSED PlaintextAdminIntegrationTest > testElectPreferredLeaders() PASSED TopicCommandIntegrationTest > testAlterWhenTopicDoesntExist() PASSED AddPartitionsTest > testMissingPartition0() PASSED FetchRequestBetweenDifferentIbpTest > testControllerOldToNewIBP() PASSED PlaintextAdminIntegrationTest > testDeleteConsumerGroupOffsets() PASSED DelegationTokenEndToEndAuthorizationTest > testNoConsumeWithoutDescribeAclViaAssign() PASSED CustomQuotaCallbackTest > testCustomQuotaCallback() PASSED ReassignPartitionsIntegrationTest > testProduceAndConsumeWithReassignmentInProgress() PASSED PlaintextAdminIntegrationTest > testListReassignmentsDoesNotShowNonReassigningPartitions() PASSED AddPartitionsTest > testWrongReplicaCount() PASSED MetricsTest > testMetrics() PASSED TopicCommandIntegrationTest > testCreateAlterTopicWithRackAware() PASSED FetchRequestBetweenDifferentIbpTest > testControllerNewIBP() PASSED SaslClientsWithInvalidCredentialsTest > testTransactionalProducerWithAuthenticationFailure() PASSED PlaintextAdminIntegrationTest > testConsumeAfterDeleteRecords() PASSED AddPartitionsTest > testReplicaPlacementPartialServers() PASSED ReassignPartitionsIntegrationTest > testAlterReassignmentThrottle() PASSED TopicCommandIntegrationTest > testListTopicsWithIncludeList() PASSED PlaintextAdminIntegrationTest > testClose() PASSED DelegationTokenEndToEndAuthorizationTest > testNoGroupAcl() PASSED SaslClientsWithInvalidCredentialsTest > testManualAssignmentConsumerWithAuthenticationFailure() PASSED FetchRequestBetweenDifferentIbpTest > testControllerOldIBP() PASSED AddPartitionsTest > testIncrementPartitions() PASSED TopicCommandIntegrationTest > testTopicDeletion() PASSED ReassignPartitionsIntegrationTest > testReassignment() PASSED SaslClientsWithInvalidCredentialsTest > testConsumerGroupServiceWithAuthenticationSuccess() PASSED TopicCommandIntegrationTest > testCreateWithDefaults() PASSED AddPartitionsTest > testManualAssignmentOfReplicas() PASSED ReassignPartitionsIntegrationTest > testReassignmentCompletionDuringPartialUpgrade() PASSED PlaintextAdminIntegrationTest > testReplicaCanFetchFromLogStartOffsetAfterDeleteRecords() PASSED PlaintextAdminIntegrationTest > testIncrementalAlterConfigsForLog4jLogLevelsDoesNotWorkWithInvalidConfigs() SKIPPED SaslClientsWithInvalidCredentialsTest > testProducerWithAuthenticationFailure(boolean) > kafka.api.SaslClientsWithInvalidCredentialsTest.testProducerWithAuthenticationFailure(boolean)[1] PASSED DescribeConsumerGroupTest > testDescribeMembersOfNonExistingGroup() PASSED TopicCommandIntegrationTest > testDescribeReportOverriddenConfigs() PASSED DescribeConsumerGroupTest > testDescribeStateOfExistingGroup() PASSED PlaintextAdminIntegrationTest > testDescribeConfigsForLog4jLogLevels() PASSED FetchRequestBetweenDifferentIbpTest > testControllerNewToOldIBP() PASSED DelegationTokenEndToEndAuthorizationTest > testNoProduceWithDescribeAcl(boolean) > kafka.api.DelegationTokenEndToEndAuthorizationTest.testNoProduceWithDescribeAcl(boolean)[1] PASSED SaslClientsWithInvalidCredentialsTest > testProducerWithAuthenticationFailure(boolean) > kafka.api.SaslClientsWithInvalidCredentialsTest.testProducerWithAuthenticationFailure(boolean)[2] PASSED PlaintextAdminIntegrationTest > testMinimumRequestTimeouts() PASSED DescribeConsumerGroupTest > testDescribeExistingGroup() PASSED TopicCommandIntegrationTest > testDescribeWhenTopicDoesntExist() PASSED SaslClientsWithInvalidCredentialsTest > testConsumerGroupServiceWithAuthenticationFailure() PASSED PlaintextAdminIntegrationTest > testIncrementalAlterConfigsDeleteAndSetBrokerConfigs() PASSED PlaintextAdminIntegrationTest > testIncrementalAlterConfigsForLog4jLogLevelsCanResetLoggerToCurrentRoot() SKIPPED TopicCommandIntegrationTest > testDescribeDoesNotFailWhenListingReassignmentIsUnauthorized() PASSED PlaintextAdminIntegrationTest > testForceClose() PASSED SaslClientsWithInvalidCredentialsTest > testManualAssignmentConsumerWithAutoCommitDisabledWithAuthenticationFailure() PASSED ReassignPartitionsIntegrationTest > testAlterLogDirReassignmentThrottle() PASSED PlaintextAdminIntegrationTest > testListNodes() PASSED DelegationTokenEndToEndAuthorizationTest > testNoProduceWithDescribeAcl(boolean) > kafka.api.DelegationTokenEndToEndAuthorizationTest.testNoProduceWithDescribeAcl(boolean)[2] PASSED DescribeConsumerGroupTest > testDescribeStateWithConsumersWithoutAssignedPartitions() PASSED TopicCommandIntegrationTest > testAlterAssignmentWithMoreAssignmentThanPartitions() PASSED SaslClientsWithInvalidCredentialsTest > testKafkaAdminClientWithAuthenticationFailure() PASSED DescribeConsumerGroupTest > testDescribeWithMultipleSubActions() PASSED PlaintextAdminIntegrationTest > testDelayedClose() PASSED DescribeConsumerGroupTest > testDescribeGroupOffsetsWithShortInitializationTimeout() PASSED ReassignPartitionsIntegrationTest > testCancellation() PASSED PlaintextAdminIntegrationTest > testLongTopicNames() PASSED TopicCommandIntegrationTest > testDescribeWhenTopicDoesntExistWithIfExists() PASSED DescribeConsumerGroupTest > testDescribeOffsetsOfExistingGroupWithNoMembers() PASSED SaslClientsWithInvalidCredentialsTest > testConsumerWithAuthenticationFailure() PASSED DescribeConsumerGroupTest > testDescribeGroupMembersWithShortInitializationTimeout() PASSED ReassignPartitionsIntegrationTest > testReassignmentWithAlterIsrDisabled() PASSED DescribeConsumerGroupTest > testDescribeMembersOfExistingGroup() PASSED TopicCommandIntegrationTest > testCreateWithDefaultPartitions() PASSED DescribeConsumerGroupTest > testDescribeOffsetsOfExistingGroup() PASSED PlaintextAdminIntegrationTest > testOffsetsForTimesAfterDeleteRecords() PASSED DescribeConsumerGroupTest > testDescribeOffsetsWithConsumersWithoutAssignedPartitions() PASSED DelegationTokenEndToEndAuthorizationTest > testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl(boolean) > kafka.api.DelegationTokenEndToEndAuthorizationTest.testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl(boolean)[1] PASSED UserClientIdQuotaTest > testProducerConsumerOverrideLowerQuota() PASSED PlaintextAdminIntegrationTest > testListReassignmentsDoesNotShowDeletedPartitions() PASSED TopicCommandIntegrationTest > testListTopics() PASSED PlaintextAdminIntegrationTest > testDeleteTopicsWithIds() PASSED ReassignPartitionsIntegrationTest > testThrottledReassignment() PASSED TopicCommandIntegrationTest > testDeleteWhenTopicDoesntExistWithIfExists() PASSED AclCommandTest > testAclCliWithAuthorizer() PASSED PlaintextAdminIntegrationTest > testDeleteRecordsWithException() PASSED ReassignPartitionsIntegrationTest > testHighWaterMarkAfterPartitionReassignment() PASSED PlaintextAdminIntegrationTest > testDescribeLogDirs() PASSED TopicCommandIntegrationTest > testCreateWhenAlreadyExistsWithIfNotExists() PASSED UserClientIdQuotaTest > testProducerConsumerOverrideUnthrottled() PASSED PlaintextAdminIntegrationTest > testAlterReplicaLogDirs() PASSED DelegationTokenEndToEndAuthorizationTest > testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl(boolean) > kafka.api.DelegationTokenEndToEndAuthorizationTest.testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl(boolean)[2] PASSED TopicCommandIntegrationTest > testDeleteInternalTopic() PASSED ReassignPartitionsIntegrationTest > testLogDirReassignment() PASSED AuthorizerIntegrationTest > testCommitWithTopicWrite(String) > kafka.api.AuthorizerIntegrationTest.testCommitWithTopicWrite(String)[1] PASSED TopicCommandIntegrationTest > testInvalidTopicLevelConfig() PASSED AclCommandTest > testAclCliWithClientId() PASSED DescribeConsumerGroupTest > testDescribeWithMultiPartitionTopicAndMultipleConsumers() PASSED AclCommandTest > testInvalidAuthorizerProperty() PASSED AuthorizerIntegrationTest > testCommitWithTopicWrite(String) > kafka.api.AuthorizerIntegrationTest.testCommitWithTopicWrite(String)[2] PASSED AclCommandTest > testAclsOnPrefixedResourcesWithAdminAPI() PASSED AuthorizerIntegrationTest > shouldInitTransactionsWhenAclSet(String) > kafka.api.AuthorizerIntegrationTest.shouldInitTransactionsWhenAclSet(String)[1] PASSED TopicCommandIntegrationTest > testAlterAssignmentWithMorePartitionsThanAssignment() PASSED DelegationTokenEndToEndAuthorizationTest > testProduceConsumeViaSubscribe() PASSED PlaintextAdminIntegrationTest > testLogStartOffsetCheckpoint() PASSED PlaintextAdminIntegrationTest > testAlterConfigsForLog4jLogLevelsDoesNotWork() SKIPPED AuthorizerIntegrationTest > shouldInitTransactionsWhenAclSet(String) > kafka.api.AuthorizerIntegrationTest.shouldInitTransactionsWhenAclSet(String)[2] PASSED PlaintextAdminIntegrationTest > testAclOperations() PASSED TopicCommandIntegrationTest > testConfigPreservationAcrossPartitionAlteration() PASSED AuthorizerIntegrationTest > testOffsetFetchAllTopicPartitionsAuthorization(String) > kafka.api.AuthorizerIntegrationTest.testOffsetFetchAllTopicPartitionsAuthorization(String)[1] PASSED AclCommandTest > testPatternTypes() PASSED AuthorizerIntegrationTest > testOffsetFetchAllTopicPartitionsAuthorization(String) > kafka.api.AuthorizerIntegrationTest.testOffsetFetchAllTopicPartitionsAuthorization(String)[2] PASSED PlaintextAdminIntegrationTest > testDescribeCluster() PASSED TopicCommandIntegrationTest > testCreateWithConfigs() PASSED AuthorizerIntegrationTest > testDeleteGroupApiWithNoDeleteGroupAcl(String) > kafka.api.AuthorizerIntegrationTest.testDeleteGroupApiWithNoDeleteGroupAcl(String)[1] PASSED DescribeConsumerGroupTest > testDescribeSimpleConsumerGroup() PASSED AuthorizerIntegrationTest > testDeleteGroupApiWithNoDeleteGroupAcl(String) > kafka.api.AuthorizerIntegrationTest.testDeleteGroupApiWithNoDeleteGroupAcl(String)[2] PASSED PlaintextAdminIntegrationTest > testElectUncleanLeadersForManyPartitions() PASSED DescribeConsumerGroupTest > testDescribeStateOfNonExistingGroup() PASSED DelegationTokenEndToEndAuthorizationTest > testCreateUserWithDelegationToken() PASSED DescribeConsumerGroupTest > testDescribeMembersWithConsumersWithoutAssignedPartitions() PASSED GroupAuthorizerIntegrationTest > testUnauthorizedProduceAndConsume() PASSED TopicCommandIntegrationTest > testDescribeUnderReplicatedPartitions() PASSED AuthorizerIntegrationTest > testPatternSubscriptionWithTopicAndGroupRead(String) > kafka.api.AuthorizerIntegrationTest.testPatternSubscriptionWithTopicAndGroupRead(String)[1] PASSED PlaintextAdminIntegrationTest > testElectUncleanLeadersForUnknownPartitions() PASSED DescribeConsumerGroupTest > testDescribeMembersOfExistingGroupWithNoMembers() PASSED GroupAuthorizerIntegrationTest > testAuthorizedProduceAndConsume() PASSED DescribeConsumerGroupTest > testDescribeWithUnrecognizedNewConsumerOption() PASSED AuthorizerIntegrationTest > testPatternSubscriptionWithTopicAndGroupRead(String) > kafka.api.AuthorizerIntegrationTest.testPatternSubscriptionWithTopicAndGroupRead(String)[2] PASSED DescribeConsumerGroupTest > testDescribeGroupStateWithShortInitializationTimeout() PASSED PlaintextAdminIntegrationTest > testCreatePartitions() PASSED TopicCommandIntegrationTest > testDescribeUnderMinIsrPartitions() PASSED AuthorizerIntegrationTest > testPatternSubscriptionWithNoTopicAccess(String) > kafka.api.AuthorizerIntegrationTest.testPatternSubscriptionWithNoTopicAccess(String)[1] PASSED PlaintextAdminIntegrationTest > testDescribeNonExistingTopic() PASSED AuthorizerIntegrationTest > testPatternSubscriptionWithNoTopicAccess(String) > kafka.api.AuthorizerIntegrationTest.testPatternSubscriptionWithNoTopicAccess(String)[2] PASSED TopicCommandIntegrationTest > testDeleteWhenTopicDoesntExist() PASSED AclCommandTest > testProducerConsumerCliWithAdminAPI() PASSED PlaintextAdminIntegrationTest > testMetadataRefresh() PASSED AuthorizerIntegrationTest > testCreatePermissionOnClusterToWriteToNonExistentTopic(String) > kafka.api.AuthorizerIntegrationTest.testCreatePermissionOnClusterToWriteToNonExistentTopic(String)[1] PASSED AuthorizerIntegrationTest > testCreatePermissionOnClusterToWriteToNonExistentTopic(String) > kafka.api.AuthorizerIntegrationTest.testCreatePermissionOnClusterToWriteToNonExistentTopic(String)[2] PASSED AclCommandTest > testAclsOnPrefixedResourcesWithAuthorizer() PASSED UserClientIdQuotaTest > testThrottledProducerConsumer() PASSED PlaintextEndToEndAuthorizationTest > testNoConsumeWithoutDescribeAclViaSubscribe() PASSED PlaintextAdminIntegrationTest > testDescribeAndAlterConfigs() PASSED TopicCommandIntegrationTest > testDescribeAndListTopicsWithoutInternalTopics() PASSED AuthorizerIntegrationTest > testCreatePermissionOnClusterToReadFromNonExistentTopic(String) > kafka.api.AuthorizerIntegrationTest.testCreatePermissionOnClusterToReadFromNonExistentTopic(String)[1] PASSED DescribeConsumerGroupTest > testDescribeMembersWithMultiPartitionTopicAndMultipleConsumers() PASSED AuthorizerIntegrationTest > testCreatePermissionOnClusterToReadFromNonExistentTopic(String) > kafka.api.AuthorizerIntegrationTest.testCreatePermissionOnClusterToReadFromNonExistentTopic(String)[2] PASSED DescribeConsumerGroupTest > testDescribeExistingGroups() PASSED PlaintextAdminIntegrationTest > testElectUncleanLeadersForAllPartitions() PASSED AuthorizerIntegrationTest > testDescribeClusterClusterAuthorizedOperationsWithDescribeAndAlterCluster(String) > kafka.api.AuthorizerIntegrationTest.testDescribeClusterClusterAuthorizedOperationsWithDescribeAndAlterCluster(String)[1] PASSED DescribeConsumerGroupTest > testDescribeNonOffsetCommitGroup() PASSED AuthorizerIntegrationTest > testDescribeClusterClusterAuthorizedOperationsWithDescribeAndAlterCluster(String) > kafka.api.AuthorizerIntegrationTest.testDescribeClusterClusterAuthorizedOperationsWithDescribeAndAlterCluster(String)[2] PASSED TopicCommandIntegrationTest > testDescribeUnavailablePartitions() PASSED PlaintextEndToEndAuthorizationTest > testProduceConsumeWithPrefixedAcls() PASSED DescribeConsumerGroupTest > testDescribeNonExistingGroup() PASSED AuthorizerIntegrationTest > testUnauthorizedDeleteTopicsWithDescribe(String) > kafka.api.AuthorizerIntegrationTest.testUnauthorizedDeleteTopicsWithDescribe(String)[1] PASSED PlaintextAdminIntegrationTest > testLogStartOffsetAfterDeleteRecords() PASSED AuthorizerIntegrationTest > testUnauthorizedDeleteTopicsWithDescribe(String) > kafka.api.AuthorizerIntegrationTest.testUnauthorizedDeleteTopicsWithDescribe(String)[2] PASSED TopicCommandIntegrationTest > testCreateTopicDoesNotRetryThrottlingQuotaExceededException() PASSED AuthorizerIntegrationTest > shouldSuccessfullyAbortTransactionAfterTopicAuthorizationException(String) > kafka.api.AuthorizerIntegrationTest.shouldSuccessfullyAbortTransactionAfterTopicAuthorizationException(String)[1] PASSED PlaintextAdminIntegrationTest > testElectUncleanLeadersForOnePartition() PASSED AuthorizerIntegrationTest > shouldSuccessfullyAbortTransactionAfterTopicAuthorizationException(String) > kafka.api.AuthorizerIntegrationTest.shouldSuccessfullyAbortTransactionAfterTopicAuthorizationException(String)[2] PASSED PlaintextEndToEndAuthorizationTest > testProduceConsumeViaAssign() PASSED PlaintextAdminIntegrationTest > testDescribeTopicsWithIds() PASSED TopicCommandIntegrationTest > testCreateWithReplicaAssignment() PASSED AuthorizerIntegrationTest > testSendOffsetsWithNoConsumerGroupWriteAccess(String) > kafka.api.AuthorizerIntegrationTest.testSendOffsetsWithNoConsumerGroupWriteAccess(String)[1] PASSED DescribeConsumerGroupTest > testDescribeStateWithMultiPartitionTopicAndMultipleConsumers() PASSED PlaintextAdminIntegrationTest > testValidIncrementalAlterConfigs() PASSED AuthorizerIntegrationTest > testSendOffsetsWithNoConsumerGroupWriteAccess(String) > kafka.api.AuthorizerIntegrationTest.testSendOffsetsWithNoConsumerGroupWriteAccess(String)[2] PASSED DescribeConsumerGroupTest > testDescribeStateOfExistingGroupWithRoundRobinAssignor() PASSED TopicCommandIntegrationTest > testAlterWithInvalidPartitionCount() PASSED AuthorizerIntegrationTest > testPatternSubscriptionWithTopicDescribeOnlyAndGroupRead(String) > kafka.api.AuthorizerIntegrationTest.testPatternSubscriptionWithTopicDescribeOnlyAndGroupRead(String)[1] PASSED DescribeConsumerGroupTest > testDescribeOffsetsOfNonExistingGroup() PASSED AclCommandTest > testProducerConsumerCliWithAuthorizer() PASSED PlaintextAdminIntegrationTest > testInvalidIncrementalAlterConfigs() PASSED AuthorizerIntegrationTest > testPatternSubscriptionWithTopicDescribeOnlyAndGroupRead(String) > kafka.api.AuthorizerIntegrationTest.testPatternSubscriptionWithTopicDescribeOnlyAndGroupRead(String)[2] PASSED PlaintextEndToEndAuthorizationTest > testNoConsumeWithDescribeAclViaAssign() PASSED TopicCommandIntegrationTest > testCreate() PASSED DescribeConsumerGroupTest > testDescribeExistingGroupWithNoMembers() PASSED AuthorizerIntegrationTest > testDeleteGroupOffsetsWithNoAcl(String) > kafka.api.AuthorizerIntegrationTest.testDeleteGroupOffsetsWithNoAcl(String)[1] PASSED > Task :raft:integrationTest RaftEventSimulationTest > canElectNewLeaderAfterOldLeaderFailure PASSED > Task :core:integrationTest AuthorizerIntegrationTest > testDeleteGroupOffsetsWithNoAcl(String) > kafka.api.AuthorizerIntegrationTest.testDeleteGroupOffsetsWithNoAcl(String)[2] PASSED DescribeConsumerGroupTest > testDescribeAllExistingGroups() PASSED AuthorizerIntegrationTest > testDescribeGroupCliWithGroupDescribe(String) > kafka.api.AuthorizerIntegrationTest.testDescribeGroupCliWithGroupDescribe(String)[1] PASSED PlaintextAdminIntegrationTest > testSeekAfterDeleteRecords() PASSED AuthorizerIntegrationTest > testDescribeGroupCliWithGroupDescribe(String) > kafka.api.AuthorizerIntegrationTest.testDescribeGroupCliWithGroupDescribe(String)[2] PASSED TopicCommandIntegrationTest > testDescribeUnderMinIsrPartitionsMixed() PASSED PlaintextEndToEndAuthorizationTest > testProduceConsumeTopicAutoCreateTopicCreateAcl() PASSED AuthorizerIntegrationTest > testTransactionalProducerTopicAuthorizationExceptionInCommit(String) > kafka.api.AuthorizerIntegrationTest.testTransactionalProducerTopicAuthorizationExceptionInCommit(String)[1] PASSED AuthorizerIntegrationTest > testTransactionalProducerTopicAuthorizationExceptionInCommit(String) > kafka.api.AuthorizerIntegrationTest.testTransactionalProducerTopicAuthorizationExceptionInCommit(String)[2] PASSED TopicCommandIntegrationTest > testCreateWhenAlreadyExists() PASSED AuthorizerIntegrationTest > testOffsetFetchWithNoAccess(String) > kafka.api.AuthorizerIntegrationTest.testOffsetFetchWithNoAccess(String)[1] PASSED AclCommandTest > testAclCliWithAdminAPI() PASSED AuthorizerIntegrationTest > testOffsetFetchWithNoAccess(String) > kafka.api.AuthorizerIntegrationTest.testOffsetFetchWithNoAccess(String)[2] PASSED ConfigCommandTest > testEntityDefaultOptionWithDescribeBrokerLoggerIsNotAllowed() PASSED ConfigCommandTest > testNoSpecifiedEntityOptionWithDescribeBrokersInBootstrapServerIsAllowed() PASSED TopicCommandIntegrationTest > testDescribe() PASSED ConfigCommandTest > testScramCredentials() PASSED AuthorizerIntegrationTest > testConsumeUsingAssignWithNoAccess(String) > kafka.api.AuthorizerIntegrationTest.testConsumeUsingAssignWithNoAccess(String)[1] PASSED ConfigCommandTest > shouldExitWithNonZeroStatusOnUpdatingUnallowedConfigViaZk() PASSED PlaintextEndToEndAuthorizationTest > testProduceConsumeWithWildcardAcls() PASSED ConfigCommandTest > shouldFailIfBrokerEntityTypeIsNotAnIntegerUsingZookeeper() PASSED ConfigCommandTest > shouldFailIfUnrecognisedEntityTypeUsingZookeeper() PASSED ConfigCommandTest > shouldNotUpdateBrokerConfigIfMalformedConfigUsingZookeeper() PASSED AuthorizerIntegrationTest > testConsumeUsingAssignWithNoAccess(String) > kafka.api.AuthorizerIntegrationTest.testConsumeUsingAssignWithNoAccess(String)[2] PASSED ConfigCommandTest > shouldParseArgumentsForTopicsEntityType() PASSED ConfigCommandTest > shouldFailParseArgumentsForTopicsEntityTypeUsingZookeeper() PASSED TopicCommandIntegrationTest > testAlterAssignment() PASSED AuthorizerIntegrationTest > testProduceWithTopicRead(String) > kafka.api.AuthorizerIntegrationTest.testProduceWithTopicRead(String)[1] PASSED EndToEndClusterIdTest > testEndToEnd() PASSED AuthorizerIntegrationTest > testProduceWithTopicRead(String) > kafka.api.AuthorizerIntegrationTest.testProduceWithTopicRead(String)[2] PASSED ConfigCommandTest > shouldNotAllowAddBrokerQuotaConfigWhileBrokerUpUsingZookeeper() PASSED ConfigCommandTest > testOptionEntityTypeNames() PASSED ConfigCommandTest > shouldParseArgumentsForUsersEntityType() PASSED ConfigCommandTest > shouldFailIfMixedEntityTypeFlagsUsingZookeeper() PASSED AuthorizerIntegrationTest > testListOffsetsWithNoTopicAccess(String) > kafka.api.AuthorizerIntegrationTest.testListOffsetsWithNoTopicAccess(String)[1] PASSED ConfigCommandTest > shouldFailIfBrokerEntityTypeIsNotAnInteger() PASSED PlaintextEndToEndAuthorizationTest > testNoConsumeWithDescribeAclViaSubscribe() PASSED ConfigCommandTest > shouldAddBrokerDynamicConfig() PASSED AuthorizerIntegrationTest > testListOffsetsWithNoTopicAccess(String) > kafka.api.AuthorizerIntegrationTest.testListOffsetsWithNoTopicAccess(String)[2] PASSED ConfigCommandTest > shouldFailIfMixedEntityTypeFlags() PASSED ConfigCommandTest > shouldParseArgumentsForBrokersEntityTypeUsingZookeeper() PASSED ConfigCommandTest > shouldNotUpdateBrokerConfigIfMalformedEntityNameUsingZookeeper() PASSED ConfigCommandTest > testUserClientQuotaOpts() PASSED ConfigCommandTest > shouldAlterTopicConfig() PASSED PlaintextAdminIntegrationTest > testAdminClientHandlingBadIPWithoutTimeout() PASSED ConfigCommandTest > testQuotaConfigEntityUsingZookeeperNotAllowed() PASSED AuthorizerIntegrationTest > testDeleteGroupApiWithDeleteGroupAcl(String) > kafka.api.AuthorizerIntegrationTest.testDeleteGroupApiWithDeleteGroupAcl(String)[1] PASSED ConfigCommandTest > shouldFailParseArgumentsForClientsEntityTypeUsingZookeeper() PASSED ConfigCommandTest > shouldNotCreateUserScramCredentialConfigWithUnderMinimumIterationsUsingBootstrapServer() PASSED AuthorizerIntegrationTest > testDeleteGroupApiWithDeleteGroupAcl(String) > kafka.api.AuthorizerIntegrationTest.testDeleteGroupApiWithDeleteGroupAcl(String)[2] PASSED ConfigCommandTest > shouldExitWithNonZeroStatusOnBrokerCommandWithZkTlsConfigFile() PASSED ProducerSendWhileDeletionTest > testSendWithTopicDeletionMidWay() PASSED ConfigCommandTest > shouldAddClientConfig() PASSED ConfigCommandTest > shouldAddClientConfigUsingZookeeper() PASSED PlaintextAdminIntegrationTest > testCallInFlightTimeouts() PASSED ConfigCommandTest > shouldFailIfUnresolvableHostUsingZookeeper() PASSED ConfigCommandTest > testDescribeIpConfigs() PASSED ConfigCommandTest > shouldFailIfInvalidHost() PASSED AuthorizerIntegrationTest > testTopicIdAuthorization(String, boolean) > kafka.api.AuthorizerIntegrationTest.testTopicIdAuthorization(String, boolean)[1] PASSED ConfigCommandTest > shouldParseArgumentsForIpEntityType() PASSED DescribeConsumerGroupTest > testDescribeWithConsumersWithoutAssignedPartitions() PASSED ConfigCommandTest > shouldFailParseArgumentsForIpEntityTypeUsingZookeeper() PASSED ConfigCommandTest > shouldDescribeConfigBrokerWithoutEntityName() PASSED ConfigCommandTest > shouldSupportCommaSeparatedValuesUsingZookeeper() PASSED ConfigCommandTest > shouldAddDefaultBrokerDynamicConfig() PASSED ConfigCommandTest > shouldSupportDescribeBrokerBeforeBrokerUpUsingZookeeper() PASSED PlaintextAdminIntegrationTest > testNullConfigs() PASSED AuthorizerIntegrationTest > testTopicIdAuthorization(String, boolean) > kafka.api.AuthorizerIntegrationTest.testTopicIdAuthorization(String, boolean)[2] PASSED DescribeConsumerGroupTest > testDescribeGroupWithShortInitializationTimeout() PASSED ConfigCommandTest > testQuotaConfigEntity() PASSED ConfigCommandTest > shouldNotAlterScramClientConfigUsingBootstrapServer() PASSED ConfigCommandTest > shouldNotDeleteBrokerConfigWhileBrokerUpUsingZookeeper() PASSED ConfigCommandTest > shouldNotUpdateBrokerConfigIfMalformedBracketConfigUsingZookeeper() PASSED AuthorizerIntegrationTest > testTopicIdAuthorization(String, boolean) > kafka.api.AuthorizerIntegrationTest.testTopicIdAuthorization(String, boolean)[3] PASSED ConfigCommandTest > testUserClientQuotaOptsUsingZookeeperNotAllowed() PASSED ConfigCommandTest > testDescribeAllTopicConfig() PASSED ConfigCommandTest > shouldNotUpdateBrokerConfigIfMalformedBracketConfig() PASSED ConfigCommandTest > shouldAddBrokerLoggerConfig() PASSED PlaintextEndToEndAuthorizationTest > testNoConsumeWithoutDescribeAclViaAssign() PASSED DescribeConsumerGroupTest > testDescribeOffsetsWithMultiPartitionTopicAndMultipleConsumers() PASSED AuthorizerIntegrationTest > testTopicIdAuthorization(String, boolean) > kafka.api.AuthorizerIntegrationTest.testTopicIdAuthorization(String, boolean)[4] PASSED ConfigCommandTest > shouldFailIfAddAndAddFile() PASSED PlaintextAdminIntegrationTest > testDescribeConfigsForTopic() PASSED ConfigCommandTest > shouldFailIfUnrecognisedEntityType() PASSED ConfigCommandTest > shouldNotAlterNonQuotaNonScramUserOrClientConfigUsingBootstrapServer() PASSED ConfigCommandTest > shouldNotUpdateConfigIfNonExistingConfigIsDeletedUsingZookeeper() PASSED ConfigCommandTest > shouldFailIfInvalidHostUsingZookeeper() PASSED ConfigCommandTest > shouldExitWithNonZeroStatusOnZkCommandWithClientsEntity() PASSED DescribeConsumerGroupTest > testDescribeStateOfExistingGroupWithNoMembers() PASSED AuthorizerIntegrationTest > testMetadataClusterAuthorizedOperationsWithDescribeAndAlterCluster(String) > kafka.api.AuthorizerIntegrationTest.testMetadataClusterAuthorizedOperationsWithDescribeAndAlterCluster(String)[1] PASSED ConfigCommandTest > shouldFailIfShortBrokerEntityTypeIsNotAnIntegerUsingZookeeper() PASSED ConfigCommandTest > shouldNotDescribeUserScramCredentialsWithEntityDefaultUsingBootstrapServer() PASSED ConfigCommandTest > shouldNotUpdateBrokerConfigIfMalformedEntityName() PASSED AuthorizerIntegrationTest > testMetadataClusterAuthorizedOperationsWithDescribeAndAlterCluster(String) > kafka.api.AuthorizerIntegrationTest.testMetadataClusterAuthorizedOperationsWithDescribeAndAlterCluster(String)[2] PASSED ConfigCommandTest > shouldRaiseInvalidConfigurationExceptionWhenAddingInvalidBrokerLoggerConfig() PASSED DescribeConsumerGroupTest > testDescribeWithStateValue() PASSED ConfigCommandTest > testOptionEntityTypeNamesUsingZookeeper() PASSED ConfigCommandTest > shouldDescribeConfigSynonyms() PASSED ConfigCommandTest > shouldNotAllowDescribeBrokerWhileBrokerUpUsingZookeeper() PASSED ConfigCommandTest > testAlterIpConfig() PASSED ConfigCommandTest > shouldNotAlterNonQuotaIpConfigsUsingBootstrapServer() PASSED UserClientIdQuotaTest > testQuotaOverrideDelete() PASSED ConfigCommandTest > shouldParseArgumentsForUsersEntityTypeUsingZookeeper() PASSED AuthorizerIntegrationTest > testDeleteRecordsWithWildCardAuth(String) > kafka.api.AuthorizerIntegrationTest.testDeleteRecordsWithWildCardAuth(String)[1] PASSED ConfigCommandTest > testEntityDefaultOptionWithAlterBrokerLoggerIsNotAllowed() PASSED ConfigCommandTest > shouldNotUpdateBrokerConfigIfMalformedConfig() PASSED ConfigCommandTest > testParseConfigsToBeAddedForAddConfigFile() PASSED ConfigCommandTest > shouldParseArgumentsForBrokerLoggersEntityType() PASSED AdminClientWithPoliciesIntegrationTest > testInvalidAlterConfigs() PASSED ConfigCommandTest > shouldNotUpdateConfigIfNonExistingConfigIsDeleted() PASSED PlaintextEndToEndAuthorizationTest > testNoGroupAcl() PASSED ConfigCommandTest > shouldFailIfShortBrokerEntityTypeIsNotAnInteger() PASSED AuthorizerIntegrationTest > testDeleteRecordsWithWildCardAuth(String) > kafka.api.AuthorizerIntegrationTest.testDeleteRecordsWithWildCardAuth(String)[2] PASSED ConfigCommandTest > testDescribeAllBrokerConfig() PASSED ConfigCommandTest > shouldExitWithNonZeroStatusOnBrokerCommandError() PASSED ConfigCommandTest > shouldParseArgumentsForBrokersEntityType() PASSED ConfigCommandTest > shouldExitWithNonZeroStatusAlterUserQuotaWithoutEntityName() PASSED AuthorizerIntegrationTest > testFetchFollowerRequest(String) > kafka.api.AuthorizerIntegrationTest.testFetchFollowerRequest(String)[1] PASSED ConfigCommandTest > testDynamicBrokerConfigUpdateUsingZooKeeper() PASSED ConfigCommandTest > testNoSpecifiedEntityOptionWithDescribeBrokersInZKIsAllowed() PASSED AdminClientWithPoliciesIntegrationTest > testValidAlterConfigs() PASSED ConfigCommandTest > testQuotaDescribeEntities() PASSED AuthorizerIntegrationTest > testFetchFollowerRequest(String) > kafka.api.AuthorizerIntegrationTest.testFetchFollowerRequest(String)[2] PASSED ConfigCommandTest > shouldExitWithNonZeroStatusOnZkCommandAlterUserQuota() PASSED ConfigCommandTest > shouldExitWithNonZeroStatusOnZkCommandWithIpsEntity() PASSED ConfigCommandTest > shouldParseArgumentsForClientsEntityType() PASSED ConfigCommandTest > testDescribeAllBrokerConfigBootstrapServerRequired() PASSED ConfigCommandTest > shouldExitWithNonZeroStatusOnZkCommandWithTopicsEntity() PASSED UserClientIdQuotaTest > testThrottledRequest() PASSED ConfigCommandTest > shouldAddIpConfigsUsingZookeeper() PASSED AuthorizerIntegrationTest > testDeleteGroupOffsetsWithoutDeleteAcl(String) > kafka.api.AuthorizerIntegrationTest.testDeleteGroupOffsetsWithoutDeleteAcl(String)[1] PASSED ConfigCommandTest > shouldFailIfUnresolvableHost() PASSED SaslOAuthBearerSslEndToEndAuthorizationTest > testNoConsumeWithoutDescribeAclViaSubscribe() PASSED ConfigCommandTest > shouldAlterTopicConfigFile() PASSED ConfigCommandTest > shouldNotAlterUserScramCredentialAndClientQuotaConfigsSimultaneouslyUsingBootstrapServer() PASSED PlaintextEndToEndAuthorizationTest > testNoProduceWithDescribeAcl(boolean) > kafka.api.PlaintextEndToEndAuthorizationTest.testNoProduceWithDescribeAcl(boolean)[1] PASSED AuthorizerIntegrationTest > testDeleteGroupOffsetsWithoutDeleteAcl(String) > kafka.api.AuthorizerIntegrationTest.testDeleteGroupOffsetsWithoutDeleteAcl(String)[2] PASSED MinIsrConfigTest > testDeaultKafkaConfig(String) > kafka.integration.MinIsrConfigTest.testDeaultKafkaConfig(String)[1] PASSED ConfigCommandTest > shouldExitWithNonZeroStatusOnArgError() PASSED AdminClientWithPoliciesIntegrationTest > testInvalidAlterConfigsDueToPolicy() PASSED ConfigCommandTest > shouldAddTopicConfigUsingZookeeper() PASSED MinIsrConfigTest > testDeaultKafkaConfig(String) > kafka.integration.MinIsrConfigTest.testDeaultKafkaConfig(String)[2] PASSED AuthorizerIntegrationTest > testIdempotentProducerNoIdempotentWriteAclInProduce(String) > kafka.api.AuthorizerIntegrationTest.testIdempotentProducerNoIdempotentWriteAclInProduce(String)[1] PASSED PlaintextAdminIntegrationTest > testConsumerGroups() PASSED DescribeClusterRequestTest > testDescribeClusterRequestExcludingClusterAuthorizedOperations() PASSED AuthorizerIntegrationTest > testIdempotentProducerNoIdempotentWriteAclInProduce(String) > kafka.api.AuthorizerIntegrationTest.testIdempotentProducerNoIdempotentWriteAclInProduce(String)[2] PASSED LogAppendTimeTest > testProduceConsume() PASSED PlaintextAdminIntegrationTest > testElectUncleanLeadersWhenNoLiveBrokers() PASSED AuthorizerIntegrationTest > testDeleteGroupOffsetsWithAcl(String) > kafka.api.AuthorizerIntegrationTest.testDeleteGroupOffsetsWithAcl(String)[1] PASSED DescribeClusterRequestTest > testDescribeClusterRequestIncludingClusterAuthorizedOperations() PASSED PlaintextEndToEndAuthorizationTest > testNoProduceWithDescribeAcl(boolean) > kafka.api.PlaintextEndToEndAuthorizationTest.testNoProduceWithDescribeAcl(boolean)[2] PASSED AuthorizerIntegrationTest > testDeleteGroupOffsetsWithAcl(String) > kafka.api.AuthorizerIntegrationTest.testDeleteGroupOffsetsWithAcl(String)[2] PASSED PlaintextAdminIntegrationTest > testCreateExistingTopicsThrowTopicExistsException() PASSED RackAwareAutoTopicCreationTest > testAutoCreateTopic() PASSED SaslOAuthBearerSslEndToEndAuthorizationTest > testProduceConsumeWithPrefixedAcls() PASSED AuthorizerIntegrationTest > testCreatePermissionOnTopicToReadFromNonExistentTopic(String) > kafka.api.AuthorizerIntegrationTest.testCreatePermissionOnTopicToReadFromNonExistentTopic(String)[1] PASSED DescribeUserScramCredentialsRequestNotAuthorizedTest > testDescribeNotAuthorized() PASSED PlaintextProducerSendTest > testSendNonCompressedMessageWithCreateTime() PASSED TransactionsWithMaxInFlightOneTest > testTransactionalProducerSingleBrokerMaxInFlightOne() PASSED AuthorizerIntegrationTest > testCreatePermissionOnTopicToReadFromNonExistentTopic(String) > kafka.api.AuthorizerIntegrationTest.testCreatePermissionOnTopicToReadFromNonExistentTopic(String)[2] PASSED ZkNodeChangeNotificationListenerTest > testProcessNotification() PASSED PlaintextProducerSendTest > testClose() PASSED FetchRequestDownConversionConfigTest > testV1FetchWithDownConversionDisabled() PASSED ZkNodeChangeNotificationListenerTest > testSwallowsProcessorException() PASSED AuthorizerIntegrationTest > testPatternSubscriptionMatchingInternalTopicWithDescribeOnlyPermission(String) > kafka.api.AuthorizerIntegrationTest.testPatternSubscriptionMatchingInternalTopicWithDescribeOnlyPermission(String)[1] PASSED FetchRequestDownConversionConfigTest > testV1FetchFromReplica() PASSED PlaintextProducerSendTest > testFlush() PASSED PlaintextEndToEndAuthorizationTest > testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl(boolean) > kafka.api.PlaintextEndToEndAuthorizationTest.testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl(boolean)[1] PASSED MetricsDuringTopicCreationDeletionTest > testMetricsDuringTopicCreateDelete() PASSED AuthorizerInterfaceDefaultTest > testAuthorizeByResourceTypeWithAllHostAce() PASSED FetchRequestDownConversionConfigTest > testLatestFetchWithDownConversionDisabled() PASSED SaslOAuthBearerSslEndToEndAuthorizationTest > testProduceConsumeViaAssign() PASSED AuthorizerInterfaceDefaultTest > testAuthorizeByResourceTypeIsolationUnrelatedDenyWontDominateAllow() PASSED AuthorizerIntegrationTest > testPatternSubscriptionMatchingInternalTopicWithDescribeOnlyPermission(String) > kafka.api.AuthorizerIntegrationTest.testPatternSubscriptionMatchingInternalTopicWithDescribeOnlyPermission(String)[2] PASSED AuthorizerInterfaceDefaultTest > testAuthorizeByResourceTypeWildcardResourceDenyDominate() PASSED PlaintextProducerSendTest > testSendToPartition() PASSED AuthorizerInterfaceDefaultTest > testAuthorizeByResourceTypeWithAllOperationAce() PASSED AuthorizerIntegrationTest > testSimpleConsumeWithOffsetLookupAndNoGroupAccess(String) > kafka.api.AuthorizerIntegrationTest.testSimpleConsumeWithOffsetLookupAndNoGroupAccess(String)[1] PASSED AuthorizerInterfaceDefaultTest > testAuthorzeByResourceTypeSuperUserHasAccess() PASSED FetchRequestDownConversionConfigTest > testV1FetchWithTopicLevelOverrides() PASSED AuthorizerIntegrationTest > testSimpleConsumeWithOffsetLookupAndNoGroupAccess(String) > kafka.api.AuthorizerIntegrationTest.testSimpleConsumeWithOffsetLookupAndNoGroupAccess(String)[2] PASSED AuthorizerInterfaceDefaultTest > testAuthorizeByResourceTypePrefixedResourceDenyDominate() PASSED > Task :raft:integrationTest RaftEventSimulationTest > canElectNewLeaderAfterOldLeaderPartitionedAway PASSED > Task :core:integrationTest AuthorizerIntegrationTest > testDeleteTopicsWithWildCardAuth(String) > kafka.api.AuthorizerIntegrationTest.testDeleteTopicsWithWildCardAuth(String)[1] PASSED PlaintextProducerSendTest > testSendOffset() PASSED FetchRequestDownConversionConfigTest > testV12WithDownConversionDisabled() PASSED AuthorizerIntegrationTest > testDeleteTopicsWithWildCardAuth(String) > kafka.api.AuthorizerIntegrationTest.testDeleteTopicsWithWildCardAuth(String)[2] PASSED AuthorizerInterfaceDefaultTest > testAuthorizeByResourceTypeMultipleAddAndRemove() PASSED PlaintextEndToEndAuthorizationTest > testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl(boolean) > kafka.api.PlaintextEndToEndAuthorizationTest.testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl(boolean)[2] PASSED AuthorizerInterfaceDefaultTest > testAuthorizeByResourceTypeDenyTakesPrecedence() PASSED AuthorizerInterfaceDefaultTest > testAuthorizeByResourceTypeWithAllPrincipalAce() PASSED AuthorizerIntegrationTest > testAuthorizeByResourceTypeIsolationUnrelatedDenyWontDominateAllow(String) > kafka.api.AuthorizerIntegrationTest.testAuthorizeByResourceTypeIsolationUnrelatedDenyWontDominateAllow(String)[1] PASSED SaslOAuthBearerSslEndToEndAuthorizationTest > testNoConsumeWithDescribeAclViaAssign() PASSED PlaintextProducerSendTest > testSendCompressedMessageWithCreateTime() PASSED AuthorizerIntegrationTest > testAuthorizeByResourceTypeIsolationUnrelatedDenyWontDominateAllow(String) > kafka.api.AuthorizerIntegrationTest.testAuthorizeByResourceTypeIsolationUnrelatedDenyWontDominateAllow(String)[2] PASSED DelegationTokenManagerTest > testPeriodicTokenExpiry() PASSED DelegationTokenManagerTest > testTokenRequestsWithDelegationTokenDisabled() PASSED DelegationTokenManagerTest > testDescribeToken() PASSED AuthorizerIntegrationTest > testConsumeWithTopicDescribe(String) > kafka.api.AuthorizerIntegrationTest.testConsumeWithTopicDescribe(String)[1] PASSED PlaintextEndToEndAuthorizationTest > testProduceConsumeViaSubscribe() PASSED DelegationTokenManagerTest > testCreateToken() PASSED DelegationTokenManagerTest > testExpireToken() PASSED AuthorizerIntegrationTest > testConsumeWithTopicDescribe(String) > kafka.api.AuthorizerIntegrationTest.testConsumeWithTopicDescribe(String)[2] PASSED DelegationTokenManagerTest > testRenewToken() PASSED WARNING: An illegal reflective access operation has occurred WARNING: Illegal reflective access by kafka.security.minikdc.MiniKdc (file:/home/ubuntu/anant/kafka/core/build/classes/scala/test/) to method sun.security.krb5.Config.refresh() WARNING: Please consider reporting this to the maintainers of kafka.security.minikdc.MiniKdc WARNING: Use --illegal-access=warn to enable warnings of further illegal reflective access operations WARNING: All illegal access operations will be denied in a future release DelegationTokenManagerTest > testRemoveTokenHmac() PASSED DeleteTopicTest > testDeleteTopicWithCleaner() PASSED DeleteTopicsRequestWithDeletionDisabledTest > testDeleteRecordsRequest() PASSED AuthorizerIntegrationTest > shouldThrowTransactionalIdAuthorizationExceptionWhenNoTransactionAccessDuringSend(String) > kafka.api.AuthorizerIntegrationTest.shouldThrowTransactionalIdAuthorizationExceptionWhenNoTransactionAccessDuringSend(String)[1] PASSED PlaintextProducerSendTest > testCloseWithZeroTimeoutFromCallerThread() PASSED PlaintextEndToEndAuthorizationTest > testListenerName() PASSED AuthorizerIntegrationTest > shouldThrowTransactionalIdAuthorizationExceptionWhenNoTransactionAccessDuringSend(String) > kafka.api.AuthorizerIntegrationTest.shouldThrowTransactionalIdAuthorizationExceptionWhenNoTransactionAccessDuringSend(String)[2] PASSED DescribeQuorumRequestTest > testDescribeQuorum() > kafka.server.DescribeQuorumRequestTest.testDescribeQuorum()[1] PASSED SaslOAuthBearerSslEndToEndAuthorizationTest > testProduceConsumeTopicAutoCreateTopicCreateAcl() PASSED AuthorizerIntegrationTest > testOffsetFetchWithNoTopicAccess(String) > kafka.api.AuthorizerIntegrationTest.testOffsetFetchWithNoTopicAccess(String)[1] PASSED DeleteTopicTest > testResumeDeleteTopicOnControllerFailover() PASSED DescribeQuorumRequestTest > testDescribeQuorumNotSupportedByZkBrokers() > kafka.server.DescribeQuorumRequestTest.testDescribeQuorumNotSupportedByZkBrokers()[1] PASSED AuthorizerIntegrationTest > testOffsetFetchWithNoTopicAccess(String) > kafka.api.AuthorizerIntegrationTest.testOffsetFetchWithNoTopicAccess(String)[2] PASSED EdgeCaseRequestTest > testInvalidApiVersionRequest() PASSED PlaintextProducerSendTest > testCloseWithZeroTimeoutFromSenderThread() PASSED EdgeCaseRequestTest > testMalformedHeaderRequest() PASSED AuthorizerIntegrationTest > testCreatePermissionOnTopicToWriteToNonExistentTopic(String) > kafka.api.AuthorizerIntegrationTest.testCreatePermissionOnTopicToWriteToNonExistentTopic(String)[1] PASSED DeleteTopicTest > testResumeDeleteTopicWithRecoveredFollower() PASSED MultipleListenersWithDefaultJaasContextTest > testProduceConsume() PASSED EdgeCaseRequestTest > testProduceRequestWithNullClientId() PASSED AuthorizerIntegrationTest > testCreatePermissionOnTopicToWriteToNonExistentTopic(String) > kafka.api.AuthorizerIntegrationTest.testCreatePermissionOnTopicToWriteToNonExistentTopic(String)[2] PASSED EdgeCaseRequestTest > testInvalidApiKeyRequest() PASSED WARNING: An illegal reflective access operation has occurred WARNING: Illegal reflective access by kafka.security.minikdc.MiniKdc (file:/home/ubuntu/anant/kafka/core/build/classes/scala/test/) to method sun.security.krb5.Config.refresh() WARNING: Please consider reporting this to the maintainers of kafka.security.minikdc.MiniKdc WARNING: Use --illegal-access=warn to enable warnings of further illegal reflective access operations WARNING: All illegal access operations will be denied in a future release AuthorizerIntegrationTest > testCommitWithNoTopicAccess(String) > kafka.api.AuthorizerIntegrationTest.testCommitWithNoTopicAccess(String)[1] PASSED EdgeCaseRequestTest > testHeaderOnlyRequest() PASSED SaslOAuthBearerSslEndToEndAuthorizationTest > testProduceConsumeWithWildcardAcls() PASSED DeleteTopicTest > testDeleteTopicAlreadyMarkedAsDeleted() PASSED FinalizedFeatureChangeListenerTest > testFeatureZNodeDeleteNotificationProcessing() PASSED AuthorizerIntegrationTest > testCommitWithNoTopicAccess(String) > kafka.api.AuthorizerIntegrationTest.testCommitWithNoTopicAccess(String)[2] PASSED AuthorizerIntegrationTest > testMetadataWithNoTopicAccess(String) > kafka.api.AuthorizerIntegrationTest.testMetadataWithNoTopicAccess(String)[1] PASSED ProduceRequestTest > testSimpleProduceRequest() PASSED AuthorizerIntegrationTest > testMetadataWithNoTopicAccess(String) > kafka.api.AuthorizerIntegrationTest.testMetadataWithNoTopicAccess(String)[2] PASSED DeleteTopicTest > testIncreasePartitionCountDuringDeleteTopic() PASSED AuthorizerIntegrationTest > testProduceWithNoTopicAccess(String) > kafka.api.AuthorizerIntegrationTest.testProduceWithNoTopicAccess(String)[1] PASSED ProduceRequestTest > testCorruptLz4ProduceRequest() PASSED AuthorizerIntegrationTest > testProduceWithNoTopicAccess(String) > kafka.api.AuthorizerIntegrationTest.testProduceWithNoTopicAccess(String)[2] PASSED SaslSslAdminIntegrationTest > testCreateDeleteTopics() PASSED ProduceRequestTest > testProduceToNonReplica() PASSED AuthorizerIntegrationTest > testProduceWithTopicWrite(String) > kafka.api.AuthorizerIntegrationTest.testProduceWithTopicWrite(String)[1] PASSED DeleteTopicTest > testPartitionReassignmentDuringDeleteTopic() PASSED AuthorizerIntegrationTest > testProduceWithTopicWrite(String) > kafka.api.AuthorizerIntegrationTest.testProduceWithTopicWrite(String)[2] PASSED PlaintextProducerSendTest > testSendBeforeAndAfterPartitionExpansion() PASSED SaslOAuthBearerSslEndToEndAuthorizationTest > testNoConsumeWithDescribeAclViaSubscribe() PASSED ProduceRequestTest > testZSTDProduceRequest() PASSED AuthorizerIntegrationTest > testCreatePartitionsWithWildCardAuth(String) > kafka.api.AuthorizerIntegrationTest.testCreatePartitionsWithWildCardAuth(String)[1] PASSED DeleteTopicTest > testDeleteNonExistingTopic() PASSED AuthorizerIntegrationTest > testCreatePartitionsWithWildCardAuth(String) > kafka.api.AuthorizerIntegrationTest.testCreatePartitionsWithWildCardAuth(String)[2] PASSED PlaintextProducerSendTest > testSendCompressedMessageWithLogAppendTime() PASSED ProduceRequestTest > testProduceWithInvalidTimestamp() PASSED AuthorizerIntegrationTest > testAuthorizeByResourceTypeWildcardResourceDenyDominate(String) > kafka.api.AuthorizerIntegrationTest.testAuthorizeByResourceTypeWildcardResourceDenyDominate(String)[1] PASSED DeleteTopicTest > testRecreateTopicAfterDeletion() PASSED PlaintextProducerSendTest > testNonBlockingProducer() PASSED ServerShutdownTest > testCleanShutdownAfterFailedStartup(String) > kafka.server.ServerShutdownTest.testCleanShutdownAfterFailedStartup(String)[1] PASSED AuthorizerIntegrationTest > testAuthorizeByResourceTypeWildcardResourceDenyDominate(String) > kafka.api.AuthorizerIntegrationTest.testAuthorizeByResourceTypeWildcardResourceDenyDominate(String)[2] PASSED DeleteTopicTest > testDisableDeleteTopic() PASSED AuthorizerIntegrationTest > testUnauthorizedDeleteTopicsWithoutDescribe(String) > kafka.api.AuthorizerIntegrationTest.testUnauthorizedDeleteTopicsWithoutDescribe(String)[1] PASSED PlaintextProducerSendTest > testAutoCreateTopic() PASSED AuthorizerIntegrationTest > testUnauthorizedDeleteTopicsWithoutDescribe(String) > kafka.api.AuthorizerIntegrationTest.testUnauthorizedDeleteTopicsWithoutDescribe(String)[2] PASSED ServerShutdownTest > testCleanShutdownAfterFailedStartup(String) > kafka.server.ServerShutdownTest.testCleanShutdownAfterFailedStartup(String)[2] PASSED ServerShutdownTest > testConsecutiveShutdown(String) > kafka.server.ServerShutdownTest.testConsecutiveShutdown(String)[1] PASSED DeleteTopicTest > testAddPartitionDuringDeleteTopic() PASSED SaslSslAdminIntegrationTest > testAuthorizedOperations() PASSED PlaintextProducerSendTest > testSendRecordBatchWithMaxRequestSizeAndHigher() PASSED AuthorizerIntegrationTest > testDescribeGroupApiWithGroupDescribe(String) > kafka.api.AuthorizerIntegrationTest.testDescribeGroupApiWithGroupDescribe(String)[1] PASSED ServerShutdownTest > testConsecutiveShutdown(String) > kafka.server.ServerShutdownTest.testConsecutiveShutdown(String)[2] PASSED ServerShutdownTest > testControllerShutdownDuringSend() PASSED AuthorizerIntegrationTest > testDescribeGroupApiWithGroupDescribe(String) > kafka.api.AuthorizerIntegrationTest.testDescribeGroupApiWithGroupDescribe(String)[2] PASSED SaslOAuthBearerSslEndToEndAuthorizationTest > testNoConsumeWithoutDescribeAclViaAssign() PASSED PlaintextProducerSendTest > testSendWithInvalidCreateTime() PASSED DeleteTopicTest > testDeleteTopicWithAllAliveReplicas() PASSED ServerShutdownTest > testCleanShutdownAfterFailedStartupDueToCorruptLogs(String) > kafka.server.ServerShutdownTest.testCleanShutdownAfterFailedStartupDueToCorruptLogs(String)[1] PASSED AuthorizerIntegrationTest > testAuthorizationWithTopicNotExisting(String) > kafka.api.AuthorizerIntegrationTest.testAuthorizationWithTopicNotExisting(String)[1] PASSED ServerShutdownTest > testCleanShutdownAfterFailedStartupDueToCorruptLogs(String) > kafka.server.ServerShutdownTest.testCleanShutdownAfterFailedStartupDueToCorruptLogs(String)[2] PASSED PlaintextProducerSendTest > testBatchSizeZero() PASSED DeleteTopicTest > testDeleteTopicDuringAddPartition() PASSED PlaintextProducerSendTest > testWrongSerializer() PASSED ServerShutdownTest > testCleanShutdown(String) > kafka.server.ServerShutdownTest.testCleanShutdown(String)[1] PASSED PlaintextProducerSendTest > testSendNonCompressedMessageWithLogAppendTime() PASSED SaslOAuthBearerSslEndToEndAuthorizationTest > testNoGroupAcl() PASSED ServerShutdownTest > testCleanShutdown(String) > kafka.server.ServerShutdownTest.testCleanShutdown(String)[2] PASSED SaslSslAdminIntegrationTest > testAclDescribe() PASSED DeleteTopicTest > testDeletingPartiallyDeletedTopic() PASSED ServerShutdownTest > testCleanShutdownWithZkUnavailable(String) > kafka.server.ServerShutdownTest.testCleanShutdownWithZkUnavailable(String)[1] PASSED ServerShutdownTest > testCleanShutdownWithKRaftControllerUnavailable(String) > kafka.server.ServerShutdownTest.testCleanShutdownWithKRaftControllerUnavailable(String)[1] PASSED AuthorizerIntegrationTest > testAuthorizationWithTopicNotExisting(String) > kafka.api.AuthorizerIntegrationTest.testAuthorizationWithTopicNotExisting(String)[2] PASSED GetOffsetShellTest > testTopicPartitionsFlagWithTopicFlagCauseExit() PASSED ClientIdQuotaTest > testProducerConsumerOverrideLowerQuota() PASSED AuthorizerIntegrationTest > shouldNotIncludeUnauthorizedTopicsInDescribeTransactionsResponse(String) > kafka.api.AuthorizerIntegrationTest.shouldNotIncludeUnauthorizedTopicsInDescribeTransactionsResponse(String)[1] PASSED GetOffsetShellTest > testTopicPatternArgWithPartitionsArg() PASSED AuthorizerIntegrationTest > shouldNotIncludeUnauthorizedTopicsInDescribeTransactionsResponse(String) > kafka.api.AuthorizerIntegrationTest.shouldNotIncludeUnauthorizedTopicsInDescribeTransactionsResponse(String)[2] PASSED SaslOAuthBearerSslEndToEndAuthorizationTest > testNoProduceWithDescribeAcl(boolean) > kafka.api.SaslOAuthBearerSslEndToEndAuthorizationTest.testNoProduceWithDescribeAcl(boolean)[1] PASSED AuthorizerIntegrationTest > testListOffsetsWithTopicDescribe(String) > kafka.api.AuthorizerIntegrationTest.testListOffsetsWithTopicDescribe(String)[1] PASSED GetOffsetShellTest > testTopicNameArg() PASSED WARNING: An illegal reflective access operation has occurred WARNING: Illegal reflective access by kafka.security.minikdc.MiniKdc (file:/home/ubuntu/anant/kafka/core/build/classes/scala/test/) to method sun.security.krb5.Config.refresh() WARNING: Please consider reporting this to the maintainers of kafka.security.minikdc.MiniKdc WARNING: Use --illegal-access=warn to enable warnings of further illegal reflective access operations WARNING: All illegal access operations will be denied in a future release AuthorizerIntegrationTest > testListOffsetsWithTopicDescribe(String) > kafka.api.AuthorizerIntegrationTest.testListOffsetsWithTopicDescribe(String)[2] PASSED GetOffsetShellTest > testTopicPatternArg() PASSED SaslSslAdminIntegrationTest > testLegacyAclOpsNeverAffectOrReturnPrefixed() PASSED AuthorizerIntegrationTest > testListGroupApiWithAndWithoutListGroupAcls(String) > kafka.api.AuthorizerIntegrationTest.testListGroupApiWithAndWithoutListGroupAcls(String)[1] PASSED ClientIdQuotaTest > testProducerConsumerOverrideUnthrottled() PASSED GetOffsetShellTest > testTopicPartitionsNotFoundForNonExistentTopic() PASSED SaslOAuthBearerSslEndToEndAuthorizationTest > testNoProduceWithDescribeAcl(boolean) > kafka.api.SaslOAuthBearerSslEndToEndAuthorizationTest.testNoProduceWithDescribeAcl(boolean)[2] PASSED AuthorizerIntegrationTest > testListGroupApiWithAndWithoutListGroupAcls(String) > kafka.api.AuthorizerIntegrationTest.testListGroupApiWithAndWithoutListGroupAcls(String)[2] PASSED GetOffsetShellTest > testPartitionsArg() PASSED AuthorizerIntegrationTest > testCreatePermissionMetadataRequestAutoCreate(String) > kafka.api.AuthorizerIntegrationTest.testCreatePermissionMetadataRequestAutoCreate(String)[1] PASSED AuthorizerIntegrationTest > testCreatePermissionMetadataRequestAutoCreate(String) > kafka.api.AuthorizerIntegrationTest.testCreatePermissionMetadataRequestAutoCreate(String)[2] PASSED GetOffsetShellTest > testTopicPartitionsArgWithInternalExcluded() PASSED > Task :raft:integrationTest RaftEventSimulationTest > canMakeProgressAfterBackToBackLeaderFailures PASSED RaftEventSimulationTest > canRecoverFromSingleNodeCommittedDataLoss PASSED RaftEventSimulationTest > canRecoverAfterAllNodesKilled PASSED RaftEventSimulationTest > canElectInitialLeader PASSED > Task :core:integrationTest AuthorizerIntegrationTest > testDeleteGroupApiWithNoDeleteGroupAcl2(String) > kafka.api.AuthorizerIntegrationTest.testDeleteGroupApiWithNoDeleteGroupAcl2(String)[1] PASSED GetOffsetShellTest > testNoFilterOptions() PASSED AuthorizerIntegrationTest > testDeleteGroupApiWithNoDeleteGroupAcl2(String) > kafka.api.AuthorizerIntegrationTest.testDeleteGroupApiWithNoDeleteGroupAcl2(String)[2] PASSED GetOffsetShellTest > testTopicPartitionsFlagWithPartitionsFlagCauseExit() PASSED AuthorizerIntegrationTest > testConsumeWithTopicAndGroupRead(String) > kafka.api.AuthorizerIntegrationTest.testConsumeWithTopicAndGroupRead(String)[1] PASSED SaslSslAdminIntegrationTest > testCreateTopicsResponseMetadataAndConfig() PASSED AuthorizerIntegrationTest > testConsumeWithTopicAndGroupRead(String) > kafka.api.AuthorizerIntegrationTest.testConsumeWithTopicAndGroupRead(String)[2] PASSED FinalizedFeatureChangeListenerTest > testCacheUpdateWaitFailsForUnreachableVersion() PASSED SaslGssapiSslEndToEndAuthorizationTest > testNoConsumeWithoutDescribeAclViaSubscribe() PASSED FinalizedFeatureChangeListenerTest > testInitFailureDueToInvalidWaitTime() PASSED GetOffsetShellTest > testTopicPartitionsArg() PASSED AuthorizerIntegrationTest > testPatternSubscriptionNotMatchingInternalTopic(String) > kafka.api.AuthorizerIntegrationTest.testPatternSubscriptionNotMatchingInternalTopic(String)[1] PASSED SaslOAuthBearerSslEndToEndAuthorizationTest > testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl(boolean) > kafka.api.SaslOAuthBearerSslEndToEndAuthorizationTest.testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl(boolean)[1] PASSED GetOffsetShellTest > testInternalExcluded() PASSED AuthorizerIntegrationTest > testPatternSubscriptionNotMatchingInternalTopic(String) > kafka.api.AuthorizerIntegrationTest.testPatternSubscriptionNotMatchingInternalTopic(String)[2] PASSED GetOffsetShellTest > testTopicPartitionsNotFoundForNonMatchingTopicPartitionPattern() PASSED AuthorizerIntegrationTest > shouldSendSuccessfullyWhenIdempotentAndHasCorrectACL(String) > kafka.api.AuthorizerIntegrationTest.shouldSendSuccessfullyWhenIdempotentAndHasCorrectACL(String)[1] PASSED AuthorizerIntegrationTest > shouldSendSuccessfullyWhenIdempotentAndHasCorrectACL(String) > kafka.api.AuthorizerIntegrationTest.shouldSendSuccessfullyWhenIdempotentAndHasCorrectACL(String)[2] PASSED GetOffsetShellTest > testTopicPartitionsNotFoundForExcludedInternalTopic() PASSED KafkaZkClientTest > testZNodeChangeHandlerForDataChange() PASSED AuthorizerIntegrationTest > testAuthorizeByResourceTypePrefixedResourceDenyDominate(String) > kafka.api.AuthorizerIntegrationTest.testAuthorizeByResourceTypePrefixedResourceDenyDominate(String)[1] PASSED KafkaZkClientTest > testCreateAndGetTopicPartitionStatesRaw() PASSED SaslSslAdminIntegrationTest > testAttemptToCreateInvalidAcls() PASSED FinalizedFeatureChangeListenerTest > testInitFailureDueToFeatureIncompatibility() PASSED KafkaZkClientTest > testLogDirGetters() PASSED AuthorizerIntegrationTest > testAuthorizeByResourceTypePrefixedResourceDenyDominate(String) > kafka.api.AuthorizerIntegrationTest.testAuthorizeByResourceTypePrefixedResourceDenyDominate(String)[2] PASSED FinalizedFeatureChangeListenerTest > testInitSuccessAndNotificationSuccess() PASSED FinalizedFeatureChangeListenerTest > testNotificationFailureDueToFeatureIncompatibility() PASSED KafkaZkClientTest > testSetGetAndDeletePartitionReassignment() PASSED FinalizedFeatureChangeListenerTest > testFeatureZNodeDisablingNotificationProcessing() PASSED KafkaZkClientTest > testIsrChangeNotificationsDeletion() PASSED AuthorizerIntegrationTest > testAuthorizeByResourceTypeMultipleAddAndRemove(String) > kafka.api.AuthorizerIntegrationTest.testAuthorizeByResourceTypeMultipleAddAndRemove(String)[1] PASSED ClientIdQuotaTest > testThrottledProducerConsumer() PASSED KafkaZkClientTest > testGetDataAndVersion() PASSED KafkaMetricReporterClusterIdTest > testClusterIdPresent() PASSED KafkaZkClientTest > testGetChildren() PASSED KafkaMetricsReporterTest > testMetricsContextNamespacePresent() PASSED KafkaZkClientTest > testSetAndGetConsumerOffset() PASSED AuthorizerIntegrationTest > testAuthorizeByResourceTypeMultipleAddAndRemove(String) > kafka.api.AuthorizerIntegrationTest.testAuthorizeByResourceTypeMultipleAddAndRemove(String)[2] PASSED SaslOAuthBearerSslEndToEndAuthorizationTest > testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl(boolean) > kafka.api.SaslOAuthBearerSslEndToEndAuthorizationTest.testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl(boolean)[2] PASSED SaslGssapiSslEndToEndAuthorizationTest > testProduceConsumeWithPrefixedAcls() PASSED KafkaZkClientTest > testClusterIdMethods() PASSED KafkaZkClientTest > testEntityConfigManagementMethods() PASSED AuthorizerIntegrationTest > testConsumeWithTopicWrite(String) > kafka.api.AuthorizerIntegrationTest.testConsumeWithTopicWrite(String)[1] PASSED KafkaZkClientTest > testUpdateLeaderAndIsr() PASSED KafkaZkClientTest > testUpdateBrokerInfo() PASSED KafkaZkClientTest > testCreateRecursive() PASSED AuthorizerIntegrationTest > testConsumeWithTopicWrite(String) > kafka.api.AuthorizerIntegrationTest.testConsumeWithTopicWrite(String)[2] PASSED KafkaZkClientTest > testGetConsumerOffsetNoData() PASSED SaslSslAdminIntegrationTest > testAclAuthorizationDenied() PASSED KafkaZkClientTest > testDeleteTopicPathMethods() PASSED AuthorizerIntegrationTest > testOffsetsForLeaderEpochClusterPermission(String) > kafka.api.AuthorizerIntegrationTest.testOffsetsForLeaderEpochClusterPermission(String)[1] PASSED KafkaZkClientTest > testSetTopicPartitionStatesRaw() PASSED AuthorizerIntegrationTest > testOffsetsForLeaderEpochClusterPermission(String) > kafka.api.AuthorizerIntegrationTest.testOffsetsForLeaderEpochClusterPermission(String)[2] PASSED KafkaZkClientTest > testAclManagementMethods() PASSED KafkaZkClientTest > testPreferredReplicaElectionMethods() PASSED SaslOAuthBearerSslEndToEndAuthorizationTest > testProduceConsumeViaSubscribe() PASSED KafkaZkClientTest > testPropagateLogDir() PASSED WARNING: An illegal reflective access operation has occurred WARNING: Illegal reflective access by kafka.security.minikdc.MiniKdc (file:/home/ubuntu/anant/kafka/core/build/classes/scala/test/) to method sun.security.krb5.Config.refresh() WARNING: Please consider reporting this to the maintainers of kafka.security.minikdc.MiniKdc WARNING: Use --illegal-access=warn to enable warnings of further illegal reflective access operations WARNING: All illegal access operations will be denied in a future release AuthorizerIntegrationTest > testTransactionalProducerTopicAuthorizationExceptionInSendCallback(String) > kafka.api.AuthorizerIntegrationTest.testTransactionalProducerTopicAuthorizationExceptionInSendCallback(String)[1] PASSED KafkaZkClientTest > testGetDataAndStat() PASSED KafkaZkClientTest > testReassignPartitionsInProgress() PASSED AuthorizerIntegrationTest > testTransactionalProducerTopicAuthorizationExceptionInSendCallback(String) > kafka.api.AuthorizerIntegrationTest.testTransactionalProducerTopicAuthorizationExceptionInSendCallback(String)[2] PASSED KafkaZkClientTest > testChrootExistsAndRootIsLocked() PASSED KafkaZkClientTest > testCreateTopLevelPaths() PASSED KafkaZkClientTest > testGetAllTopicsInClusterDoesNotTriggerWatch() PASSED AuthorizerIntegrationTest > testTransactionalProducerInitTransactionsNoWriteTransactionalIdAcl(String) > kafka.api.AuthorizerIntegrationTest.testTransactionalProducerInitTransactionsNoWriteTransactionalIdAcl(String)[1] PASSED KafkaZkClientTest > testIsrChangeNotificationGetters() PASSED SaslGssapiSslEndToEndAuthorizationTest > testProduceConsumeViaAssign() PASSED AuthorizerIntegrationTest > testTransactionalProducerInitTransactionsNoWriteTransactionalIdAcl(String) > kafka.api.AuthorizerIntegrationTest.testTransactionalProducerInitTransactionsNoWriteTransactionalIdAcl(String)[2] PASSED KafkaZkClientTest > testLogDirEventNotificationsDeletion() PASSED SaslSslAdminIntegrationTest > testAclOperations() PASSED KafkaZkClientTest > testGetLogConfigs() PASSED SaslOAuthBearerSslEndToEndAuthorizationTest > testTwoConsumersWithDifferentSaslCredentials() PASSED KafkaZkClientTest > testBrokerSequenceIdMethods() PASSED AuthorizerIntegrationTest > testMetadataClusterAuthorizedOperationsWithoutDescribeCluster(String) > kafka.api.AuthorizerIntegrationTest.testMetadataClusterAuthorizedOperationsWithoutDescribeCluster(String)[1] PASSED KafkaZkClientTest > testAclMethods() PASSED AuthorizerIntegrationTest > testMetadataClusterAuthorizedOperationsWithoutDescribeCluster(String) > kafka.api.AuthorizerIntegrationTest.testMetadataClusterAuthorizedOperationsWithoutDescribeCluster(String)[2] PASSED KafkaZkClientTest > testCreateSequentialPersistentPath() PASSED KafkaZkClientTest > testConditionalUpdatePath() PASSED DelegationTokenCommandTest > testDelegationTokenRequests() PASSED KafkaZkClientTest > testGetAllTopicsInClusterTriggersWatch() PASSED AuthorizerIntegrationTest > testIncrementalAlterConfigsRequestRequiresClusterPermissionForBrokerLogger(String) > kafka.api.AuthorizerIntegrationTest.testIncrementalAlterConfigsRequestRequiresClusterPermissionForBrokerLogger(String)[1] PASSED KafkaZkClientTest > testDeleteTopicZNode() PASSED MultipleListenersWithAdditionalJaasContextTest > testProduceConsume() PASSED KafkaZkClientTest > testDeletePath() PASSED AuthorizerIntegrationTest > testIncrementalAlterConfigsRequestRequiresClusterPermissionForBrokerLogger(String) > kafka.api.AuthorizerIntegrationTest.testIncrementalAlterConfigsRequestRequiresClusterPermissionForBrokerLogger(String)[2] PASSED KafkaZkClientTest > testGetBrokerMethods() PASSED WARNING: An illegal reflective access operation has occurred WARNING: Illegal reflective access by kafka.security.minikdc.MiniKdc (file:/home/ubuntu/anant/kafka/core/build/classes/scala/test/) to method sun.security.krb5.Config.refresh() WARNING: Please consider reporting this to the maintainers of kafka.security.minikdc.MiniKdc WARNING: Use --illegal-access=warn to enable warnings of further illegal reflective access operations WARNING: All illegal access operations will be denied in a future release AuthorizerIntegrationTest > testDescribeClusterClusterAuthorizedOperationsWithoutDescribeCluster(String) > kafka.api.AuthorizerIntegrationTest.testDescribeClusterClusterAuthorizedOperationsWithoutDescribeCluster(String)[1] PASSED KafkaZkClientTest > testJuteMaxBufffer() PASSED KafkaZkClientTest > testCreateTokenChangeNotification() PASSED AuthorizerIntegrationTest > testDescribeClusterClusterAuthorizedOperationsWithoutDescribeCluster(String) > kafka.api.AuthorizerIntegrationTest.testDescribeClusterClusterAuthorizedOperationsWithoutDescribeCluster(String)[2] PASSED KafkaZkClientTest > testGetTopicsAndPartitions() PASSED SaslSslAdminIntegrationTest > testAclOperations2() PASSED KafkaZkClientTest > testChroot(boolean) > kafka.zk.KafkaZkClientTest.testChroot(boolean)[1] PASSED AuthorizerIntegrationTest > testOffsetFetchWithNoGroupAccess(String) > kafka.api.AuthorizerIntegrationTest.testOffsetFetchWithNoGroupAccess(String)[1] PASSED LeaderElectionCommandTest > testAllTopicPartition() > kafka.admin.LeaderElectionCommandTest.testAllTopicPartition()[1] PASSED SaslGssapiSslEndToEndAuthorizationTest > testNoConsumeWithDescribeAclViaAssign() PASSED KafkaZkClientTest > testChroot(boolean) > kafka.zk.KafkaZkClientTest.testChroot(boolean)[2] PASSED AuthorizerIntegrationTest > testOffsetFetchWithNoGroupAccess(String) > kafka.api.AuthorizerIntegrationTest.testOffsetFetchWithNoGroupAccess(String)[2] PASSED KafkaZkClientTest > testRegisterBrokerInfo() PASSED KafkaZkClientTest > testRetryRegisterBrokerInfo() PASSED KafkaZkClientTest > testConsumerOffsetPath() PASSED AuthorizerIntegrationTest > testCommitWithNoAccess(String) > kafka.api.AuthorizerIntegrationTest.testCommitWithNoAccess(String)[1] PASSED ClientIdQuotaTest > testQuotaOverrideDelete() PASSED KafkaZkClientTest > testDeleteRecursiveWithControllerEpochVersionCheck() PASSED AuthorizerIntegrationTest > testCommitWithNoAccess(String) > kafka.api.AuthorizerIntegrationTest.testCommitWithNoAccess(String)[2] PASSED SaslPlaintextConsumerTest > testCoordinatorFailover() PASSED KafkaZkClientTest > testTopicAssignments() PASSED KafkaZkClientTest > testControllerManagementMethods() PASSED AuthorizerIntegrationTest > testUnauthorizedCreatePartitions(String) > kafka.api.AuthorizerIntegrationTest.testUnauthorizedCreatePartitions(String)[1] PASSED ClientIdQuotaTest > testThrottledRequest() PASSED KafkaZkClientTest > testTopicAssignmentMethods() PASSED LeaderElectionCommandTest > testAllTopicPartition() > kafka.admin.LeaderElectionCommandTest.testAllTopicPartition()[2] PASSED AuthorizerIntegrationTest > testUnauthorizedCreatePartitions(String) > kafka.api.AuthorizerIntegrationTest.testUnauthorizedCreatePartitions(String)[2] PASSED KafkaZkClientTest > testConnectionViaNettyClient() PASSED KafkaZkClientTest > testPropagateIsrChanges() PASSED AuthorizerIntegrationTest > testDeleteGroupOffsetsWithDeleteAclWithoutTopicAcl(String) > kafka.api.AuthorizerIntegrationTest.testDeleteGroupOffsetsWithDeleteAclWithoutTopicAcl(String)[1] PASSED KafkaZkClientTest > testControllerEpochMethods() PASSED SaslSslAdminIntegrationTest > testAclDelete() PASSED KafkaZkClientTest > testDeleteRecursive() PASSED AuthorizerIntegrationTest > testDeleteGroupOffsetsWithDeleteAclWithoutTopicAcl(String) > kafka.api.AuthorizerIntegrationTest.testDeleteGroupOffsetsWithDeleteAclWithoutTopicAcl(String)[2] PASSED KafkaZkClientTest > testGetTopicPartitionStates() PASSED KafkaZkClientTest > testCreateConfigChangeNotification() PASSED KafkaZkClientTest > testDelegationTokenMethods() PASSED AuthorizerIntegrationTest > testConsumeWithoutTopicDescribeAccess(String) > kafka.api.AuthorizerIntegrationTest.testConsumeWithoutTopicDescribeAccess(String)[1] PASSED LeaderElectionCommandTest > testPathToJsonFile() > kafka.admin.LeaderElectionCommandTest.testPathToJsonFile()[1] PASSED SaslGssapiSslEndToEndAuthorizationTest > testProduceConsumeTopicAutoCreateTopicCreateAcl() PASSED AuthorizerIntegrationTest > testConsumeWithoutTopicDescribeAccess(String) > kafka.api.AuthorizerIntegrationTest.testConsumeWithoutTopicDescribeAccess(String)[2] PASSED SaslPlaintextConsumerTest > testSimpleConsumption() PASSED AuthorizerIntegrationTest > testClusterId(String) > kafka.api.AuthorizerIntegrationTest.testClusterId(String)[1] PASSED AuthorizerIntegrationTest > testClusterId(String) > kafka.api.AuthorizerIntegrationTest.testClusterId(String)[2] PASSED SslConsumerTest > testCoordinatorFailover() PASSED LeaderElectionCommandTest > testPathToJsonFile() > kafka.admin.LeaderElectionCommandTest.testPathToJsonFile()[2] PASSED AuthorizerIntegrationTest > shouldThrowTransactionalIdAuthorizationExceptionWhenNoTransactionAccessOnEndTransaction(String) > kafka.api.AuthorizerIntegrationTest.shouldThrowTransactionalIdAuthorizationExceptionWhenNoTransactionAccessOnEndTransaction(String)[1] PASSED LeaderElectionCommandTest > testTopicDoesNotExist() > kafka.admin.LeaderElectionCommandTest.testTopicDoesNotExist()[1] PASSED AuthorizerIntegrationTest > shouldThrowTransactionalIdAuthorizationExceptionWhenNoTransactionAccessOnEndTransaction(String) > kafka.api.AuthorizerIntegrationTest.shouldThrowTransactionalIdAuthorizationExceptionWhenNoTransactionAccessOnEndTransaction(String)[2] PASSED LeaderElectionCommandTest > testTopicDoesNotExist() > kafka.admin.LeaderElectionCommandTest.testTopicDoesNotExist()[2] PASSED AuthorizerIntegrationTest > shouldThrowTransactionalIdAuthorizationExceptionWhenNoTransactionAccessOnSendOffsetsToTxn(String) > kafka.api.AuthorizerIntegrationTest.shouldThrowTransactionalIdAuthorizationExceptionWhenNoTransactionAccessOnSendOffsetsToTxn(String)[1] PASSED SslEndToEndAuthorizationTest > testNoConsumeWithoutDescribeAclViaSubscribe() PASSED AuthorizerIntegrationTest > shouldThrowTransactionalIdAuthorizationExceptionWhenNoTransactionAccessOnSendOffsetsToTxn(String) > kafka.api.AuthorizerIntegrationTest.shouldThrowTransactionalIdAuthorizationExceptionWhenNoTransactionAccessOnSendOffsetsToTxn(String)[2] PASSED AuthorizerIntegrationTest > testCommitWithNoGroupAccess(String) > kafka.api.AuthorizerIntegrationTest.testCommitWithNoGroupAccess(String)[1] PASSED AuthorizerIntegrationTest > testCommitWithNoGroupAccess(String) > kafka.api.AuthorizerIntegrationTest.testCommitWithNoGroupAccess(String)[2] PASSED SslConsumerTest > testSimpleConsumption() PASSED AuthorizerIntegrationTest > testTransactionalProducerInitTransactionsNoDescribeTransactionalIdAcl(String) > kafka.api.AuthorizerIntegrationTest.testTransactionalProducerInitTransactionsNoDescribeTransactionalIdAcl(String)[1] PASSED SaslGssapiSslEndToEndAuthorizationTest > testProduceConsumeWithWildcardAcls() PASSED LeaderElectionCommandTest > testPreferredReplicaElection() > kafka.admin.LeaderElectionCommandTest.testPreferredReplicaElection()[1] PASSED AuthorizerIntegrationTest > testTransactionalProducerInitTransactionsNoDescribeTransactionalIdAcl(String) > kafka.api.AuthorizerIntegrationTest.testTransactionalProducerInitTransactionsNoDescribeTransactionalIdAcl(String)[2] PASSED AuthorizerIntegrationTest > testAuthorizeByResourceTypeDenyTakesPrecedence(String) > kafka.api.AuthorizerIntegrationTest.testAuthorizeByResourceTypeDenyTakesPrecedence(String)[1] PASSED SslEndToEndAuthorizationTest > testProduceConsumeWithPrefixedAcls() PASSED AuthorizerIntegrationTest > testAuthorizeByResourceTypeDenyTakesPrecedence(String) > kafka.api.AuthorizerIntegrationTest.testAuthorizeByResourceTypeDenyTakesPrecedence(String)[2] PASSED LeaderElectionCommandTest > testPreferredReplicaElection() > kafka.admin.LeaderElectionCommandTest.testPreferredReplicaElection()[2] PASSED AuthorizerIntegrationTest > testUnauthorizedDeleteRecordsWithDescribe(String) > kafka.api.AuthorizerIntegrationTest.testUnauthorizedDeleteRecordsWithDescribe(String)[1] PASSED AuthorizerIntegrationTest > testUnauthorizedDeleteRecordsWithDescribe(String) > kafka.api.AuthorizerIntegrationTest.testUnauthorizedDeleteRecordsWithDescribe(String)[2] PASSED AuthorizerIntegrationTest > testCreateTopicAuthorizationWithClusterCreate(String) > kafka.api.AuthorizerIntegrationTest.testCreateTopicAuthorizationWithClusterCreate(String)[1] PASSED AuthorizerIntegrationTest > testCreateTopicAuthorizationWithClusterCreate(String) > kafka.api.AuthorizerIntegrationTest.testCreateTopicAuthorizationWithClusterCreate(String)[2] PASSED AuthorizerIntegrationTest > testOffsetFetchWithTopicAndGroupRead(String) > kafka.api.AuthorizerIntegrationTest.testOffsetFetchWithTopicAndGroupRead(String)[1] PASSED AuthorizerIntegrationTest > testOffsetFetchWithTopicAndGroupRead(String) > kafka.api.AuthorizerIntegrationTest.testOffsetFetchWithTopicAndGroupRead(String)[2] PASSED LeaderElectionCommandTest > testElectionResultOutput() > kafka.admin.LeaderElectionCommandTest.testElectionResultOutput()[1] PASSED AuthorizerIntegrationTest > testCommitWithTopicDescribe(String) > kafka.api.AuthorizerIntegrationTest.testCommitWithTopicDescribe(String)[1] PASSED SaslGssapiSslEndToEndAuthorizationTest > testNoConsumeWithDescribeAclViaSubscribe() PASSED SslEndToEndAuthorizationTest > testProduceConsumeViaAssign() PASSED AuthorizerIntegrationTest > testCommitWithTopicDescribe(String) > kafka.api.AuthorizerIntegrationTest.testCommitWithTopicDescribe(String)[2] PASSED LeaderElectionCommandTest > testElectionResultOutput() > kafka.admin.LeaderElectionCommandTest.testElectionResultOutput()[2] PASSED TransactionsTest > testBumpTransactionalEpoch() PASSED LeaderElectionCommandTest > testTopicPartition() > kafka.admin.LeaderElectionCommandTest.testTopicPartition()[1] PASSED SslEndToEndAuthorizationTest > testNoConsumeWithDescribeAclViaAssign() PASSED LeaderElectionCommandTest > testTopicPartition() > kafka.admin.LeaderElectionCommandTest.testTopicPartition()[2] PASSED TransactionsTest > testSendOffsetsWithGroupMetadata() PASSED AuthorizerIntegrationTest > testAuthorizationWithTopicExisting(String) > kafka.api.AuthorizerIntegrationTest.testAuthorizationWithTopicExisting(String)[1] PASSED TransactionsBounceTest > testWithGroupMetadata() PASSED SaslGssapiSslEndToEndAuthorizationTest > testNoConsumeWithoutDescribeAclViaAssign() PASSED TransactionsTest > testBasicTransactions() PASSED SslEndToEndAuthorizationTest > testProduceConsumeTopicAutoCreateTopicCreateAcl() PASSED AuthorizerIntegrationTest > testAuthorizationWithTopicExisting(String) > kafka.api.AuthorizerIntegrationTest.testAuthorizationWithTopicExisting(String)[2] PASSED ResetConsumerGroupOffsetTest > testResetOffsetsExportImportPlanSingleGroupArg() PASSED AuthorizerIntegrationTest > testUnauthorizedDeleteRecordsWithoutDescribe(String) > kafka.api.AuthorizerIntegrationTest.testUnauthorizedDeleteRecordsWithoutDescribe(String)[1] PASSED AuthorizerIntegrationTest > testUnauthorizedDeleteRecordsWithoutDescribe(String) > kafka.api.AuthorizerIntegrationTest.testUnauthorizedDeleteRecordsWithoutDescribe(String)[2] PASSED TransactionsTest > testSendOffsetsWithGroupId() PASSED AuthorizerIntegrationTest > testMetadataWithTopicDescribe(String) > kafka.api.AuthorizerIntegrationTest.testMetadataWithTopicDescribe(String)[1] PASSED AuthorizerIntegrationTest > testMetadataWithTopicDescribe(String) > kafka.api.AuthorizerIntegrationTest.testMetadataWithTopicDescribe(String)[2] PASSED SaslGssapiSslEndToEndAuthorizationTest > testNoGroupAcl() PASSED SslEndToEndAuthorizationTest > testProduceConsumeWithWildcardAcls() PASSED AuthorizerIntegrationTest > testProduceWithTopicDescribe(String) > kafka.api.AuthorizerIntegrationTest.testProduceWithTopicDescribe(String)[1] PASSED AuthorizerIntegrationTest > testProduceWithTopicDescribe(String) > kafka.api.AuthorizerIntegrationTest.testProduceWithTopicDescribe(String)[2] PASSED TransactionsTest > testFencingOnSendOffsets() PASSED AuthorizerIntegrationTest > testDescribeGroupApiWithNoGroupAcl(String) > kafka.api.AuthorizerIntegrationTest.testDescribeGroupApiWithNoGroupAcl(String)[1] PASSED AuthorizerIntegrationTest > testDescribeGroupApiWithNoGroupAcl(String) > kafka.api.AuthorizerIntegrationTest.testDescribeGroupApiWithNoGroupAcl(String)[2] PASSED AuthorizerIntegrationTest > testPatternSubscriptionMatchingInternalTopic(String) > kafka.api.AuthorizerIntegrationTest.testPatternSubscriptionMatchingInternalTopic(String)[1] PASSED ResetConsumerGroupOffsetTest > testResetOffsetsShiftByHigherThanLatest() PASSED TransactionsTest > testFencingOnAddPartitions() PASSED AuthorizerIntegrationTest > testPatternSubscriptionMatchingInternalTopic(String) > kafka.api.AuthorizerIntegrationTest.testPatternSubscriptionMatchingInternalTopic(String)[2] PASSED AuthorizerIntegrationTest > testSendOffsetsWithNoConsumerGroupDescribeAccess(String) > kafka.api.AuthorizerIntegrationTest.testSendOffsetsWithNoConsumerGroupDescribeAccess(String)[1] PASSED SslEndToEndAuthorizationTest > testNoConsumeWithDescribeAclViaSubscribe() PASSED AuthorizerIntegrationTest > testSendOffsetsWithNoConsumerGroupDescribeAccess(String) > kafka.api.AuthorizerIntegrationTest.testSendOffsetsWithNoConsumerGroupDescribeAccess(String)[2] PASSED SaslGssapiSslEndToEndAuthorizationTest > testNoProduceWithDescribeAcl(boolean) > kafka.api.SaslGssapiSslEndToEndAuthorizationTest.testNoProduceWithDescribeAcl(boolean)[1] PASSED AuthorizerIntegrationTest > testListTransactionsAuthorization(String) > kafka.api.AuthorizerIntegrationTest.testListTransactionsAuthorization(String)[1] PASSED TransactionsTest > testFencingOnTransactionExpiration() PASSED AuthorizerIntegrationTest > testListTransactionsAuthorization(String) > kafka.api.AuthorizerIntegrationTest.testListTransactionsAuthorization(String)[2] PASSED AuthorizerIntegrationTest > testOffsetFetchTopicDescribe(String) > kafka.api.AuthorizerIntegrationTest.testOffsetFetchTopicDescribe(String)[1] PASSED AuthorizerIntegrationTest > testOffsetFetchTopicDescribe(String) > kafka.api.AuthorizerIntegrationTest.testOffsetFetchTopicDescribe(String)[2] PASSED ResetConsumerGroupOffsetTest > testResetOffsetsShiftMinus() PASSED AuthorizerIntegrationTest > testCommitWithTopicAndGroupRead(String) > kafka.api.AuthorizerIntegrationTest.testCommitWithTopicAndGroupRead(String)[1] PASSED TransactionsTest > testDelayedFetchIncludesAbortedTransaction() PASSED AuthorizerIntegrationTest > testCommitWithTopicAndGroupRead(String) > kafka.api.AuthorizerIntegrationTest.testCommitWithTopicAndGroupRead(String)[2] PASSED SslEndToEndAuthorizationTest > testNoConsumeWithoutDescribeAclViaAssign() PASSED AuthorizerIntegrationTest > testOffsetFetchMultipleGroupsAuthorization(String) > kafka.api.AuthorizerIntegrationTest.testOffsetFetchMultipleGroupsAuthorization(String)[1] PASSED TransactionsTest > testOffsetMetadataInSendOffsetsToTransaction() PASSED SaslGssapiSslEndToEndAuthorizationTest > testNoProduceWithDescribeAcl(boolean) > kafka.api.SaslGssapiSslEndToEndAuthorizationTest.testNoProduceWithDescribeAcl(boolean)[2] PASSED AuthorizerIntegrationTest > testOffsetFetchMultipleGroupsAuthorization(String) > kafka.api.AuthorizerIntegrationTest.testOffsetFetchMultipleGroupsAuthorization(String)[2] PASSED TransactionsBounceTest > testWithGroupId() PASSED AuthorizerIntegrationTest > testIdempotentProducerNoIdempotentWriteAclInInitProducerId(String) > kafka.api.AuthorizerIntegrationTest.testIdempotentProducerNoIdempotentWriteAclInInitProducerId(String)[1] PASSED AclAuthorizerWithZkSaslTest > testAclUpdateWithSessionExpiration() PASSED AuthorizerIntegrationTest > testIdempotentProducerNoIdempotentWriteAclInInitProducerId(String) > kafka.api.AuthorizerIntegrationTest.testIdempotentProducerNoIdempotentWriteAclInInitProducerId(String)[2] PASSED AuthorizerIntegrationTest > testSimpleConsumeWithExplicitSeekAndNoGroupAccess(String) > kafka.api.AuthorizerIntegrationTest.testSimpleConsumeWithExplicitSeekAndNoGroupAccess(String)[1] PASSED SslEndToEndAuthorizationTest > testNoGroupAcl() PASSED ResetConsumerGroupOffsetTest > testResetOffsetsToCurrentOffset() PASSED AuthorizerIntegrationTest > testSimpleConsumeWithExplicitSeekAndNoGroupAccess(String) > kafka.api.AuthorizerIntegrationTest.testSimpleConsumeWithExplicitSeekAndNoGroupAccess(String)[2] PASSED AuthorizerIntegrationTest > testAuthorizationFetchV12WithTopicNotExisting(String) > kafka.api.AuthorizerIntegrationTest.testAuthorizationFetchV12WithTopicNotExisting(String)[1] PASSED AuthorizerIntegrationTest > testAuthorizationFetchV12WithTopicNotExisting(String) > kafka.api.AuthorizerIntegrationTest.testAuthorizationFetchV12WithTopicNotExisting(String)[2] PASSED TransactionsTest > testInitTransactionsTimeout() PASSED AclAuthorizerWithZkSaslTest > testAclUpdateWithAuthFailure() PASSED AlterUserScramCredentialsRequestTest > testAlterTooFewIterations() PASSED TransactionsTest > testConsecutivelyRunInitTransactions() PASSED ConsumerWithLegacyMessageFormatIntegrationTest > testEarliestOrLatestOffsets() PASSED SslEndToEndAuthorizationTest > testNoProduceWithDescribeAcl(boolean) > kafka.api.SslEndToEndAuthorizationTest.testNoProduceWithDescribeAcl(boolean)[1] PASSED AlterUserScramCredentialsRequestTest > testAlterUnknownMechanism() PASSED ConsumerWithLegacyMessageFormatIntegrationTest > testOffsetsForTimes() PASSED AlterUserScramCredentialsRequestTest > testDeleteSomethingThatDoesNotExist() PASSED ResetConsumerGroupOffsetTest > testResetOffsetsToEarliestOnOneTopicAndPartition() PASSED SaslGssapiSslEndToEndAuthorizationTest > testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl(boolean) > kafka.api.SaslGssapiSslEndToEndAuthorizationTest.testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl(boolean)[1] PASSED TransactionsTest > testReadCommittedConsumerShouldNotSeeUndecidedData() PASSED ResetConsumerGroupOffsetTest > testResetWithUnrecognizedNewConsumerOption() PASSED AlterUserScramCredentialsRequestTest > testAlterAndDescribe() PASSED AlterUserScramCredentialsRequestTest > testAlterEmptyUser() PASSED SslEndToEndAuthorizationTest > testNoProduceWithDescribeAcl(boolean) > kafka.api.SslEndToEndAuthorizationTest.testNoProduceWithDescribeAcl(boolean)[2] PASSED AlterUserScramCredentialsRequestTest > testAlterSameThingTwice() PASSED AlterUserScramCredentialsRequestTest > testAlterTooManyIterations() PASSED TransactionsTest > testSendOffsetsToTransactionTimeout() PASSED ResetConsumerGroupOffsetTest > testResetOffsetsByDurationToEarliest() PASSED AlterUserScramCredentialsRequestTest > testAlterNothing() PASSED AlterUserScramCredentialsRequestTest > testAlterNotController() PASSED GroupEndToEndAuthorizationTest > testNoConsumeWithoutDescribeAclViaSubscribe() PASSED SslEndToEndAuthorizationTest > testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl(boolean) > kafka.api.SslEndToEndAuthorizationTest.testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl(boolean)[1] PASSED SaslGssapiSslEndToEndAuthorizationTest > testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl(boolean) > kafka.api.SaslGssapiSslEndToEndAuthorizationTest.testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl(boolean)[2] PASSED BrokerEpochIntegrationTest > testControlRequestWithStaleBrokerEpoch() PASSED BrokerEpochIntegrationTest > testControlRequestWithCorrectBrokerEpoch() PASSED BrokerEpochIntegrationTest > testReplicaManagerBrokerEpochMatchesWithZk() PASSED BrokerEpochIntegrationTest > testControllerBrokerEpochCacheMatchesWithZk() PASSED ResetConsumerGroupOffsetTest > testResetOffsetsToEarliestOnOneTopic() PASSED ResetConsumerGroupOffsetTest > testResetOffsetsNotExistingGroup() PASSED BrokerEpochIntegrationTest > testControlRequestWithNewerBrokerEpoch() PASSED GroupEndToEndAuthorizationTest > testProduceConsumeWithPrefixedAcls() PASSED SslEndToEndAuthorizationTest > testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl(boolean) > kafka.api.SslEndToEndAuthorizationTest.testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl(boolean)[2] PASSED DelegationTokenRequestsTest > testDelegationTokenRequests() PASSED DynamicConfigChangeTest > testConfigureDefaultTopic(String) > kafka.server.DynamicConfigChangeTest.testConfigureDefaultTopic(String)[1] PASSED DynamicConfigChangeTest > testConfigureDefaultTopic(String) > kafka.server.DynamicConfigChangeTest.testConfigureDefaultTopic(String)[2] PASSED DynamicConfigChangeTest > testMessageFormatVersionChange(String) > kafka.server.DynamicConfigChangeTest.testMessageFormatVersionChange(String)[1] PASSED DynamicConfigChangeTest > testProcessNotification(String) > kafka.server.DynamicConfigChangeTest.testProcessNotification(String)[1] PASSED SaslGssapiSslEndToEndAuthorizationTest > testProduceConsumeViaSubscribe() PASSED DynamicConfigChangeTest > testDefaultClientIdQuotaConfigChange(String) > kafka.server.DynamicConfigChangeTest.testDefaultClientIdQuotaConfigChange(String)[1] PASSED DynamicConfigChangeTest > testDefaultClientIdQuotaConfigChange(String) > kafka.server.DynamicConfigChangeTest.testDefaultClientIdQuotaConfigChange(String)[2] PASSED DynamicConfigChangeTest > testQuotaInitialization(String) > kafka.server.DynamicConfigChangeTest.testQuotaInitialization(String)[1] PASSED DynamicConfigChangeTest > testUserQuotaConfigChange(String) > kafka.server.DynamicConfigChangeTest.testUserQuotaConfigChange(String)[1] PASSED SslEndToEndAuthorizationTest > testProduceConsumeViaSubscribe() PASSED DynamicConfigChangeTest > testUserQuotaConfigChange(String) > kafka.server.DynamicConfigChangeTest.testUserQuotaConfigChange(String)[2] PASSED GroupEndToEndAuthorizationTest > testProduceConsumeViaAssign() PASSED DynamicConfigChangeTest > testClientIdQuotaConfigChange(String) > kafka.server.DynamicConfigChangeTest.testClientIdQuotaConfigChange(String)[1] PASSED DynamicConfigChangeTest > testClientIdQuotaConfigChange(String) > kafka.server.DynamicConfigChangeTest.testClientIdQuotaConfigChange(String)[2] PASSED DynamicConfigChangeTest > testConfigChangeOnNonExistingTopicWithAdminClient(String) > kafka.server.DynamicConfigChangeTest.testConfigChangeOnNonExistingTopicWithAdminClient(String)[1] PASSED DynamicConfigChangeTest > testConfigChangeOnNonExistingTopicWithAdminClient(String) > kafka.server.DynamicConfigChangeTest.testConfigChangeOnNonExistingTopicWithAdminClient(String)[2] PASSED DynamicConfigChangeTest > testUserClientIdQuotaChange(String) > kafka.server.DynamicConfigChangeTest.testUserClientIdQuotaChange(String)[1] PASSED DynamicConfigChangeTest > testUserClientIdQuotaChange(String) > kafka.server.DynamicConfigChangeTest.testUserClientIdQuotaChange(String)[2] PASSED DynamicConfigChangeTest > testIpQuotaInitialization(String) > kafka.server.DynamicConfigChangeTest.testIpQuotaInitialization(String)[1] PASSED SaslGssapiSslEndToEndAuthorizationTest > testTwoConsumersWithDifferentSaslCredentials() PASSED DynamicConfigChangeTest > testIpQuotaInitialization(String) > kafka.server.DynamicConfigChangeTest.testIpQuotaInitialization(String)[2] PASSED DynamicConfigChangeTest > testDefaultUserQuotaConfigChange(String) > kafka.server.DynamicConfigChangeTest.testDefaultUserQuotaConfigChange(String)[1] PASSED DynamicConfigChangeTest > testDefaultUserQuotaConfigChange(String) > kafka.server.DynamicConfigChangeTest.testDefaultUserQuotaConfigChange(String)[2] PASSED DynamicConfigChangeTest > testDefaultUserClientIdQuotaConfigChange(String) > kafka.server.DynamicConfigChangeTest.testDefaultUserClientIdQuotaConfigChange(String)[1] PASSED UserQuotaTest > testProducerConsumerOverrideLowerQuota() PASSED GroupEndToEndAuthorizationTest > testNoConsumeWithDescribeAclViaAssign() PASSED DynamicConfigChangeTest > testDefaultUserClientIdQuotaConfigChange(String) > kafka.server.DynamicConfigChangeTest.testDefaultUserClientIdQuotaConfigChange(String)[2] PASSED DynamicConfigChangeTest > testConfigChangeOnNonExistingTopic(String) > kafka.server.DynamicConfigChangeTest.testConfigChangeOnNonExistingTopic(String)[1] PASSED DynamicConfigChangeTest > testConfigChange(String) > kafka.server.DynamicConfigChangeTest.testConfigChange(String)[1] PASSED DynamicConfigChangeTest > testConfigChange(String) > kafka.server.DynamicConfigChangeTest.testConfigChange(String)[2] PASSED DynamicConfigChangeTest > testIpQuotaConfigChange(String) > kafka.server.DynamicConfigChangeTest.testIpQuotaConfigChange(String)[1] PASSED SaslSslConsumerTest > testCoordinatorFailover() PASSED DynamicConfigChangeTest > testIpQuotaConfigChange(String) > kafka.server.DynamicConfigChangeTest.testIpQuotaConfigChange(String)[2] PASSED ResetConsumerGroupOffsetTest > testResetOffsetsExistingTopicSelectedGroups() PASSED DynamicConfigChangeTest > testDynamicTopicConfigChange(String) > kafka.server.DynamicConfigChangeTest.testDynamicTopicConfigChange(String)[1] PASSED UserQuotaTest > testProducerConsumerOverrideUnthrottled() PASSED DynamicConfigChangeTest > testDynamicTopicConfigChange(String) > kafka.server.DynamicConfigChangeTest.testDynamicTopicConfigChange(String)[2] PASSED GroupEndToEndAuthorizationTest > testProduceConsumeTopicAutoCreateTopicCreateAcl() PASSED SaslSslConsumerTest > testSimpleConsumption() PASSED LogDirFailureTest > testIOExceptionDuringLogRoll() PASSED ResetConsumerGroupOffsetTest > testResetOffsetsToZonedDateTime() PASSED SslProducerSendTest > testSendNonCompressedMessageWithCreateTime() PASSED LogDirFailureTest > testIOExceptionDuringCheckpoint() PASSED SslProducerSendTest > testClose() PASSED GroupEndToEndAuthorizationTest > testProduceConsumeWithWildcardAcls() PASSED LogDirFailureTest > testProduceErrorFromFailureOnCheckpoint() PASSED TransactionsTest > testFailureToFenceEpoch() PASSED SslProducerSendTest > testFlush() PASSED LogDirFailureTest > brokerWithOldInterBrokerProtocolShouldHaltOnLogDirFailure() PASSED ResetConsumerGroupOffsetTest > testResetOffsetsToEarliest() PASSED LogDirFailureTest > testReplicaFetcherThreadAfterLogDirFailureOnFollower() PASSED TransactionsTest > testFencingOnSend() PASSED SslProducerSendTest > testSendToPartition() PASSED LogDirFailureTest > testProduceErrorFromFailureOnLogRoll() PASSED SslProducerSendTest > testSendOffset() PASSED ScramServerStartupTest > testAuthentications() PASSED GroupEndToEndAuthorizationTest > testNoConsumeWithDescribeAclViaSubscribe() PASSED TransactionsTest > testFencingOnCommit() PASSED UpdateFeaturesTest > testPartialSuccessDuringInvalidFeatureUpgradeAndValidDowngrade() PASSED SslProducerSendTest > testSendCompressedMessageWithCreateTime() PASSED UpdateFeaturesTest > testShouldFailRequestDuringDeletionOfNonExistingFeature() PASSED UpdateFeaturesTest > testShouldFailRequestIfNotController() PASSED UpdateFeaturesTest > testShouldFailRequestDuringBrokerMaxVersionLevelIncompatibilityWithNoExistingFinalizedFeature() PASSED UserQuotaTest > testThrottledProducerConsumer() PASSED TransactionsTest > testAbortTransactionTimeout() PASSED UpdateFeaturesTest > testShouldFailRequestWhenDowngradeFlagIsNotSetDuringDowngrade() PASSED GroupEndToEndAuthorizationTest > testNoConsumeWithoutDescribeAclViaAssign() PASSED UpdateFeaturesTest > testShouldFailRequestWhenUpgradingToSameVersionLevel() PASSED UpdateFeaturesTest > testShouldFailRequestDuringBrokerMaxVersionLevelIncompatibilityForExistingFinalizedFeature() PASSED TransactionsTest > testMultipleMarkersOneLeader() PASSED ResetConsumerGroupOffsetTest > testResetOffsetsExportImportPlan() PASSED UpdateFeaturesTest > testPartialSuccessDuringValidFeatureUpgradeAndInvalidDowngrade() PASSED UpdateFeaturesTest > testShouldFailRequestInServerWhenDowngradeFlagIsNotSetDuringDeletion() PASSED GroupEndToEndAuthorizationTest > testNoGroupAcl() PASSED UpdateFeaturesTest > testShouldFailRequestWhenDowngradeToHigherVersionLevelIsAttempted() PASSED UpdateFeaturesTest > testSuccessfulFeatureUpgradeAndWithNoExistingFinalizedFeatures() PASSED TransactionsTest > testCommitTransactionTimeout() PASSED UpdateFeaturesTest > testSuccessfulFeatureUpgradeAndDowngrade() PASSED ApiVersionsRequestTest > testApiVersionsRequestWithUnsupportedVersion() > kafka.server.ApiVersionsRequestTest.testApiVersionsRequestWithUnsupportedVersion()[1] PASSED ResetConsumerGroupOffsetTest > testResetOffsetsToSpecificOffset() PASSED MirrorMakerIntegrationTest > testCommaSeparatedRegex() PASSED ApiVersionsRequestTest > testApiVersionsRequestValidationV0() > kafka.server.ApiVersionsRequestTest.testApiVersionsRequestValidationV0()[1] PASSED ApiVersionsRequestTest > testApiVersionsRequestValidationV3() > kafka.server.ApiVersionsRequestTest.testApiVersionsRequestValidationV3()[1] PASSED ApiVersionsRequestTest > testApiVersionsRequestThroughControlPlaneListener() > kafka.server.ApiVersionsRequestTest.testApiVersionsRequestThroughControlPlaneListener()[1] PASSED ApiVersionsRequestTest > testApiVersionsRequest() > kafka.server.ApiVersionsRequestTest.testApiVersionsRequest()[1] PASSED SslProducerSendTest > testCloseWithZeroTimeoutFromCallerThread() PASSED GroupEndToEndAuthorizationTest > testNoProduceWithDescribeAcl(boolean) > kafka.api.GroupEndToEndAuthorizationTest.testNoProduceWithDescribeAcl(boolean)[1] PASSED ApiVersionsRequestTest > testApiVersionsRequestValidationV0ThroughControlPlaneListener() > kafka.server.ApiVersionsRequestTest.testApiVersionsRequestValidationV0ThroughControlPlaneListener()[1] PASSED MirrorMakerIntegrationTest > testCommitOffsetsRemoveNonExistentTopics() PASSED MirrorMakerIntegrationTest > testCommitOffsetsThrowTimeoutException() PASSED CreateTopicsRequestWithPolicyTest > testValidCreateTopicsRequests(String) > kafka.server.CreateTopicsRequestWithPolicyTest.testValidCreateTopicsRequests(String)[1] PASSED CreateTopicsRequestWithPolicyTest > testValidCreateTopicsRequests(String) > kafka.server.CreateTopicsRequestWithPolicyTest.testValidCreateTopicsRequests(String)[2] PASSED ResetConsumerGroupOffsetTest > testResetOffsetsShiftPlus() PASSED CreateTopicsRequestWithPolicyTest > testErrorCreateTopicsRequests(String) > kafka.server.CreateTopicsRequestWithPolicyTest.testErrorCreateTopicsRequests(String)[1] PASSED CreateTopicsRequestWithPolicyTest > testErrorCreateTopicsRequests(String) > kafka.server.CreateTopicsRequestWithPolicyTest.testErrorCreateTopicsRequests(String)[2] PASSED GroupEndToEndAuthorizationTest > testNoProduceWithDescribeAcl(boolean) > kafka.api.GroupEndToEndAuthorizationTest.testNoProduceWithDescribeAcl(boolean)[2] PASSED DeleteTopicsRequestTest > testValidDeleteTopicRequests() PASSED DeleteTopicsRequestTest > testErrorDeleteTopicRequests() PASSED DeleteTopicsRequestTest > testNotController() PASSED DescribeLogDirsRequestTest > testDescribeLogDirsRequest() PASSED DynamicConfigTest > shouldFailFollowerConfigsWithInvalidValues() PASSED DynamicConfigTest > shouldFailWhenChangingUserUnknownConfig() PASSED DynamicConfigTest > shouldFailIpConfigsWithInvalidValues() PASSED DynamicConfigTest > shouldFailLeaderConfigsWithInvalidValues() PASSED ResetConsumerGroupOffsetTest > testResetOffsetsToLatest() PASSED DynamicConfigTest > shouldFailIpConfigsWithBadHost() PASSED DynamicConfigTest > shouldFailIpConfigsWithInvalidIpv4Entity() PASSED DynamicConfigTest > shouldFailWhenChangingClientIdUnknownConfig() PASSED GroupEndToEndAuthorizationTest > testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl(boolean) > kafka.api.GroupEndToEndAuthorizationTest.testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl(boolean)[1] PASSED UserQuotaTest > testQuotaOverrideDelete() PASSED ResetConsumerGroupOffsetTest > testResetOffsetsShiftByLowerThanEarliest() PASSED SslProducerSendTest > testCloseWithZeroTimeoutFromSenderThread() PASSED GroupEndToEndAuthorizationTest > testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl(boolean) > kafka.api.GroupEndToEndAuthorizationTest.testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl(boolean)[2] PASSED KRaftClusterTest > testIncrementalAlterConfigs() PASSED KRaftClusterTest > testCreateClusterWithAdvertisedHostAndPortDifferentFromSocketServer() PASSED UserQuotaTest > testThrottledRequest() PASSED SslProducerSendTest > testSendBeforeAndAfterPartitionExpansion() PASSED ControllerFailoverTest > testHandleIllegalStateException() PASSED ControllerIntegrationTest > testTopicIdCreatedOnUpgradeMultiBrokerScenario() PASSED ControllerIntegrationTest > testPreemptionWithCallbacks() PASSED GroupEndToEndAuthorizationTest > testProduceConsumeViaSubscribe() PASSED UncleanLeaderElectionTest > testTopicUncleanLeaderElectionEnable() PASSED ControllerIntegrationTest > testControllerDetectsBouncedBrokers() PASSED ControllerIntegrationTest > testControlledShutdown() PASSED ControllerIntegrationTest > testPreemptionOnControllerShutdown() PASSED UncleanLeaderElectionTest > testUncleanLeaderElectionEnabled() PASSED ControllerIntegrationTest > testPartitionReassignmentWithOfflineReplicaHaltingProgress() PASSED ControllerIntegrationTest > testNoTopicIdPersistsThroughControllerReelection() PASSED ControllerIntegrationTest > testControllerEpochPersistsWhenAllBrokersDown() PASSED KRaftClusterTest > testSetLog4jConfigurations() PASSED ControllerIntegrationTest > testTopicIdsAreAdded() PASSED GroupEndToEndAuthorizationTest > testTwoConsumersWithDifferentSaslCredentials() PASSED ResetConsumerGroupOffsetTest > testResetOffsetsExistingTopicAllGroups() PASSED ControllerIntegrationTest > testTopicCreationWithOfflineReplica() PASSED KRaftClusterTest > testClientQuotas() PASSED ControllerIntegrationTest > testPartitionReassignmentResumesAfterReplicaComesOnline() PASSED PlaintextConsumerTest > testCoordinatorFailover() PASSED ControllerIntegrationTest > testLeaderAndIsrWhenEntireIsrOfflineAndUncleanLeaderElectionDisabled() PASSED UncleanLeaderElectionTest > testUncleanLeaderElectionDisabled() PASSED ControllerIntegrationTest > testTopicIdMigrationAndHandlingWithOlderVersion() PASSED UncleanLeaderElectionTest > testUncleanLeaderElectionInvalidTopicOverride() PASSED ControllerIntegrationTest > testTopicPartitionExpansionWithOfflineReplica() PASSED PlaintextConsumerTest > testSimpleConsumption() PASSED ControllerIntegrationTest > testPartitionReassignmentToBrokerWithOfflineLogDir() PASSED ResetConsumerGroupOffsetTest > testResetOffsetsByDuration() PASSED PlaintextConsumerTest > testPartitionsForAutoCreate() PASSED UncleanLeaderElectionTest > testUncleanLeaderElectionEnabledByTopicOverride() PASSED ControllerIntegrationTest > testPreferredReplicaLeaderElectionWithOfflinePreferredReplica() PASSED ControllerIntegrationTest > testMetadataPropagationOnControlPlane() PASSED ControllerIntegrationTest > testControllerFeatureZNodeSetupWhenFeatureVersioningIsEnabledWithNonExistingFeatureZNode() PASSED ControllerIntegrationTest > testAlterIsrErrors() PASSED PlaintextConsumerTest > testShrinkingTopicSubscriptions() PASSED KRaftClusterTest > testLegacyAlterConfigs() PASSED UncleanLeaderElectionTest > testUncleanLeaderElectionDisabledByTopicOverride() PASSED ResetConsumerGroupOffsetTest > testResetOffsetsToLocalDateTime() PASSED LogCleanerIntegrationTest > testMarksPartitionsAsOfflineAndPopulatesUncleanableMetrics() PASSED LogCleanerIntegrationTest > testIsThreadFailed() PASSED ResetConsumerGroupOffsetTest > testResetOffsetsExistingTopic() PASSED ControllerIntegrationTest > testAutoPreferredReplicaLeaderElection() PASSED PlaintextConsumerTest > testMaxPollIntervalMs() PASSED LogCleanerIntegrationTest > testMaxLogCompactionLag() PASSED ControllerIntegrationTest > testTopicCreation() PASSED LogCleanerParameterizedIntegrationTest > cleanerConfigUpdateTest(CompressionType) > kafka.log.LogCleanerParameterizedIntegrationTest.cleanerConfigUpdateTest(CompressionType)[1] PASSED LogCleanerParameterizedIntegrationTest > cleanerConfigUpdateTest(CompressionType) > kafka.log.LogCleanerParameterizedIntegrationTest.cleanerConfigUpdateTest(CompressionType)[2] PASSED ControllerIntegrationTest > testControllerFeatureZNodeSetupWhenFeatureVersioningIsDisabledWithEnabledExistingFeatureZNode() PASSED LogCleanerParameterizedIntegrationTest > cleanerConfigUpdateTest(CompressionType) > kafka.log.LogCleanerParameterizedIntegrationTest.cleanerConfigUpdateTest(CompressionType)[3] PASSED LogCleanerParameterizedIntegrationTest > cleanerConfigUpdateTest(CompressionType) > kafka.log.LogCleanerParameterizedIntegrationTest.cleanerConfigUpdateTest(CompressionType)[4] PASSED LogCleanerParameterizedIntegrationTest > cleanerConfigUpdateTest(CompressionType) > kafka.log.LogCleanerParameterizedIntegrationTest.cleanerConfigUpdateTest(CompressionType)[5] PASSED ControllerIntegrationTest > testControllerMoveOnTopicDeletion() PASSED LogCleanerParameterizedIntegrationTest > testCleaningNestedMessagesWithV0AndV1(CompressionType) > kafka.log.LogCleanerParameterizedIntegrationTest.testCleaningNestedMessagesWithV0AndV1(CompressionType)[1] PASSED LogCleanerParameterizedIntegrationTest > testCleaningNestedMessagesWithV0AndV1(CompressionType) > kafka.log.LogCleanerParameterizedIntegrationTest.testCleaningNestedMessagesWithV0AndV1(CompressionType)[2] PASSED LogCleanerParameterizedIntegrationTest > testCleaningNestedMessagesWithV0AndV1(CompressionType) > kafka.log.LogCleanerParameterizedIntegrationTest.testCleaningNestedMessagesWithV0AndV1(CompressionType)[3] PASSED LogCleanerParameterizedIntegrationTest > testCleaningNestedMessagesWithV0AndV1(CompressionType) > kafka.log.LogCleanerParameterizedIntegrationTest.testCleaningNestedMessagesWithV0AndV1(CompressionType)[4] PASSED ControllerIntegrationTest > testPartitionReassignment() PASSED LogCleanerParameterizedIntegrationTest > testCleansCombinedCompactAndDeleteTopic(CompressionType) > kafka.log.LogCleanerParameterizedIntegrationTest.testCleansCombinedCompactAndDeleteTopic(CompressionType)[1] PASSED LogCleanerParameterizedIntegrationTest > testCleansCombinedCompactAndDeleteTopic(CompressionType) > kafka.log.LogCleanerParameterizedIntegrationTest.testCleansCombinedCompactAndDeleteTopic(CompressionType)[2] PASSED LogCleanerParameterizedIntegrationTest > testCleansCombinedCompactAndDeleteTopic(CompressionType) > kafka.log.LogCleanerParameterizedIntegrationTest.testCleansCombinedCompactAndDeleteTopic(CompressionType)[3] PASSED PlaintextConsumerTest > testSubsequentPatternSubscription() PASSED ControllerIntegrationTest > testTopicIdPersistsThroughControllerRestart() PASSED LogCleanerParameterizedIntegrationTest > testCleansCombinedCompactAndDeleteTopic(CompressionType) > kafka.log.LogCleanerParameterizedIntegrationTest.testCleansCombinedCompactAndDeleteTopic(CompressionType)[4] PASSED ControllerIntegrationTest > testTopicPartitionExpansion() PASSED LogCleanerParameterizedIntegrationTest > testCleansCombinedCompactAndDeleteTopic(CompressionType) > kafka.log.LogCleanerParameterizedIntegrationTest.testCleansCombinedCompactAndDeleteTopic(CompressionType)[5] PASSED ControllerIntegrationTest > testTopicIdsAreNotAdded() PASSED ControllerIntegrationTest > testControllerMoveIncrementsControllerEpoch() PASSED PlaintextConsumerTest > testPerPartitionLeadMetricsCleanUpWithAssign() PASSED ControllerIntegrationTest > testIdempotentAlterIsr() PASSED ControllerIntegrationTest > testLeaderAndIsrWhenEntireIsrOfflineAndUncleanLeaderElectionEnabled() PASSED KRaftClusterTest > testCreateClusterAndPerformReassignment() PASSED KRaftClusterTest > testCreateClusterAndClose() PASSED KRaftClusterTest > testCreateClusterWithAdvertisedPortZero() PASSED PlaintextConsumerTest > testConsumeMessagesWithCreateTime() PASSED ControllerIntegrationTest > testControllerMoveOnPartitionReassignment() PASSED ControllerIntegrationTest > testControllerFeatureZNodeSetupWhenFeatureVersioningIsEnabledWithEnabledExistingFeatureZNode() PASSED ControllerIntegrationTest > testControllerMoveOnTopicCreation() PASSED ControllerIntegrationTest > testControllerFeatureZNodeSetupWhenFeatureVersioningIsDisabledWithDisabledExistingFeatureZNode() PASSED PlaintextConsumerTest > testAsyncCommit() PASSED ControllerIntegrationTest > testMetadataPropagationOnBrokerShutdownWithNoReplicas() PASSED ControllerIntegrationTest > testControllerRejectControlledShutdownRequestWithStaleBrokerEpoch() PASSED ControllerIntegrationTest > testBackToBackPreferredReplicaLeaderElections() PASSED PlaintextConsumerTest > testLowMaxFetchSizeForRequestAndPartition() PASSED ControllerIntegrationTest > testTopicIdUpgradeAfterReassigningPartitions() PASSED ControllerIntegrationTest > testTopicIdPersistsThroughControllerReelection() PASSED ControllerIntegrationTest > testControllerFeatureZNodeSetupWhenFeatureVersioningIsDisabledWithNonExistingFeatureZNode() PASSED ControllerIntegrationTest > testEmptyCluster() PASSED KRaftClusterTest > testCreateClusterAndCreateAndManyTopics() PASSED ControllerIntegrationTest > testControllerMoveOnPreferredReplicaElection() PASSED ControllerIntegrationTest > testPreferredReplicaLeaderElection() PASSED ControllerIntegrationTest > testMetadataPropagationOnBrokerChange() PASSED ControllerIntegrationTest > testControllerFeatureZNodeSetupWhenFeatureVersioningIsEnabledWithDisabledExistingFeatureZNode() PASSED LogCleanerParameterizedIntegrationTest > cleanerTest(CompressionType) > kafka.log.LogCleanerParameterizedIntegrationTest.cleanerTest(CompressionType)[1] PASSED ControllerIntegrationTest > testMetadataPropagationForOfflineReplicas() PASSED ControllerIntegrationTest > testTopicIdCreatedOnUpgrade() PASSED ControllerIntegrationTest > testTopicIdMigrationAndHandling() PASSED AddPartitionsToTxnRequestServerTest > shouldReceiveOperationNotAttemptedWhenOtherPartitionHasError() PASSED AlterReplicaLogDirsRequestTest > testAlterReplicaLogDirsRequest() PASSED KRaftClusterTest > testCreateClusterAndWaitForBrokerInRunningState() PASSED AlterReplicaLogDirsRequestTest > testAlterReplicaLogDirsRequestErrorCode() PASSED CreateTopicsRequestTest > testValidCreateTopicsRequests(String) > kafka.server.CreateTopicsRequestTest.testValidCreateTopicsRequests(String)[1] PASSED CreateTopicsRequestTest > testValidCreateTopicsRequests(String) > kafka.server.CreateTopicsRequestTest.testValidCreateTopicsRequests(String)[2] PASSED PlaintextConsumerTest > testMultiConsumerSessionTimeoutOnStopPolling() PASSED CreateTopicsRequestTest > testErrorCreateTopicsRequests(String) > kafka.server.CreateTopicsRequestTest.testErrorCreateTopicsRequests(String)[1] PASSED CreateTopicsRequestTest > testErrorCreateTopicsRequests(String) > kafka.server.CreateTopicsRequestTest.testErrorCreateTopicsRequests(String)[2] PASSED CreateTopicsRequestTest > testCreateTopicsWithVeryShortTimeouts(String) > kafka.server.CreateTopicsRequestTest.testCreateTopicsWithVeryShortTimeouts(String)[1] PASSED ResetConsumerGroupOffsetTest > testResetOffsetsAllTopicsAllGroups() PASSED CreateTopicsRequestTest > testCreateTopicsRequestVersions(String) > kafka.server.CreateTopicsRequestTest.testCreateTopicsRequestVersions(String)[1] PASSED CreateTopicsRequestTest > testInvalidCreateTopicsRequests(String) > kafka.server.CreateTopicsRequestTest.testInvalidCreateTopicsRequests(String)[1] PASSED PlaintextConsumerTest > testMaxPollIntervalMsDelayInRevocation() PASSED CreateTopicsRequestTest > testInvalidCreateTopicsRequests(String) > kafka.server.CreateTopicsRequestTest.testInvalidCreateTopicsRequests(String)[2] PASSED KRaftClusterTest > testCreateClusterAndCreateListDeleteTopic() PASSED CreateTopicsRequestTest > testNotController(String) > kafka.server.CreateTopicsRequestTest.testNotController(String)[1] PASSED PlaintextConsumerTest > testPerPartitionLagMetricsCleanUpWithAssign() PASSED LogCleanerParameterizedIntegrationTest > cleanerTest(CompressionType) > kafka.log.LogCleanerParameterizedIntegrationTest.cleanerTest(CompressionType)[2] PASSED PlaintextConsumerTest > testPartitionsForInvalidTopic() PASSED FetchRequestTest > testLastFetchedEpochValidation() PASSED LogRecoveryTest > testHWCheckpointNoFailuresMultipleLogSegments() PASSED ResetConsumerGroupOffsetTest > testResetOffsetsToEarliestOnTopicsAndPartitions() PASSED FetchRequestTest > testZStdCompressedRecords() PASSED PlaintextConsumerTest > testPauseStateNotPreservedByRebalance() PASSED ResetConsumerGroupOffsetTest > testResetOffsetsByDurationFallbackToLatestWhenNoRecords() PASSED FetchRequestTest > testFetchRequestToNonReplica() PASSED PlaintextConsumerTest > testFetchHonoursFetchSizeIfLargeRecordNotFirst() PASSED LogRecoveryTest > testHWCheckpointWithFailuresMultipleLogSegments() PASSED FetchRequestTest > testBrokerRespectsPartitionsOrderAndSizeLimits() PASSED LogRecoveryTest > testHWCheckpointNoFailuresSingleLogSegment() PASSED FetchRequestTest > testZStdCompressedTopic() PASSED PlaintextConsumerTest > testSeek() PASSED FetchRequestTest > testDownConversionFromBatchedToUnbatchedRespectsOffset() PASSED FetchRequestTest > testEpochValidationWithinFetchSession() PASSED LogRecoveryTest > testHWCheckpointWithFailuresSingleLogSegment() PASSED OffsetsForLeaderEpochRequestTest > testOffsetsForLeaderEpochErrorCodes() PASSED OffsetsForLeaderEpochRequestTest > testCurrentEpochValidation() PASSED FetchRequestTest > testDownConversionWithConnectionFailure() PASSED ResetConsumerGroupOffsetTest > testResetOffsetsToEarliestOnTopics() PASSED PlaintextConsumerTest > testConsumingWithNullGroupId() PASSED LogCleanerParameterizedIntegrationTest > cleanerTest(CompressionType) > kafka.log.LogCleanerParameterizedIntegrationTest.cleanerTest(CompressionType)[3] PASSED ReplicaFetchTest > testReplicaFetcherThread() PASSED FetchRequestTest > testLastFetchedEpochValidationV12() PASSED PlaintextConsumerTest > testPositionAndCommit() PASSED ServerGenerateClusterIdTest > testAutoGenerateClusterIdForKafkaClusterParallel() PASSED FetchRequestTest > testCreateIncrementalFetchWithPartitionsInErrorV12() PASSED ServerGenerateClusterIdTest > testAutoGenerateClusterId() PASSED WARNING: An illegal reflective access operation has occurred WARNING: Illegal reflective access by kafka.security.minikdc.MiniKdc (file:/home/ubuntu/anant/kafka/core/build/classes/scala/test/) to method sun.security.krb5.Config.refresh() WARNING: Please consider reporting this to the maintainers of kafka.security.minikdc.MiniKdc WARNING: Use --illegal-access=warn to enable warnings of further illegal reflective access operations WARNING: All illegal access operations will be denied in a future release PlaintextConsumerTest > testFetchRecordLargerThanMaxPartitionFetchBytes() PASSED FetchRequestTest > testCurrentEpochValidation() PASSED ServerGenerateClusterIdTest > testAutoGenerateClusterIdForKafkaClusterSequential() PASSED ServerGenerateClusterIdTest > testInconsistentBrokerMetadataBetweenMultipleLogDirs() PASSED FetchRequestTest > testCurrentEpochValidationV12() PASSED ServerGenerateClusterIdTest > testInconsistentClusterIdFromZookeeperAndFromMetaProps() PASSED PlaintextConsumerTest > testUnsubscribeTopic() PASSED ServerGenerateClusterIdTest > testConsistentClusterIdFromZookeeperAndFromMetaProps() PASSED FetchRequestTest > testFetchWithPartitionsWithIdError() PASSED DescribeAuthorizedOperationsTest > testClusterAuthorizedOperations() PASSED FetchRequestTest > testEpochValidationWithinFetchSessionV12() PASSED LeaderEpochIntegrationTest > shouldIncreaseLeaderEpochBetweenLeaderRestarts() PASSED FetchRequestTest > testFetchRequestV4WithReadCommitted() PASSED LeaderElectionTest > testLeaderElectionWithStaleControllerEpoch() PASSED LeaderEpochIntegrationTest > shouldAddCurrentLeaderEpochToMessagesAsTheyAreWrittenToLeader() PASSED DescribeAuthorizedOperationsTest > testTopicAuthorizedOperations() PASSED LeaderEpochIntegrationTest > shouldSendLeaderEpochRequestAndGetAResponse() PASSED PlaintextConsumerTest > testMultiConsumerSessionTimeoutOnClose() PASSED LeaderElectionTest > testLeaderElectionAndEpoch() PASSED MetadataRequestTest > testIsrAfterBrokerShutDownAndJoinsBack(String) > kafka.server.MetadataRequestTest.testIsrAfterBrokerShutDownAndJoinsBack(String)[1] PASSED DescribeAuthorizedOperationsTest > testConsumerGroupAuthorizedOperations() PASSED LogCleanerParameterizedIntegrationTest > cleanerTest(CompressionType) > kafka.log.LogCleanerParameterizedIntegrationTest.cleanerTest(CompressionType)[4] PASSED ProducerFailureHandlingTest > testCannotSendToInternalTopic() PASSED ProducerFailureHandlingTest > testTooLargeRecordWithAckOne() PASSED PlaintextConsumerTest > testMultiConsumerStickyAssignor() PASSED PlaintextConsumerTest > testFetchRecordLargerThanFetchMaxBytes() PASSED PlaintextConsumerTest > testAutoCommitOnClose() PASSED PlaintextConsumerTest > testListTopics() PASSED PlaintextConsumerTest > testExpandingTopicSubscriptions() PASSED MetadataRequestTest > testIsrAfterBrokerShutDownAndJoinsBack(String) > kafka.server.MetadataRequestTest.testIsrAfterBrokerShutDownAndJoinsBack(String)[2] PASSED ProducerFailureHandlingTest > testWrongBrokerList() PASSED MetadataRequestTest > testReplicaDownResponse(String) > kafka.server.MetadataRequestTest.testReplicaDownResponse(String)[1] PASSED ProducerFailureHandlingTest > testNotEnoughReplicas() PASSED ProducerFailureHandlingTest > testResponseTooLargeForReplicationWithAckAll() PASSED LogCleanerParameterizedIntegrationTest > cleanerTest(CompressionType) > kafka.log.LogCleanerParameterizedIntegrationTest.cleanerTest(CompressionType)[5] PASSED PlaintextConsumerTest > testMultiConsumerDefaultAssignor() PASSED PlaintextConsumerTest > testInterceptors() PASSED PlaintextConsumerTest > testConsumingWithEmptyGroupId() PASSED MetadataRequestTest > testReplicaDownResponse(String) > kafka.server.MetadataRequestTest.testReplicaDownResponse(String)[2] PASSED MetadataRequestTest > testAutoCreateOfCollidingTopics(String) > kafka.server.MetadataRequestTest.testAutoCreateOfCollidingTopics(String)[1] PASSED MetadataRequestTest > testRack(String) > kafka.server.MetadataRequestTest.testRack(String)[1] PASSED MetadataRequestTest > testRack(String) > kafka.server.MetadataRequestTest.testRack(String)[2] PASSED PlaintextConsumerTest > testPatternUnsubscription() PASSED ProducerFailureHandlingTest > testNonExistentTopic() PASSED MetadataRequestTest > testTopicIdsInResponse(String) > kafka.server.MetadataRequestTest.testTopicIdsInResponse(String)[1] PASSED MetadataRequestTest > testTopicIdsInResponse(String) > kafka.server.MetadataRequestTest.testTopicIdsInResponse(String)[2] PASSED PlaintextConsumerTest > testGroupConsumption() PASSED MetadataRequestTest > testIsInternal(String) > kafka.server.MetadataRequestTest.testIsInternal(String)[1] PASSED MetadataRequestTest > testIsInternal(String) > kafka.server.MetadataRequestTest.testIsInternal(String)[2] PASSED PlaintextConsumerTest > testPartitionsFor() PASSED MetadataRequestTest > testControllerId() > kafka.server.MetadataRequestTest.testControllerId()[1] PASSED MetadataRequestTest > testAliveBrokersWithNoTopics(String) > kafka.server.MetadataRequestTest.testAliveBrokersWithNoTopics(String)[1] PASSED PlaintextConsumerTest > testMultiConsumerDefaultAssignorAndVerifyAssignment() PASSED LogCleanerParameterizedIntegrationTest > testCleanerWithMessageFormatV0(CompressionType) > kafka.log.LogCleanerParameterizedIntegrationTest.testCleanerWithMessageFormatV0(CompressionType)[1] PASSED PlaintextConsumerTest > testAutoCommitOnRebalance() PASSED PlaintextConsumerTest > testInterceptorsWithWrongKeyValue() PASSED ProducerFailureHandlingTest > testInvalidPartition() PASSED PlaintextConsumerTest > testPerPartitionLeadWithMaxPollRecords() PASSED ProducerFailureHandlingTest > testSendAfterClosed() PASSED ProducerFailureHandlingTest > testTooLargeRecordWithAckZero() PASSED PlaintextConsumerTest > testHeaders() PASSED ProducerFailureHandlingTest > testPartitionTooLargeForReplicationWithAckAll() PASSED ProducerFailureHandlingTest > testNotEnoughReplicasAfterBrokerShutdown() PASSED PlaintextConsumerTest > testMaxPollIntervalMsDelayInAssignment() PASSED MetadataRequestTest > testAliveBrokersWithNoTopics(String) > kafka.server.MetadataRequestTest.testAliveBrokersWithNoTopics(String)[2] PASSED PlaintextConsumerTest > testHeadersSerializerDeserializer() PASSED MetadataRequestTest > testAllTopicsRequest(String) > kafka.server.MetadataRequestTest.testAllTopicsRequest(String)[1] PASSED MetadataRequestTest > testAllTopicsRequest(String) > kafka.server.MetadataRequestTest.testAllTopicsRequest(String)[2] PASSED PlaintextConsumerTest > testDeprecatedPollBlocksForAssignment() PASSED MetadataRequestTest > testClusterIdIsValid(String) > kafka.server.MetadataRequestTest.testClusterIdIsValid(String)[1] PASSED SaslMultiMechanismConsumerTest > testCoordinatorFailover() PASSED MetadataRequestTest > testClusterIdIsValid(String) > kafka.server.MetadataRequestTest.testClusterIdIsValid(String)[2] PASSED LogCleanerParameterizedIntegrationTest > testCleanerWithMessageFormatV0(CompressionType) > kafka.log.LogCleanerParameterizedIntegrationTest.testCleanerWithMessageFormatV0(CompressionType)[2] PASSED MetadataRequestTest > testNoTopicsRequest(String) > kafka.server.MetadataRequestTest.testNoTopicsRequest(String)[1] PASSED MetadataRequestTest > testNoTopicsRequest(String) > kafka.server.MetadataRequestTest.testNoTopicsRequest(String)[2] PASSED PlaintextConsumerTest > testPartitionPauseAndResume() PASSED MetadataRequestTest > testAutoCreateTopicWithInvalidReplicationFactor(String) > kafka.server.MetadataRequestTest.testAutoCreateTopicWithInvalidReplicationFactor(String)[1] PASSED MetadataRequestTest > testAutoCreateTopicWithInvalidReplicationFactor(String) > kafka.server.MetadataRequestTest.testAutoCreateTopicWithInvalidReplicationFactor(String)[2] PASSED PlaintextConsumerTest > testQuotaMetricsNotCreatedIfNoQuotasConfigured() PASSED MetadataRequestTest > testPreferredReplica(String) > kafka.server.MetadataRequestTest.testPreferredReplica(String)[1] PASSED MetadataRequestTest > testPreferredReplica(String) > kafka.server.MetadataRequestTest.testPreferredReplica(String)[2] PASSED SaslMultiMechanismConsumerTest > testSimpleConsumption() PASSED MetadataRequestTest > testClusterIdWithRequestVersion1(String) > kafka.server.MetadataRequestTest.testClusterIdWithRequestVersion1(String)[1] PASSED MetadataRequestTest > testClusterIdWithRequestVersion1(String) > kafka.server.MetadataRequestTest.testClusterIdWithRequestVersion1(String)[2] PASSED PlaintextConsumerTest > testPerPartitionLagMetricsCleanUpWithSubscribe() PASSED MetadataRequestTest > testAutoTopicCreation(String) > kafka.server.MetadataRequestTest.testAutoTopicCreation(String)[1] PASSED MetadataRequestTest > testAutoTopicCreation(String) > kafka.server.MetadataRequestTest.testAutoTopicCreation(String)[2] PASSED PlaintextConsumerTest > testConsumeMessagesWithLogAppendTime() PASSED PlaintextConsumerTest > testPerPartitionLagMetricsWhenReadCommitted() PASSED SaslMultiMechanismConsumerTest > testMultipleBrokerMechanisms() PASSED PlaintextConsumerTest > testMultiConsumerRoundRobinAssignor() PASSED LogCleanerParameterizedIntegrationTest > testCleanerWithMessageFormatV0(CompressionType) > kafka.log.LogCleanerParameterizedIntegrationTest.testCleanerWithMessageFormatV0(CompressionType)[3] PASSED SaslPlainSslEndToEndAuthorizationTest > testNoConsumeWithoutDescribeAclViaSubscribe() PASSED PlaintextConsumerTest > testAutoCommitOnCloseAfterWakeup() PASSED PlaintextConsumerTest > testMaxPollRecords() PASSED ReplicationQuotasTest > shouldBootstrapTwoBrokersWithLeaderThrottle() PASSED SaslPlainSslEndToEndAuthorizationTest > testProduceConsumeWithPrefixedAcls() PASSED PlaintextConsumerTest > testAutoOffsetReset() PASSED PlaintextConsumerTest > testPerPartitionLagWithMaxPollRecords() PASSED ReplicationQuotasTest > shouldThrottleOldSegments() PASSED SaslPlainSslEndToEndAuthorizationTest > testProduceConsumeViaAssign() PASSED PlaintextConsumerTest > testFetchInvalidOffset() PASSED PlaintextConsumerTest > testAutoCommitIntercept() PASSED SaslPlainSslEndToEndAuthorizationTest > testNoConsumeWithDescribeAclViaAssign() PASSED PlaintextConsumerTest > testStaticConsumerDetectsNewPartitionCreatedAfterRestart() PASSED LogCleanerParameterizedIntegrationTest > testCleanerWithMessageFormatV0(CompressionType) > kafka.log.LogCleanerParameterizedIntegrationTest.testCleanerWithMessageFormatV0(CompressionType)[4] PASSED PlaintextConsumerTest > testFetchHonoursMaxPartitionFetchBytesIfLargeRecordNotFirst() PASSED DynamicConnectionQuotaTest > testDynamicConnectionQuota() PASSED PlaintextConsumerTest > testCommitSpecifiedOffsets() PASSED SaslPlainSslEndToEndAuthorizationTest > testProduceConsumeTopicAutoCreateTopicCreateAcl() PASSED DynamicConnectionQuotaTest > testDynamicListenerConnectionQuota() PASSED PlaintextConsumerTest > testPerPartitionLeadMetricsCleanUpWithSubscribe() PASSED ReplicationQuotasTest > shouldBootstrapTwoBrokersWithFollowerThrottle() PASSED PlaintextConsumerTest > testCommitMetadata() PASSED SaslPlainSslEndToEndAuthorizationTest > testProduceConsumeWithWildcardAcls() PASSED RequestQuotaTest > testUnauthorizedThrottle() PASSED RequestQuotaTest > testResponseThrottleTimeWhenBothFetchAndRequestQuotasViolated() PASSED RequestQuotaTest > testUnthrottledClient() PASSED RequestQuotaTest > testExemptRequestTime() PASSED PlaintextConsumerTest > testRoundRobinAssignment() PASSED RequestQuotaTest > testResponseThrottleTime() PASSED SaslPlainSslEndToEndAuthorizationTest > testNoConsumeWithDescribeAclViaSubscribe() PASSED RequestQuotaTest > testResponseThrottleTimeWhenBothProduceAndRequestQuotasViolated() PASSED PlaintextConsumerTest > testPatternSubscription() PASSED SaslPlainSslEndToEndAuthorizationTest > testNoConsumeWithoutDescribeAclViaAssign() PASSED SaslPlainPlaintextConsumerTest > testCoordinatorFailover() PASSED EpochDrivenReplicationProtocolAcceptanceTest > shouldSurviveFastLeaderChange() PASSED SaslPlainPlaintextConsumerTest > testSimpleConsumption() PASSED SaslPlainPlaintextConsumerTest > testZkAclsDisabled() PASSED SaslPlainSslEndToEndAuthorizationTest > testNoGroupAcl() PASSED SaslPlainSslEndToEndAuthorizationTest > testNoProduceWithDescribeAcl(boolean) > kafka.api.SaslPlainSslEndToEndAuthorizationTest.testNoProduceWithDescribeAcl(boolean)[1] PASSED SaslScramSslEndToEndAuthorizationTest > testNoConsumeWithoutDescribeAclViaSubscribe() PASSED SaslPlainSslEndToEndAuthorizationTest > testNoProduceWithDescribeAcl(boolean) > kafka.api.SaslPlainSslEndToEndAuthorizationTest.testNoProduceWithDescribeAcl(boolean)[2] PASSED SaslScramSslEndToEndAuthorizationTest > testProduceConsumeWithPrefixedAcls() PASSED SaslPlainSslEndToEndAuthorizationTest > testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl(boolean) > kafka.api.SaslPlainSslEndToEndAuthorizationTest.testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl(boolean)[1] PASSED SaslScramSslEndToEndAuthorizationTest > testProduceConsumeViaAssign() PASSED SaslPlainSslEndToEndAuthorizationTest > testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl(boolean) > kafka.api.SaslPlainSslEndToEndAuthorizationTest.testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl(boolean)[2] PASSED SaslScramSslEndToEndAuthorizationTest > testNoConsumeWithDescribeAclViaAssign() PASSED SaslPlainSslEndToEndAuthorizationTest > testProduceConsumeViaSubscribe() PASSED SaslScramSslEndToEndAuthorizationTest > testProduceConsumeTopicAutoCreateTopicCreateAcl() PASSED SaslPlainSslEndToEndAuthorizationTest > testTwoConsumersWithDifferentSaslCredentials() PASSED SaslScramSslEndToEndAuthorizationTest > testProduceConsumeWithWildcardAcls() PASSED SaslPlainSslEndToEndAuthorizationTest > testAcls() PASSED LogCleanerLagIntegrationTest > cleanerTest(CompressionType) > kafka.log.LogCleanerLagIntegrationTest.cleanerTest(CompressionType)[1] PASSED SaslScramSslEndToEndAuthorizationTest > testNoConsumeWithDescribeAclViaSubscribe() PASSED LogCleanerLagIntegrationTest > cleanerTest(CompressionType) > kafka.log.LogCleanerLagIntegrationTest.cleanerTest(CompressionType)[2] PASSED LogCleanerLagIntegrationTest > cleanerTest(CompressionType) > kafka.log.LogCleanerLagIntegrationTest.cleanerTest(CompressionType)[3] PASSED LogCleanerLagIntegrationTest > cleanerTest(CompressionType) > kafka.log.LogCleanerLagIntegrationTest.cleanerTest(CompressionType)[4] PASSED DynamicConnectionQuotaTest > testDynamicListenerConnectionCreationRateQuota() PASSED SaslScramSslEndToEndAuthorizationTest > testNoConsumeWithoutDescribeAclViaAssign() PASSED LogCleanerLagIntegrationTest > cleanerTest(CompressionType) > kafka.log.LogCleanerLagIntegrationTest.cleanerTest(CompressionType)[5] PASSED AclAuthorizerTest > testAuthorizeWithPrefixedResource() PASSED AclAuthorizerTest > testAllowAllAccess() PASSED AclAuthorizerTest > testAuthorizerNoZkConfig() PASSED AclAuthorizerTest > testLocalConcurrentModificationOfResourceAcls() PASSED AclAuthorizerTest > testDeleteAllAclOnWildcardResource() PASSED AclAuthorizerTest > testAddAclsOnPrefixedResource() PASSED AclAuthorizerTest > testAuthorizerZkConfigFromKafkaConfigWithDefaults() PASSED AclAuthorizerTest > testHighConcurrencyDeletionOfResourceAcls() PASSED SaslScramSslEndToEndAuthorizationTest > testNoGroupAcl() PASSED AclAuthorizerTest > testNoAclFound() PASSED AclAuthorizerTest > testAclInheritance() PASSED AclAuthorizerTest > testDistributedConcurrentModificationOfResourceAcls() PASSED AclAuthorizerTest > testAddAclsOnWildcardResource() PASSED AclAuthorizerTest > testWritesExtendedAclChangeEventWhenInterBrokerProtocolAtLeastKafkaV2() PASSED AclAuthorizerTest > testAuthorizerZkConfigFromPrefixOverrides() PASSED AclAuthorizerTest > testAclsFilter() PASSED AclAuthorizerTest > testAclManagementAPIs() PASSED AclAuthorizerTest > testWildCardAcls() PASSED SaslScramSslEndToEndAuthorizationTest > testNoProduceWithDescribeAcl(boolean) > kafka.api.SaslScramSslEndToEndAuthorizationTest.testNoProduceWithDescribeAcl(boolean)[1] PASSED AclAuthorizerTest > testCreateDeleteTiming() PASSED AclAuthorizerTest > testAuthorizeByResourceTypeWithAllHostAce() PASSED AclAuthorizerTest > testWritesLiteralAclChangeEventWhenInterBrokerProtocolIsKafkaV2() PASSED AclAuthorizerTest > testTopicAcl() PASSED AclAuthorizerTest > testSuperUserHasAccess() PASSED AclAuthorizerTest > testDeleteAclOnPrefixedResource() PASSED AclAuthorizerTest > testDenyTakesPrecedence() PASSED AclAuthorizerTest > testAuthorizeByResourceTypeIsolationUnrelatedDenyWontDominateAllow() PASSED AclAuthorizerTest > testSingleCharacterResourceAcls() PASSED SaslScramSslEndToEndAuthorizationTest > testNoProduceWithDescribeAcl(boolean) > kafka.api.SaslScramSslEndToEndAuthorizationTest.testNoProduceWithDescribeAcl(boolean)[2] PASSED AclAuthorizerTest > testNoAclFoundOverride() PASSED AclAuthorizerTest > testAuthorizeByResourceTypeWildcardResourceDenyDominate() PASSED AclAuthorizerTest > testEmptyAclThrowsException() PASSED AclAuthorizerTest > testAuthorizeByResourceTypeNoAclFoundOverride() PASSED AclAuthorizerTest > testSuperUserWithCustomPrincipalHasAccess() PASSED AclAuthorizerTest > testAuthorizeByResourceTypeWithAllOperationAce() PASSED AclAuthorizerTest > testAllowAccessWithCustomPrincipal() PASSED AclAuthorizerTest > testDeleteAclOnWildcardResource() PASSED AclAuthorizerTest > testAuthorizerZkConfigFromKafkaConfig() PASSED AclAuthorizerTest > testChangeListenerTiming() PASSED AclAuthorizerTest > testWritesLiteralWritesLiteralAclChangeEventWhenInterBrokerProtocolLessThanKafkaV2eralAclChangesForOlderProtocolVersions() PASSED EpochDrivenReplicationProtocolAcceptanceTest > offsetsShouldNotGoBackwards() PASSED AclAuthorizerTest > testAuthorzeByResourceTypeSuperUserHasAccess() PASSED AclAuthorizerTest > testAuthorizeByResourceTypePrefixedResourceDenyDominate() PASSED SaslScramSslEndToEndAuthorizationTest > testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl(boolean) > kafka.api.SaslScramSslEndToEndAuthorizationTest.testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl(boolean)[1] PASSED AclAuthorizerTest > testAuthorizeByResourceTypeMultipleAddAndRemove() PASSED AclAuthorizerTest > testThrowsOnAddPrefixedAclIfInterBrokerProtocolVersionTooLow() PASSED EpochDrivenReplicationProtocolAcceptanceTest > shouldFollowLeaderEpochBasicWorkflow() PASSED AclAuthorizerTest > testAccessAllowedIfAllowAclExistsOnPrefixedResource() PASSED AclAuthorizerTest > testAuthorizeByResourceTypeDenyTakesPrecedence() PASSED AclAuthorizerTest > testHighConcurrencyModificationOfResourceAcls() PASSED AclAuthorizerTest > testAuthorizeByResourceTypeWithAllPrincipalAce() PASSED AclAuthorizerTest > testAuthorizeWithEmptyResourceName() PASSED EpochDrivenReplicationProtocolAcceptanceTest > shouldNotAllowDivergentLogs() PASSED AclAuthorizerTest > testAuthorizeThrowsOnNonLiteralResource() PASSED AclAuthorizerTest > testDeleteAllAclOnPrefixedResource() PASSED AclAuthorizerTest > testAddAclsOnLiteralResource() PASSED AclAuthorizerTest > testGetAclsPrincipal() PASSED AclAuthorizerTest > testWritesExtendedAclChangeEventIfInterBrokerProtocolNotSet() PASSED SaslScramSslEndToEndAuthorizationTest > testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl(boolean) > kafka.api.SaslScramSslEndToEndAuthorizationTest.testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl(boolean)[2] PASSED AclAuthorizerTest > testAccessAllowedIfAllowAclExistsOnWildcardResource() PASSED AclAuthorizerTest > testLoadCache() PASSED AdvertiseBrokerTest > testBrokerAdvertiseListenersToZK() PASSED EpochDrivenReplicationProtocolAcceptanceTest > logsShouldNotDivergeOnUncleanLeaderElections() PASSED AdvertiseBrokerTest > testBrokerAdvertiseListenersWithCustomNamesToZK() PASSED AlterUserScramCredentialsRequestNotAuthorizedTest > testAlterNothingNotAuthorized() PASSED AlterUserScramCredentialsRequestNotAuthorizedTest > testAlterSomethingNotAuthorized() PASSED SaslScramSslEndToEndAuthorizationTest > testProduceConsumeViaSubscribe() PASSED CreateTopicsRequestWithForwardingTest > testForwardToController(String) > kafka.server.CreateTopicsRequestWithForwardingTest.testForwardToController(String)[1] PASSED CreateTopicsRequestWithForwardingTest > testForwardToController(String) > kafka.server.CreateTopicsRequestWithForwardingTest.testForwardToController(String)[2] PASSED DelegationTokenRequestsOnPlainTextTest > testDelegationTokenRequests() PASSED SaslScramSslEndToEndAuthorizationTest > testTwoConsumersWithDifferentSaslCredentials() PASSED DynamicBrokerReconfigurationTest > testDefaultTopicConfig() PASSED DynamicConnectionQuotaTest > testDynamicIpConnectionRateQuota() PASSED ZkAuthorizationTest > testIsZkSecurityEnabled() PASSED ZkAuthorizationTest > testKafkaZkClient() PASSED SslAdminIntegrationTest > testCreateDeleteTopics() PASSED ZkAuthorizationTest > testZkAntiMigration() PASSED ZkAuthorizationTest > testConsumerOffsetPathAcls() PASSED ZkAuthorizationTest > testZkMigration() PASSED DynamicBrokerReconfigurationTest > testMetricsReporterUpdate() PASSED ZkAuthorizationTest > testChroot() PASSED ZkAuthorizationTest > testDelete() PASSED ZkAuthorizationTest > testDeleteRecursive() PASSED ClientQuotasRequestTest > testAlterClientQuotasInvalidRequests() > kafka.server.ClientQuotasRequestTest.testAlterClientQuotasInvalidRequests()[1] PASSED ClientQuotasRequestTest > testAlterClientQuotasInvalidRequests() > kafka.server.ClientQuotasRequestTest.testAlterClientQuotasInvalidRequests()[2] PASSED ClientQuotasRequestTest > testDescribeClientQuotasMatchPartial() > kafka.server.ClientQuotasRequestTest.testDescribeClientQuotasMatchPartial()[1] PASSED SslAdminIntegrationTest > testAuthorizedOperations() PASSED ClientQuotasRequestTest > testDescribeClientQuotasMatchPartial() > kafka.server.ClientQuotasRequestTest.testDescribeClientQuotasMatchPartial()[2] PASSED ClientQuotasRequestTest > testAlterIpQuotasRequest() > kafka.server.ClientQuotasRequestTest.testAlterIpQuotasRequest()[1] PASSED ClientQuotasRequestTest > testAlterIpQuotasRequest() > kafka.server.ClientQuotasRequestTest.testAlterIpQuotasRequest()[2] PASSED ClientQuotasRequestTest > testAlterClientQuotasRequestValidateOnly() > kafka.server.ClientQuotasRequestTest.testAlterClientQuotasRequestValidateOnly()[1] PASSED ClientQuotasRequestTest > testAlterClientQuotasRequestValidateOnly() > kafka.server.ClientQuotasRequestTest.testAlterClientQuotasRequestValidateOnly()[2] PASSED ClientQuotasRequestTest > testClientQuotasSanitized() > kafka.server.ClientQuotasRequestTest.testClientQuotasSanitized()[1] PASSED SslAdminIntegrationTest > testAclDescribe() PASSED DynamicBrokerReconfigurationTest > testAdvertisedListenerUpdate() PASSED ClientQuotasRequestTest > testClientQuotasSanitized() > kafka.server.ClientQuotasRequestTest.testClientQuotasSanitized()[2] PASSED ClientQuotasRequestTest > testAlterClientQuotasBadIp() > kafka.server.ClientQuotasRequestTest.testAlterClientQuotasBadIp()[1] PASSED ClientQuotasRequestTest > testAlterClientQuotasBadIp() > kafka.server.ClientQuotasRequestTest.testAlterClientQuotasBadIp()[2] PASSED ClientQuotasRequestTest > testDescribeClientQuotasInvalidFilterCombination() > kafka.server.ClientQuotasRequestTest.testDescribeClientQuotasInvalidFilterCombination()[1] PASSED ClientQuotasRequestTest > testDescribeClientQuotasInvalidFilterCombination() > kafka.server.ClientQuotasRequestTest.testDescribeClientQuotasInvalidFilterCombination()[2] PASSED ClientQuotasRequestTest > testClientQuotasForScramUsers() > kafka.server.ClientQuotasRequestTest.testClientQuotasForScramUsers()[1] PASSED ClientQuotasRequestTest > testClientQuotasUnsupportedEntityTypes() > kafka.server.ClientQuotasRequestTest.testClientQuotasUnsupportedEntityTypes()[1] PASSED DynamicBrokerReconfigurationTest > testConsecutiveConfigChange() PASSED ClientQuotasRequestTest > testClientQuotasUnsupportedEntityTypes() > kafka.server.ClientQuotasRequestTest.testClientQuotasUnsupportedEntityTypes()[2] PASSED ClientQuotasRequestTest > testClientQuotasWithDefaultName() > kafka.server.ClientQuotasRequestTest.testClientQuotasWithDefaultName()[1] PASSED SslAdminIntegrationTest > testLegacyAclOpsNeverAffectOrReturnPrefixed() PASSED ClientQuotasRequestTest > testClientQuotasWithDefaultName() > kafka.server.ClientQuotasRequestTest.testClientQuotasWithDefaultName()[2] PASSED ClientQuotasRequestTest > testAlterClientQuotasRequest() > kafka.server.ClientQuotasRequestTest.testAlterClientQuotasRequest()[1] PASSED ClientQuotasRequestTest > testAlterClientQuotasRequest() > kafka.server.ClientQuotasRequestTest.testAlterClientQuotasRequest()[2] PASSED ClientQuotasRequestTest > testDescribeClientQuotasMatchExact() > kafka.server.ClientQuotasRequestTest.testDescribeClientQuotasMatchExact()[1] PASSED ClientQuotasRequestTest > testDescribeClientQuotasMatchExact() > kafka.server.ClientQuotasRequestTest.testDescribeClientQuotasMatchExact()[2] PASSED ClientQuotasRequestTest > testAlterClientQuotasInvalidEntityCombination() > kafka.server.ClientQuotasRequestTest.testAlterClientQuotasInvalidEntityCombination()[1] PASSED SslAdminIntegrationTest > testCreateTopicsResponseMetadataAndConfig() PASSED ClientQuotasRequestTest > testAlterClientQuotasInvalidEntityCombination() > kafka.server.ClientQuotasRequestTest.testAlterClientQuotasInvalidEntityCombination()[2] PASSED ControllerMutationQuotaTest > testUnboundedCreateTopicsRequest() PASSED SslAdminIntegrationTest > testAttemptToCreateInvalidAcls() PASSED DynamicBrokerReconfigurationTest > testThreadPoolResize() PASSED SslAdminIntegrationTest > testAclAuthorizationDenied() PASSED ControllerMutationQuotaTest > testStrictCreatePartitionsRequest() PASSED ControllerMutationQuotaTest > testPermissiveCreateTopicsRequest() PASSED SslAdminIntegrationTest > testAclOperations() PASSED DynamicBrokerReconfigurationTest > testAddRemoveSaslListeners() PASSED SslAdminIntegrationTest > testAclOperations2() PASSED ControllerMutationQuotaTest > testStrictDeleteTopicsRequest() PASSED ControllerMutationQuotaTest > testQuotaMetric() PASSED ControllerMutationQuotaTest > testSetUnsetQuota() PASSED ControllerMutationQuotaTest > testUnboundedDeleteTopicsRequest() PASSED SslAdminIntegrationTest > testAclDelete() PASSED DynamicBrokerReconfigurationTest > testTrustStoreAlter() PASSED ControllerMutationQuotaTest > testUnboundedCreatePartitionsRequest() PASSED ControllerMutationQuotaTest > testPermissiveDeleteTopicsRequest() PASSED ControllerMutationQuotaTest > testPermissiveCreatePartitionsRequest() PASSED DynamicBrokerReconfigurationTest > testConfigDescribeUsingAdminClient() PASSED DynamicBrokerReconfigurationTest > testUncleanLeaderElectionEnable() PASSED ControllerMutationQuotaTest > testStrictCreateTopicsRequest() PASSED SslAdminIntegrationTest > testAsynchronousAuthorizerAclUpdatesDontBlockRequestThreads() PASSED DescribeUserScramCredentialsRequestTest > testDescribeNotController() PASSED DescribeUserScramCredentialsRequestTest > testUnknownUser() PASSED DescribeUserScramCredentialsRequestTest > testDescribeSameUserTwice() PASSED DescribeUserScramCredentialsRequestTest > testDescribeWithNull() PASSED DescribeUserScramCredentialsRequestTest > testDescribeNothing() PASSED FetchRequestMaxBytesTest > testConsumeMultipleRecords() PASSED DynamicBrokerReconfigurationTest > testKeyStoreAlter() PASSED GssapiAuthenticationTest > testServerNotFoundInKerberosDatabase() PASSED DynamicBrokerReconfigurationTest > testUpdatesUsingConfigProvider() PASSED DynamicBrokerReconfigurationTest > testAddRemoveSslListener() SKIPPED GssapiAuthenticationTest > testLoginFailure() PASSED SslAdminIntegrationTest > testSynchronousAuthorizerAclUpdatesBlockRequestThreads() PASSED DynamicBrokerReconfigurationTest > testLogCleanerConfig() PASSED FetchRequestWithLegacyMessageFormatTest > testFetchRequestV2WithOversizedMessage() PASSED KafkaMetricReporterExceptionHandlingTest > testBothReportersAreInvoked() PASSED ListOffsetsRequestTest > testResponseDefaultOffsetAndLeaderEpochForAllVersions() PASSED SslAdminIntegrationTest > testAclUpdatesUsingAsynchronousAuthorizer() PASSED ListOffsetsRequestTest > testListOffsetsMaxTimeStampOldestVersion() PASSED ListOffsetsRequestTest > testListOffsetsErrorCodes() PASSED ListOffsetsRequestTest > testCurrentEpochValidation() PASSED SslAdminIntegrationTest > testAclUpdatesUsingSynchronousAuthorizer() PASSED GssapiAuthenticationTest > testRequestIsAReplay() PASSED ListOffsetsRequestTest > testResponseIncludesLeaderEpoch() PASSED MetadataRequestWithForwardingTest > testAutoCreateOfCollidingTopics() PASSED GssapiAuthenticationTest > testServerAuthenticationFailure() PASSED MetadataRequestWithForwardingTest > testAutoCreateTopicWithInvalidReplicationFactor() PASSED MetadataRequestWithForwardingTest > testAutoTopicCreation() PASSED SaslApiVersionsRequestTest > testApiVersionsRequestWithUnsupportedVersion() > kafka.server.SaslApiVersionsRequestTest.testApiVersionsRequestWithUnsupportedVersion()[1] PASSED TransactionsExpirationTest > testBumpTransactionalEpochAfterInvalidProducerIdMapping(String) > kafka.api.TransactionsExpirationTest.testBumpTransactionalEpochAfterInvalidProducerIdMapping(String)[1] PASSED SaslApiVersionsRequestTest > testApiVersionsRequestBeforeSaslHandshakeRequest() > kafka.server.SaslApiVersionsRequestTest.testApiVersionsRequestBeforeSaslHandshakeRequest()[1] PASSED SaslApiVersionsRequestTest > testApiVersionsRequestAfterSaslHandshakeRequest() > kafka.server.SaslApiVersionsRequestTest.testApiVersionsRequestAfterSaslHandshakeRequest()[1] PASSED GssapiAuthenticationTest > testReLogin() PASSED StopReplicaRequestTest > testStopReplicaRequest() PASSED KafkaServerTest > testAlreadyRegisteredAdvertisedListeners() PASSED TopicIdWithOldInterBrokerProtocolTest > testFetchTopicIdsWithOldIBPWrongFetchVersion() PASSED KafkaServerTest > testAlterIsrManager() PASSED KafkaServerTest > testCreatesProperZkConfigWhenSaslDisabled() PASSED KafkaServerTest > testZkIsrManager() PASSED TopicIdWithOldInterBrokerProtocolTest > testDeleteTopicsWithOldIBP() PASSED KafkaServerTest > testCreatesProperZkTlsConfigWithFalseAndListValues() PASSED KafkaServerTest > testCreatesProperZkTlsConfigWhenDisabled() PASSED KafkaServerTest > testCreatesProperZkTlsConfigWithTrueValues() PASSED TopicIdWithOldInterBrokerProtocolTest > testFetchTopicIdsWithOldIBPCorrectFetchVersion() PASSED TransactionsExpirationTest > testBumpTransactionalEpochAfterInvalidProducerIdMapping(String) > kafka.api.TransactionsExpirationTest.testBumpTransactionalEpochAfterInvalidProducerIdMapping(String)[2] PASSED MetadataRequestBetweenDifferentIbpTest > testUnknownTopicId() PASSED TopicIdWithOldInterBrokerProtocolTest > testMetadataTopicIdsWithOldIBP() PASSED ProducerCompressionTest > testCompression(String) > kafka.api.test.ProducerCompressionTest.testCompression(String)[1] PASSED ServerStartupTest > testBrokerStateRunningAfterZK() PASSED ServerStartupTest > testBrokerCreatesZKChroot() PASSED TopicIdWithOldInterBrokerProtocolTest > testDeleteTopicsWithOldIBPUsingIDs() PASSED ProducerCompressionTest > testCompression(String) > kafka.api.test.ProducerCompressionTest.testCompression(String)[2] PASSED ServerStartupTest > testConflictBrokerStartupWithSamePort() PASSED ProducerCompressionTest > testCompression(String) > kafka.api.test.ProducerCompressionTest.testCompression(String)[3] PASSED ServerStartupTest > testConflictBrokerRegistration() PASSED ServerStartupTest > testBrokerSelfAware() PASSED ProducerCompressionTest > testCompression(String) > kafka.api.test.ProducerCompressionTest.testCompression(String)[4] PASSED ProducerCompressionTest > testCompression(String) > kafka.api.test.ProducerCompressionTest.testCompression(String)[5] PASSED MetricsTest > testUpdateJMXFilter(String) > kafka.metrics.MetricsTest.testUpdateJMXFilter(String)[1] PASSED MetricsTest > testUpdateJMXFilter(String) > kafka.metrics.MetricsTest.testUpdateJMXFilter(String)[2] PASSED MetricsTest > testGeneralBrokerTopicMetricsAreGreedilyRegistered(String) > kafka.metrics.MetricsTest.testGeneralBrokerTopicMetricsAreGreedilyRegistered(String)[1] PASSED MetricsTest > testGeneralBrokerTopicMetricsAreGreedilyRegistered(String) > kafka.metrics.MetricsTest.testGeneralBrokerTopicMetricsAreGreedilyRegistered(String)[2] PASSED EpochDrivenReplicationProtocolAcceptanceWithIbp26Test > shouldSurviveFastLeaderChange() PASSED MetricsTest > testLinuxIoMetrics(String) > kafka.metrics.MetricsTest.testLinuxIoMetrics(String)[1] PASSED MetricsTest > testLinuxIoMetrics(String) > kafka.metrics.MetricsTest.testLinuxIoMetrics(String)[2] PASSED MetricsTest > testMetricsReporterAfterDeletingTopic(String) > kafka.metrics.MetricsTest.testMetricsReporterAfterDeletingTopic(String)[1] PASSED MetricsTest > testMetricsReporterAfterDeletingTopic(String) > kafka.metrics.MetricsTest.testMetricsReporterAfterDeletingTopic(String)[2] PASSED MetricsTest > testSessionExpireListenerMetrics(String) > kafka.metrics.MetricsTest.testSessionExpireListenerMetrics(String)[1] PASSED MetricsTest > testSessionExpireListenerMetrics(String) > kafka.metrics.MetricsTest.testSessionExpireListenerMetrics(String)[2] PASSED MetricsTest > testBrokerTopicMetricsUnregisteredAfterDeletingTopic(String) > kafka.metrics.MetricsTest.testBrokerTopicMetricsUnregisteredAfterDeletingTopic(String)[1] PASSED MetricsTest > testBrokerTopicMetricsUnregisteredAfterDeletingTopic(String) > kafka.metrics.MetricsTest.testBrokerTopicMetricsUnregisteredAfterDeletingTopic(String)[2] PASSED MetricsTest > testYammerMetricsCountMetric(String) > kafka.metrics.MetricsTest.testYammerMetricsCountMetric(String)[1] PASSED MetricsTest > testYammerMetricsCountMetric(String) > kafka.metrics.MetricsTest.testYammerMetricsCountMetric(String)[2] PASSED MetricsTest > testClusterIdMetric(String) > kafka.metrics.MetricsTest.testClusterIdMetric(String)[1] PASSED MetricsTest > testClusterIdMetric(String) > kafka.metrics.MetricsTest.testClusterIdMetric(String)[2] PASSED MetricsTest > testWindowsStyleTagNames(String) > kafka.metrics.MetricsTest.testWindowsStyleTagNames(String)[1] PASSED MetricsTest > testWindowsStyleTagNames(String) > kafka.metrics.MetricsTest.testWindowsStyleTagNames(String)[2] PASSED MetricsTest > testBrokerStateMetric(String) > kafka.metrics.MetricsTest.testBrokerStateMetric(String)[1] PASSED MetricsTest > testBrokerStateMetric(String) > kafka.metrics.MetricsTest.testBrokerStateMetric(String)[2] PASSED MetricsTest > testZkControllerMetrics(String) > kafka.metrics.MetricsTest.testZkControllerMetrics(String)[1] PASSED MetricsTest > testBrokerTopicMetricsBytesInOut(String) > kafka.metrics.MetricsTest.testBrokerTopicMetricsBytesInOut(String)[1] PASSED MetricsTest > testBrokerTopicMetricsBytesInOut(String) > kafka.metrics.MetricsTest.testBrokerTopicMetricsBytesInOut(String)[2] PASSED MetricsTest > testJMXFilter(String) > kafka.metrics.MetricsTest.testJMXFilter(String)[1] PASSED MetricsTest > testJMXFilter(String) > kafka.metrics.MetricsTest.testJMXFilter(String)[2] PASSED DelegationTokenRequestsWithDisableTokenFeatureTest > testDelegationTokenRequests() PASSED LogOffsetTest > testFetchOffsetsBeforeWithChangingSegmentSize() PASSED LogOffsetTest > testGetOffsetsBeforeEarliestTime() PASSED LogOffsetTest > testFetchOffsetByTimestampForMaxTimestampAfterTruncate() PASSED LogOffsetTest > testFetchOffsetByTimestampForMaxTimestampWithUnorderedTimestamps() PASSED LogOffsetTest > testGetOffsetsForUnknownTopic() PASSED LogOffsetTest > testFetchOffsetByTimestampForMaxTimestampWithEmptyLog() PASSED LogOffsetTest > testEmptyLogsGetOffsets() PASSED LogOffsetTest > testFetchOffsetsBeforeWithChangingSegments() PASSED LogOffsetTest > testGetOffsetsBeforeLatestTime() PASSED LogOffsetTest > testGetOffsetsBeforeNow() PASSED LogOffsetTest > testGetOffsetsAfterDeleteRecords() PASSED OffsetFetchRequestTest > testOffsetFetchRequestSingleGroup() PASSED OffsetFetchRequestTest > testOffsetFetchRequestWithMultipleGroups() PASSED OffsetFetchRequestTest > testOffsetFetchRequestWithMultipleGroupsWithOneGroupRepeating() PASSED ServerGenerateBrokerIdTest > testBrokerMetadataOnIdCollision() PASSED ServerGenerateBrokerIdTest > testAutoGenerateBrokerId() PASSED ServerGenerateBrokerIdTest > testMultipleLogDirsMetaProps() PASSED ServerGenerateBrokerIdTest > testDisableGeneratedBrokerId() PASSED ServerGenerateBrokerIdTest > testUserConfigAndGeneratedBrokerId() PASSED ServerGenerateBrokerIdTest > testConsistentBrokerIdFromUserConfigAndMetaProps() PASSED ReplicationUtilsTest > testUpdateLeaderAndIsr() PASSED ZooKeeperClientTest > testZNodeChangeHandlerForDataChange() PASSED ZooKeeperClientTest > testZooKeeperSessionStateMetric() PASSED ZooKeeperClientTest > testExceptionInBeforeInitializingSession() PASSED ZooKeeperClientTest > testGetChildrenExistingZNode() PASSED ZooKeeperClientTest > testConnection() PASSED ZooKeeperClientTest > testZNodeChangeHandlerForCreation() PASSED ZooKeeperClientTest > testGetAclExistingZNode() PASSED ZooKeeperClientTest > testSessionExpiryDuringClose() PASSED ZooKeeperClientTest > testReinitializeAfterAuthFailure() PASSED ZooKeeperClientTest > testSetAclNonExistentZNode() PASSED ZooKeeperClientTest > testConnectionLossRequestTermination() PASSED ZooKeeperClientTest > testExistsNonExistentZNode() PASSED ZooKeeperClientTest > testGetDataNonExistentZNode() PASSED ZooKeeperClientTest > testConnectionTimeout() PASSED ZooKeeperClientTest > testBlockOnRequestCompletionFromStateChangeHandler() PASSED ZooKeeperClientTest > testUnresolvableConnectString() PASSED ZooKeeperClientTest > testGetChildrenNonExistentZNode() PASSED ZooKeeperClientTest > testPipelinedGetData() PASSED ZooKeeperClientTest > testZNodeChildChangeHandlerForChildChange() PASSED ZooKeeperClientTest > testGetChildrenExistingZNodeWithChildren() PASSED ZooKeeperClientTest > testSetDataExistingZNode() PASSED ZooKeeperClientTest > testZNodeChildChangeHandlerForChildChangeNotTriggered() PASSED ZooKeeperClientTest > testMixedPipeline() PASSED ZooKeeperClientTest > testGetDataExistingZNode() PASSED ZooKeeperClientTest > testDeleteExistingZNode() PASSED ZooKeeperClientTest > testSessionExpiry() PASSED ZooKeeperClientTest > testSetDataNonExistentZNode() PASSED ZooKeeperClientTest > testConnectionViaNettyClient() PASSED ZooKeeperClientTest > testDeleteNonExistentZNode() PASSED ZooKeeperClientTest > testExistsExistingZNode() PASSED ZooKeeperClientTest > testZooKeeperStateChangeRateMetrics() PASSED ZooKeeperClientTest > testZNodeChangeHandlerForDeletion() PASSED ZooKeeperClientTest > testGetAclNonExistentZNode() PASSED ZooKeeperClientTest > testStateChangeHandlerForAuthFailure() PASSED EpochDrivenReplicationProtocolAcceptanceWithIbp26Test > offsetsShouldNotGoBackwards() PASSED EpochDrivenReplicationProtocolAcceptanceWithIbp26Test > shouldFollowLeaderEpochBasicWorkflow() PASSED EpochDrivenReplicationProtocolAcceptanceWithIbp26Test > shouldNotAllowDivergentLogs() PASSED EpochDrivenReplicationProtocolAcceptanceWithIbp26Test > logsShouldNotDivergeOnUncleanLeaderElections() PASSED 1512 tests completed, 1 failed, 7 skipped > Task :core:integrationTest FAILED FAILURE: Build failed with an exception. * What went wrong: Execution failed for task ':core:integrationTest'. > There were failing tests. See the report at: file:///home/ubuntu/anant/kafka/core/build/reports/tests/integrationTest/index.html * Try: > Run with --stacktrace option to get the stack trace. > Run with --info or --debug option to get more log output. > Run with --scan to get full insights. * Get more help at https://help.gradle.org Deprecated Gradle features were used in this build, making it incompatible with Gradle 8.0. You can use '--warning-mode all' to show the individual deprecation warnings and determine if they come from your own scripts or plugins. See https://docs.gradle.org/7.3.3/userguide/command_line_interface.html#sec:command_line_warnings BUILD FAILED in 14m 14s 202 actionable tasks: 82 executed, 120 up-to-date