You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "frankvicky (via GitHub)" <gi...@apache.org> on 2024/08/20 13:58:09 UTC
[PR] KAFKA-17372: Move `ThrottledChannelExpirationTest#testThrottledChannelDelay` and `ThrottledChannel` to server module [kafka]
frankvicky opened a new pull request, #16935:
URL: https://github.com/apache/kafka/pull/16935
JIRA Link: [KAFKA-17372](https://issues.apache.org/jira/browse/KAFKA-17372)
Migrate `ThrottledChannel` and `ThrottleCallback` to `kafka.server`
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including upgrade notes)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscribe@kafka.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [PR] KAFKA-17372: Move `ThrottledChannelExpirationTest#testThrottledChannelDelay` and `ThrottledChannel` to server module [kafka]
Posted by "chia7712 (via GitHub)" <gi...@apache.org>.
chia7712 commented on PR #16935:
URL: https://github.com/apache/kafka/pull/16935#issuecomment-2304130774
@frankvicky please rebase code to trigger CI again
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscribe@kafka.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [PR] KAFKA-17372: Move `ThrottledChannelExpirationTest#testThrottledChannelDelay` and `ThrottledChannel` to server module [kafka]
Posted by "frankvicky (via GitHub)" <gi...@apache.org>.
frankvicky commented on code in PR #16935:
URL: https://github.com/apache/kafka/pull/16935#discussion_r1726154948
##########
server/src/test/java/org/apache/kafka/server/ThrottledChannelTest.java:
##########
@@ -0,0 +1,58 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.kafka.server;
Review Comment:
I have addressed it, PTAL 😸
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscribe@kafka.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [PR] KAFKA-17372: Move `ThrottledChannelExpirationTest#testThrottledChannelDelay` and `ThrottledChannel` to server module [kafka]
Posted by "chia7712 (via GitHub)" <gi...@apache.org>.
chia7712 commented on code in PR #16935:
URL: https://github.com/apache/kafka/pull/16935#discussion_r1726147686
##########
server/src/test/java/org/apache/kafka/server/ThrottledChannelTest.java:
##########
@@ -0,0 +1,58 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.kafka.server;
Review Comment:
please move this to `org.apache.kafka.server.quota`
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscribe@kafka.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [PR] KAFKA-17372: Move `ThrottledChannelExpirationTest#testThrottledChannelDelay` and `ThrottledChannel` to server module [kafka]
Posted by "chia7712 (via GitHub)" <gi...@apache.org>.
chia7712 merged PR #16935:
URL: https://github.com/apache/kafka/pull/16935
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscribe@kafka.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [PR] KAFKA-17372: Move `ThrottledChannelExpirationTest#testThrottledChannelDelay` and `ThrottledChannel` to server module [kafka]
Posted by "frankvicky (via GitHub)" <gi...@apache.org>.
frankvicky commented on PR #16935:
URL: https://github.com/apache/kafka/pull/16935#issuecomment-2304966368
I have run the fail test on my machine and there are no failure.
```
> Configure project :
Starting build with version 4.0.0-SNAPSHOT (commit id 01ecc750) using Gradle 8.8, Java 21 and Scala 2.13.14
Build properties: maxParallelForks=11, maxScalacThreads=8, maxTestRetries=0
> Task :streams:processMessages
MessageGenerator: processed 1 Kafka message JSON files(s).
> Task :transaction-coordinator:processMessages
MessageGenerator: processed 2 Kafka message JSON files(s).
> Task :raft:processMessages
MessageGenerator: processed 1 Kafka message JSON files(s).
> Task :storage:processMessages
MessageGenerator: processed 5 Kafka message JSON files(s).
> Task :group-coordinator:processMessages
MessageGenerator: processed 22 Kafka message JSON files(s).
> Task :metadata:processMessages
MessageGenerator: processed 25 Kafka message JSON files(s).
> Task :clients:processMessages
MessageGenerator: processed 186 Kafka message JSON files(s).
> Task :clients:processTestMessages
MessageGenerator: processed 4 Kafka message JSON files(s).
> Task :core:compileScala
Unexpected javac output: warning: [options] bootstrap class path not set in conjunction with -source 8
warning: [options] source value 8 is obsolete and will be removed in a future release
warning: [options] target value 8 is obsolete and will be removed in a future release
warning: [options] To suppress warnings about obsolete options, use -Xlint:-options.
Note: Some input files use or override a deprecated API.
Note: Recompile with -Xlint:deprecation for details.
Note: /Users/frankvicky/IdeaProjects/kafka/core/src/main/java/kafka/log/remote/RemoteLogManager.java uses unchecked or unsafe operations.
Note: Recompile with -Xlint:unchecked for details.
4 warnings.
> Task :core:compileTestScala
Unexpected javac output: warning: [options] bootstrap class path not set in conjunction with -source 8
warning: [options] source value 8 is obsolete and will be removed in a future release
warning: [options] target value 8 is obsolete and will be removed in a future release
warning: [options] To suppress warnings about obsolete options, use -Xlint:-options.
Note: Some input files use or override a deprecated API.
Note: Recompile with -Xlint:deprecation for details.
Note: Some input files use unchecked or unsafe operations.
Note: Recompile with -Xlint:unchecked for details.
4 warnings.
> Task :storage:test
Gradle Test Run :storage:test > Gradle Test Executor 8 > ReassignReplicaMoveTest > executeTieredStorageTest(String) > executeTieredStorageTest(String).quorum=zk PASSED
Gradle Test Run :storage:test > Gradle Test Executor 7 > TransactionsWithTieredStoreTest > testSendOffsetsToTransactionTimeout(String) > "testSendOffsetsToTransactionTimeout(String).quorum=zk" PASSED
Gradle Test Run :storage:test > Gradle Test Executor 8 > ReassignReplicaMoveTest > executeTieredStorageTest(String) > executeTieredStorageTest(String).quorum=kraft PASSED
Gradle Test Run :storage:test > Gradle Test Executor 7 > TransactionsWithTieredStoreTest > testSendOffsetsToTransactionTimeout(String) > "testSendOffsetsToTransactionTimeout(String).quorum=kraft" PASSED
> Task :connect:runtime:test
Gradle Test Run :connect:runtime:test > Gradle Test Executor 16 > RestExtensionIntegrationTest > testRestExtensionApi() PASSED
> Task :tools:test
Gradle Test Run :tools:test > Gradle Test Executor 15 > TopicCommandIntegrationTest > testDeleteInternalTopic(String) > "testDeleteInternalTopic(String).quorum=zk" PASSED
Gradle Test Run :tools:test > Gradle Test Executor 14 > ReassignPartitionsCommandTest > testReassignment() > testReassignment [1] Type=ZK, MetadataVersion=4.0-IV0,Security=PLAINTEXT PASSED
Gradle Test Run :tools:test > Gradle Test Executor 15 > TopicCommandIntegrationTest > testDeleteInternalTopic(String) > "testDeleteInternalTopic(String).quorum=kraft" PASSED
Gradle Test Run :tools:test > Gradle Test Executor 13 > MetadataQuorumCommandTest > testDescribeQuorumStatusSuccessful(ClusterInstance) > testDescribeQuorumStatusSuccessful [1] Type=Raft-Isolated, MetadataVersion=4.0-IV0,Security=PLAINTEXT PASSED
Gradle Test Run :tools:test > Gradle Test Executor 14 > ReassignPartitionsCommandTest > testReassignment() > testReassignment [2] Type=Raft-Isolated, MetadataVersion=4.0-IV0,Security=PLAINTEXT PASSED
Gradle Test Run :tools:test > Gradle Test Executor 15 > TopicCommandIntegrationTest > testInvalidTopicLevelConfig(String) > "testInvalidTopicLevelConfig(String).quorum=zk" PASSED
Gradle Test Run :tools:test > Gradle Test Executor 14 > ReassignPartitionsCommandTest > testReassignment() > testReassignment [3] Type=Raft-Combined, MetadataVersion=4.0-IV0,Security=PLAINTEXT PASSED
Gradle Test Run :tools:test > Gradle Test Executor 15 > TopicCommandIntegrationTest > testInvalidTopicLevelConfig(String) > "testInvalidTopicLevelConfig(String).quorum=kraft" PASSED
Gradle Test Run :tools:test > Gradle Test Executor 13 > MetadataQuorumCommandTest > testDescribeQuorumStatusSuccessful(ClusterInstance) > testDescribeQuorumStatusSuccessful [2] Type=Raft-Combined, MetadataVersion=4.0-IV0,Security=PLAINTEXT PASSED
Gradle Test Run :tools:test > Gradle Test Executor 13 > MetadataQuorumCommandTest > testDescribeQuorumStatusSuccessful(ClusterInstance) > testDescribeQuorumStatusSuccessful [3] Type=Raft-Isolated, MetadataVersion=4.0-IV0,Security=PLAINTEXT PASSED
Gradle Test Run :tools:test > Gradle Test Executor 13 > MetadataQuorumCommandTest > testDescribeQuorumStatusSuccessful(ClusterInstance) > testDescribeQuorumStatusSuccessful [4] Type=Raft-Combined, MetadataVersion=4.0-IV0,Security=PLAINTEXT PASSED
Gradle Test Run :tools:test > Gradle Test Executor 15 > TopicCommandIntegrationTest > testDescribeWithDescribeTopicPartitionsApi(String) > "testDescribeWithDescribeTopicPartitionsApi(String).quorum=quorum=zk" PASSED
Gradle Test Run :tools:test > Gradle Test Executor 14 > ReassignPartitionsCommandTest > testReassignmentCompletionDuringPartialUpgrade() > testReassignmentCompletionDuringPartialUpgrade [1] Type=ZK, MetadataVersion=4.0-IV0,Security=PLAINTEXT PASSED
Gradle Test Run :tools:test > Gradle Test Executor 14 > ReassignPartitionsCommandTest > testReassignmentCompletionDuringPartialUpgrade() > testReassignmentCompletionDuringPartialUpgrade [2] Type=Raft-Isolated, MetadataVersion=4.0-IV0,Security=PLAINTEXT PASSED
Gradle Test Run :tools:test > Gradle Test Executor 13 > MetadataQuorumCommandTest > testDescribeQuorumStatusSuccessful(ClusterInstance) > testDescribeQuorumStatusSuccessful [5] Type=Raft-Isolated, MetadataVersion=4.0-IV0,Security=PLAINTEXT PASSED
Gradle Test Run :tools:test > Gradle Test Executor 15 > TopicCommandIntegrationTest > testDescribeWithDescribeTopicPartitionsApi(String) > "testDescribeWithDescribeTopicPartitionsApi(String).quorum=quorum=kraft" PASSED
Gradle Test Run :tools:test > Gradle Test Executor 14 > ReassignPartitionsCommandTest > testReassignmentCompletionDuringPartialUpgrade() > testReassignmentCompletionDuringPartialUpgrade [3] Type=Raft-Combined, MetadataVersion=4.0-IV0,Security=PLAINTEXT PASSED
Gradle Test Run :tools:test > Gradle Test Executor 13 > MetadataQuorumCommandTest > testDescribeQuorumStatusSuccessful(ClusterInstance) > testDescribeQuorumStatusSuccessful [6] Type=Raft-Combined, MetadataVersion=4.0-IV0,Security=PLAINTEXT PASSED
> Task :storage:test
Gradle Test Run :storage:test > Gradle Test Executor 7 > TransactionsWithTieredStoreTest > testSendOffsetsToTransactionTimeout(String) > "testSendOffsetsToTransactionTimeout(String).quorum=kraft+kip848" PASSED
Gradle Test Run :storage:test > Gradle Test Executor 7 > TransactionsWithTieredStoreTest > testFencingOnSend(String) > "testFencingOnSend(String).quorum=zk" PASSED
Gradle Test Run :storage:test > Gradle Test Executor 7 > TransactionsWithTieredStoreTest > testFencingOnSend(String) > "testFencingOnSend(String).quorum=kraft" PASSED
Gradle Test Run :storage:test > Gradle Test Executor 7 > TransactionsWithTieredStoreTest > testFencingOnSend(String) > "testFencingOnSend(String).quorum=kraft+kip848" PASSED
Gradle Test Run :storage:test > Gradle Test Executor 7 > TransactionsWithTieredStoreTest > testAbortTransactionTimeout(String) > "testAbortTransactionTimeout(String).quorum=zk" PASSED
Gradle Test Run :storage:test > Gradle Test Executor 7 > TransactionsWithTieredStoreTest > testAbortTransactionTimeout(String) > "testAbortTransactionTimeout(String).quorum=kraft" PASSED
> Task :streams:test
WARNING: unexpectedly got output for a test [org.apache.kafka.streams.integration.IQv2StoreIntegrationTest.verifyStore(boolean, boolean, StoresToTest, String)] that we didn't previously see in the beforeTest hook. Message for debugging: [[2024-08-22 23:10:13,960] INFO Generating test cases according to random seed: -7591578273721546613 (org.apache.kafka.streams.integration.IQv2StoreIntegrationTest:358)
].
Gradle Test Run :streams:test > Gradle Test Executor 20 > RangeQueryIntegrationTest > testStoreConfig(StoreType, boolean, boolean, boolean) > "testStoreConfig(StoreType, boolean, boolean, boolean).storeType=InMemory, enableLogging=true, enableCaching=true, forward=true" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=true, log=true, storeToTest=IN_MEMORY_SESSION, kind=PAPI" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 20 > RangeQueryIntegrationTest > testStoreConfig(StoreType, boolean, boolean, boolean) > "testStoreConfig(StoreType, boolean, boolean, boolean).storeType=InMemory, enableLogging=true, enableCaching=true, forward=false" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=true, log=false, storeToTest=TIME_ROCKS_KV, kind=PAPI" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 20 > RangeQueryIntegrationTest > testStoreConfig(StoreType, boolean, boolean, boolean) > "testStoreConfig(StoreType, boolean, boolean, boolean).storeType=InMemory, enableLogging=true, enableCaching=false, forward=true" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=false, log=false, storeToTest=TIME_ROCKS_WINDOW, kind=PAPI" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 20 > RangeQueryIntegrationTest > testStoreConfig(StoreType, boolean, boolean, boolean) > "testStoreConfig(StoreType, boolean, boolean, boolean).storeType=InMemory, enableLogging=true, enableCaching=false, forward=false" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=false, log=true, storeToTest=GLOBAL_IN_MEMORY_LRU, kind=DSL" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 20 > RangeQueryIntegrationTest > testStoreConfig(StoreType, boolean, boolean, boolean) > "testStoreConfig(StoreType, boolean, boolean, boolean).storeType=InMemory, enableLogging=false, enableCaching=true, forward=true" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=false, log=false, storeToTest=GLOBAL_TIME_ROCKS_KV, kind=PAPI" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 20 > RangeQueryIntegrationTest > testStoreConfig(StoreType, boolean, boolean, boolean) > "testStoreConfig(StoreType, boolean, boolean, boolean).storeType=InMemory, enableLogging=false, enableCaching=true, forward=false" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=false, log=false, storeToTest=ROCKS_KV, kind=PAPI" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 20 > RangeQueryIntegrationTest > testStoreConfig(StoreType, boolean, boolean, boolean) > "testStoreConfig(StoreType, boolean, boolean, boolean).storeType=InMemory, enableLogging=false, enableCaching=false, forward=true" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=false, log=false, storeToTest=TIME_ROCKS_KV, kind=DSL" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 20 > RangeQueryIntegrationTest > testStoreConfig(StoreType, boolean, boolean, boolean) > "testStoreConfig(StoreType, boolean, boolean, boolean).storeType=InMemory, enableLogging=false, enableCaching=false, forward=false" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=true, log=true, storeToTest=GLOBAL_IN_MEMORY_LRU, kind=PAPI" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 20 > RangeQueryIntegrationTest > testStoreConfig(StoreType, boolean, boolean, boolean) > "testStoreConfig(StoreType, boolean, boolean, boolean).storeType=RocksDB, enableLogging=true, enableCaching=true, forward=true" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=true, log=true, storeToTest=TIME_ROCKS_KV, kind=DSL" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 20 > RangeQueryIntegrationTest > testStoreConfig(StoreType, boolean, boolean, boolean) > "testStoreConfig(StoreType, boolean, boolean, boolean).storeType=RocksDB, enableLogging=true, enableCaching=true, forward=false" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=true, log=true, storeToTest=IN_MEMORY_WINDOW, kind=PAPI" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 20 > RangeQueryIntegrationTest > testStoreConfig(StoreType, boolean, boolean, boolean) > "testStoreConfig(StoreType, boolean, boolean, boolean).storeType=RocksDB, enableLogging=true, enableCaching=false, forward=true" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=true, log=false, storeToTest=ROCKS_WINDOW, kind=PAPI" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 20 > RangeQueryIntegrationTest > testStoreConfig(StoreType, boolean, boolean, boolean) > "testStoreConfig(StoreType, boolean, boolean, boolean).storeType=RocksDB, enableLogging=true, enableCaching=false, forward=false" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=false, log=true, storeToTest=GLOBAL_IN_MEMORY_KV, kind=PAPI" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 20 > RangeQueryIntegrationTest > testStoreConfig(StoreType, boolean, boolean, boolean) > "testStoreConfig(StoreType, boolean, boolean, boolean).storeType=RocksDB, enableLogging=false, enableCaching=true, forward=true" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=true, log=true, storeToTest=IN_MEMORY_LRU, kind=PAPI" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 20 > RangeQueryIntegrationTest > testStoreConfig(StoreType, boolean, boolean, boolean) > "testStoreConfig(StoreType, boolean, boolean, boolean).storeType=RocksDB, enableLogging=false, enableCaching=true, forward=false" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=false, log=false, storeToTest=GLOBAL_IN_MEMORY_LRU, kind=PAPI" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 20 > RangeQueryIntegrationTest > testStoreConfig(StoreType, boolean, boolean, boolean) > "testStoreConfig(StoreType, boolean, boolean, boolean).storeType=RocksDB, enableLogging=false, enableCaching=false, forward=true" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=true, log=false, storeToTest=GLOBAL_ROCKS_KV, kind=DSL" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 20 > RangeQueryIntegrationTest > testStoreConfig(StoreType, boolean, boolean, boolean) > "testStoreConfig(StoreType, boolean, boolean, boolean).storeType=RocksDB, enableLogging=false, enableCaching=false, forward=false" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=false, log=true, storeToTest=IN_MEMORY_LRU, kind=DSL" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 20 > RangeQueryIntegrationTest > testStoreConfig(StoreType, boolean, boolean, boolean) > "testStoreConfig(StoreType, boolean, boolean, boolean).storeType=Timed, enableLogging=true, enableCaching=true, forward=true" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=true, log=false, storeToTest=ROCKS_KV, kind=PAPI" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=false, log=false, storeToTest=GLOBAL_IN_MEMORY_KV, kind=PAPI" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 20 > RangeQueryIntegrationTest > testStoreConfig(StoreType, boolean, boolean, boolean) > "testStoreConfig(StoreType, boolean, boolean, boolean).storeType=Timed, enableLogging=true, enableCaching=true, forward=false" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=false, log=false, storeToTest=GLOBAL_ROCKS_KV, kind=PAPI" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 20 > RangeQueryIntegrationTest > testStoreConfig(StoreType, boolean, boolean, boolean) > "testStoreConfig(StoreType, boolean, boolean, boolean).storeType=Timed, enableLogging=true, enableCaching=false, forward=true" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=false, log=false, storeToTest=GLOBAL_IN_MEMORY_KV, kind=DSL" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 20 > RangeQueryIntegrationTest > testStoreConfig(StoreType, boolean, boolean, boolean) > "testStoreConfig(StoreType, boolean, boolean, boolean).storeType=Timed, enableLogging=true, enableCaching=false, forward=false" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=true, log=true, storeToTest=TIME_ROCKS_WINDOW, kind=DSL" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 20 > RangeQueryIntegrationTest > testStoreConfig(StoreType, boolean, boolean, boolean) > "testStoreConfig(StoreType, boolean, boolean, boolean).storeType=Timed, enableLogging=false, enableCaching=true, forward=true" PASSED
> Task :connect:mirror:test
Gradle Test Run :connect:mirror:test > Gradle Test Executor 12 > MirrorConnectorsIntegrationBaseTest > testRestartReplication() PASSED
> Task :core:test
Gradle Test Run :core:test > Gradle Test Executor 22 > AuthorizerIntegrationTest > testIdempotentProducerNoIdempotentWriteAclInInitProducerId(String) > "testIdempotentProducerNoIdempotentWriteAclInInitProducerId(String).quorum=zk" PASSED
Gradle Test Run :core:test > Gradle Test Executor 23 > GroupCoordinatorIntegrationTest > testGroupCoordinatorPropagatesOffsetsTopicCompressionCodec(String) > "testGroupCoordinatorPropagatesOffsetsTopicCompressionCodec(String).quorum=zk" PASSED
Gradle Test Run :core:test > Gradle Test Executor 25 > EndToEndClusterIdTest > testEndToEnd(String) > "testEndToEnd(String).quorum=zk" PASSED
Gradle Test Run :core:test > Gradle Test Executor 23 > GroupCoordinatorIntegrationTest > testGroupCoordinatorPropagatesOffsetsTopicCompressionCodec(String) > "testGroupCoordinatorPropagatesOffsetsTopicCompressionCodec(String).quorum=kraft" PASSED
Gradle Test Run :core:test > Gradle Test Executor 22 > AuthorizerIntegrationTest > testIdempotentProducerNoIdempotentWriteAclInInitProducerId(String) > "testIdempotentProducerNoIdempotentWriteAclInInitProducerId(String).quorum=kraft" PASSED
Gradle Test Run :core:test > Gradle Test Executor 25 > EndToEndClusterIdTest > testEndToEnd(String) > "testEndToEnd(String).quorum=kraft" PASSED
Gradle Test Run :core:test > Gradle Test Executor 27 > PlaintextAdminIntegrationTest > testCreateDeleteTopics(String) > "testCreateDeleteTopics(String).quorum=zk" PASSED
Gradle Test Run :core:test > Gradle Test Executor 27 > PlaintextAdminIntegrationTest > testCreateDeleteTopics(String) > "testCreateDeleteTopics(String).quorum=kraft" PASSED
Gradle Test Run :core:test > Gradle Test Executor 28 > ZkMigrationFailoverTest > testDriverSkipsEventsFromOlderEpoch() PASSED
Gradle Test Run :core:test > Gradle Test Executor 29 > SslConsumerTest > testCoordinatorFailover(String, String) > testCoordinatorFailover(String, String).quorum=zk.groupProtocol=classic PASSED
Gradle Test Run :core:test > Gradle Test Executor 24 > ConsumerBounceTest > testConsumptionWithBrokerFailures() PASSED
Gradle Test Run :core:test > Gradle Test Executor 30 > LogRecoveryTest > testHWCheckpointWithFailuresMultipleLogSegments(String) > "testHWCheckpointWithFailuresMultipleLogSegments(String).quorum=zk" PASSED
Gradle Test Run :core:test > Gradle Test Executor 26 > ZkMigrationIntegrationTest > testMigrateTopicDeletions(ClusterInstance) > testMigrateTopicDeletions [1] Type=ZK, MetadataVersion=3.4-IV0,Security=PLAINTEXT PASSED
Gradle Test Run :core:test > Gradle Test Executor 29 > SslConsumerTest > testCoordinatorFailover(String, String) > testCoordinatorFailover(String, String).quorum=kraft.groupProtocol=classic PASSED
Gradle Test Run :core:test > Gradle Test Executor 26 > ZkMigrationIntegrationTest > testMigrateTopicDeletions(ClusterInstance) > testMigrateTopicDeletions [2] Type=ZK, MetadataVersion=3.5-IV2,Security=PLAINTEXT PASSED
Gradle Test Run :core:test > Gradle Test Executor 30 > LogRecoveryTest > testHWCheckpointWithFailuresMultipleLogSegments(String) > "testHWCheckpointWithFailuresMultipleLogSegments(String).quorum=kraft" PASSED
Gradle Test Run :core:test > Gradle Test Executor 29 > SslConsumerTest > testCoordinatorFailover(String, String) > testCoordinatorFailover(String, String).quorum=kraft+kip848.groupProtocol=classic PASSED
> Task :storage:test
Gradle Test Run :storage:test > Gradle Test Executor 7 > TransactionsWithTieredStoreTest > testAbortTransactionTimeout(String) > "testAbortTransactionTimeout(String).quorum=kraft+kip848" PASSED
Gradle Test Run :storage:test > Gradle Test Executor 7 > TransactionsWithTieredStoreTest > testMultipleMarkersOneLeader(String) > "testMultipleMarkersOneLeader(String).quorum=zk" PASSED
Gradle Test Run :storage:test > Gradle Test Executor 7 > TransactionsWithTieredStoreTest > testMultipleMarkersOneLeader(String) > "testMultipleMarkersOneLeader(String).quorum=kraft" PASSED
Gradle Test Run :storage:test > Gradle Test Executor 7 > TransactionsWithTieredStoreTest > testMultipleMarkersOneLeader(String) > "testMultipleMarkersOneLeader(String).quorum=kraft+kip848" PASSED
> Task :streams:test
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=false, log=true, storeToTest=ROCKS_WINDOW, kind=PAPI" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 20 > RangeQueryIntegrationTest > testStoreConfig(StoreType, boolean, boolean, boolean) > "testStoreConfig(StoreType, boolean, boolean, boolean).storeType=Timed, enableLogging=false, enableCaching=true, forward=false" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=false, log=false, storeToTest=ROCKS_KV, kind=DSL" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 20 > RangeQueryIntegrationTest > testStoreConfig(StoreType, boolean, boolean, boolean) > "testStoreConfig(StoreType, boolean, boolean, boolean).storeType=Timed, enableLogging=false, enableCaching=false, forward=true" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=true, log=true, storeToTest=TIME_ROCKS_KV, kind=PAPI" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 20 > RangeQueryIntegrationTest > testStoreConfig(StoreType, boolean, boolean, boolean) > "testStoreConfig(StoreType, boolean, boolean, boolean).storeType=Timed, enableLogging=false, enableCaching=false, forward=false" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=false, log=false, storeToTest=ROCKS_WINDOW, kind=PAPI" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=false, log=true, storeToTest=TIME_ROCKS_KV, kind=DSL" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=true, log=true, storeToTest=ROCKS_SESSION, kind=DSL" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=false, log=false, storeToTest=ROCKS_WINDOW, kind=DSL" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=true, log=true, storeToTest=ROCKS_WINDOW, kind=PAPI" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=true, log=false, storeToTest=IN_MEMORY_SESSION, kind=DSL" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=true, log=true, storeToTest=GLOBAL_IN_MEMORY_KV, kind=PAPI" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=false, log=false, storeToTest=IN_MEMORY_KV, kind=PAPI" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=false, log=true, storeToTest=GLOBAL_ROCKS_KV, kind=PAPI" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=true, log=true, storeToTest=ROCKS_WINDOW, kind=DSL" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=false, log=true, storeToTest=GLOBAL_IN_MEMORY_LRU, kind=PAPI" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=true, log=false, storeToTest=IN_MEMORY_LRU, kind=PAPI" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=false, log=false, storeToTest=IN_MEMORY_WINDOW, kind=DSL" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=false, log=true, storeToTest=IN_MEMORY_SESSION, kind=DSL" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=true, log=true, storeToTest=GLOBAL_ROCKS_KV, kind=PAPI" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=false, log=false, storeToTest=IN_MEMORY_LRU, kind=PAPI" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=false, log=false, storeToTest=IN_MEMORY_KV, kind=DSL" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=true, log=false, storeToTest=GLOBAL_IN_MEMORY_KV, kind=DSL" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=false, log=false, storeToTest=GLOBAL_IN_MEMORY_LRU, kind=DSL" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=true, log=true, storeToTest=ROCKS_SESSION, kind=PAPI" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=false, log=false, storeToTest=GLOBAL_ROCKS_KV, kind=DSL" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 17 > RestoreIntegrationTest > shouldInvokeUserDefinedGlobalStateRestoreListener() PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=false, log=false, storeToTest=IN_MEMORY_SESSION, kind=PAPI" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 21 > SmokeTestDriverIntegrationTest > shouldWorkWithRebalance(boolean, boolean) > "shouldWorkWithRebalance(boolean, boolean).stateUpdaterEnabled=false, processingThreadsEnabled=false" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=false, log=true, storeToTest=GLOBAL_ROCKS_KV, kind=DSL" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=false, log=false, storeToTest=ROCKS_SESSION, kind=PAPI" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=false, log=true, storeToTest=ROCKS_KV, kind=PAPI" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=true, log=false, storeToTest=IN_MEMORY_WINDOW, kind=PAPI" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=false, log=true, storeToTest=IN_MEMORY_LRU, kind=PAPI" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=true, log=true, storeToTest=GLOBAL_IN_MEMORY_KV, kind=DSL" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=true, log=false, storeToTest=GLOBAL_IN_MEMORY_LRU, kind=PAPI" PASSED
> Task :connect:mirror:test
Gradle Test Run :connect:mirror:test > Gradle Test Executor 12 > MirrorConnectorsIntegrationBaseTest > testOneWayReplicationWithFrequentOffsetSyncs() PASSED
> Task :storage:test
Gradle Test Run :storage:test > Gradle Test Executor 7 > TransactionsWithTieredStoreTest > testCommitTransactionTimeout(String) > "testCommitTransactionTimeout(String).quorum=zk" PASSED
Gradle Test Run :storage:test > Gradle Test Executor 7 > TransactionsWithTieredStoreTest > testCommitTransactionTimeout(String) > "testCommitTransactionTimeout(String).quorum=kraft" PASSED
Gradle Test Run :storage:test > Gradle Test Executor 7 > TransactionsWithTieredStoreTest > testCommitTransactionTimeout(String) > "testCommitTransactionTimeout(String).quorum=kraft+kip848" PASSED
> Task :streams:test
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=true, log=false, storeToTest=ROCKS_WINDOW, kind=DSL" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=true, log=false, storeToTest=IN_MEMORY_LRU, kind=DSL" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 19 > QueryableStateIntegrationTest > shouldBeAbleToQueryDuringRebalance() PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=false, log=false, storeToTest=IN_MEMORY_SESSION, kind=DSL" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=false, log=true, storeToTest=TIME_ROCKS_WINDOW, kind=DSL" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=true, log=true, storeToTest=GLOBAL_ROCKS_KV, kind=DSL" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=true, log=false, storeToTest=GLOBAL_IN_MEMORY_KV, kind=PAPI" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=false, log=false, storeToTest=IN_MEMORY_LRU, kind=DSL" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=false, log=false, storeToTest=TIME_ROCKS_WINDOW, kind=DSL" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=false, log=true, storeToTest=ROCKS_WINDOW, kind=DSL" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=true, log=true, storeToTest=GLOBAL_TIME_ROCKS_KV, kind=DSL" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=true, log=false, storeToTest=IN_MEMORY_KV, kind=DSL" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=false, log=true, storeToTest=TIME_ROCKS_WINDOW, kind=PAPI" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=true, log=false, storeToTest=GLOBAL_TIME_ROCKS_KV, kind=PAPI" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=true, log=false, storeToTest=ROCKS_SESSION, kind=DSL" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=true, log=false, storeToTest=IN_MEMORY_SESSION, kind=PAPI" PASSED
> Task :core:test
Gradle Test Run :core:test > Gradle Test Executor 26 > ZkMigrationIntegrationTest > testMigrateTopicDeletions(ClusterInstance) > testMigrateTopicDeletions [3] Type=ZK, MetadataVersion=3.6-IV2,Security=PLAINTEXT PASSED
Gradle Test Run :core:test > Gradle Test Executor 29 > SslConsumerTest > testCoordinatorFailover(String, String) > testCoordinatorFailover(String, String).quorum=kraft+kip848.groupProtocol=consumer PASSED
Gradle Test Run :core:test > Gradle Test Executor 26 > ZkMigrationIntegrationTest > testMigrateTopicDeletions(ClusterInstance) > testMigrateTopicDeletions [4] Type=ZK, MetadataVersion=3.7-IV0,Security=PLAINTEXT PASSED
Gradle Test Run :core:test > Gradle Test Executor 26 > ZkMigrationIntegrationTest > testMigrateTopicDeletions(ClusterInstance) > testMigrateTopicDeletions [5] Type=ZK, MetadataVersion=3.7-IV1,Security=PLAINTEXT PASSED
Gradle Test Run :core:test > Gradle Test Executor 26 > ZkMigrationIntegrationTest > testMigrateTopicDeletions(ClusterInstance) > testMigrateTopicDeletions [6] Type=ZK, MetadataVersion=3.7-IV2,Security=PLAINTEXT PASSED
Gradle Test Run :core:test > Gradle Test Executor 26 > ZkMigrationIntegrationTest > testMigrateTopicDeletions(ClusterInstance) > testMigrateTopicDeletions [7] Type=ZK, MetadataVersion=3.7-IV4,Security=PLAINTEXT PASSED
> Task :streams:test
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=false, log=true, storeToTest=IN_MEMORY_WINDOW, kind=PAPI" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=false, log=true, storeToTest=IN_MEMORY_KV, kind=PAPI" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=true, log=true, storeToTest=TIME_ROCKS_WINDOW, kind=PAPI" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=true, log=false, storeToTest=ROCKS_KV, kind=DSL" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=true, log=true, storeToTest=GLOBAL_TIME_ROCKS_KV, kind=PAPI" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=true, log=true, storeToTest=GLOBAL_IN_MEMORY_LRU, kind=DSL" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=true, log=true, storeToTest=IN_MEMORY_WINDOW, kind=DSL" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=false, log=false, storeToTest=GLOBAL_TIME_ROCKS_KV, kind=DSL" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=true, log=false, storeToTest=GLOBAL_TIME_ROCKS_KV, kind=DSL" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=false, log=true, storeToTest=TIME_ROCKS_KV, kind=PAPI" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=true, log=false, storeToTest=IN_MEMORY_WINDOW, kind=DSL" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=false, log=false, storeToTest=ROCKS_SESSION, kind=DSL" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=false, log=true, storeToTest=GLOBAL_TIME_ROCKS_KV, kind=DSL" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=false, log=true, storeToTest=IN_MEMORY_WINDOW, kind=DSL" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=true, log=true, storeToTest=IN_MEMORY_KV, kind=PAPI" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=false, log=false, storeToTest=TIME_ROCKS_KV, kind=PAPI" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=true, log=true, storeToTest=IN_MEMORY_KV, kind=DSL" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=false, log=true, storeToTest=GLOBAL_TIME_ROCKS_KV, kind=PAPI" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=true, log=true, storeToTest=ROCKS_KV, kind=PAPI" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=true, log=true, storeToTest=IN_MEMORY_SESSION, kind=DSL" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=true, log=true, storeToTest=ROCKS_KV, kind=DSL" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=false, log=true, storeToTest=ROCKS_SESSION, kind=DSL" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=true, log=false, storeToTest=GLOBAL_ROCKS_KV, kind=PAPI" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=true, log=false, storeToTest=TIME_ROCKS_WINDOW, kind=PAPI" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=false, log=true, storeToTest=IN_MEMORY_SESSION, kind=PAPI" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=true, log=false, storeToTest=GLOBAL_IN_MEMORY_LRU, kind=DSL" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=false, log=true, storeToTest=GLOBAL_IN_MEMORY_KV, kind=DSL" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=true, log=false, storeToTest=TIME_ROCKS_WINDOW, kind=DSL" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=true, log=false, storeToTest=ROCKS_SESSION, kind=PAPI" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=true, log=false, storeToTest=IN_MEMORY_KV, kind=PAPI" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=false, log=true, storeToTest=ROCKS_SESSION, kind=PAPI" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=true, log=false, storeToTest=TIME_ROCKS_KV, kind=DSL" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=false, log=true, storeToTest=ROCKS_KV, kind=DSL" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=true, log=true, storeToTest=IN_MEMORY_LRU, kind=DSL" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=false, log=false, storeToTest=IN_MEMORY_WINDOW, kind=PAPI" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 18 > IQv2StoreIntegrationTest > verifyStore(boolean, boolean, StoresToTest, String) > "verifyStore(boolean, boolean, StoresToTest, String).cache=false, log=true, storeToTest=IN_MEMORY_KV, kind=DSL" PASSED
> Task :core:test
Gradle Test Run :core:test > Gradle Test Executor 26 > ZkMigrationIntegrationTest > testMigrateTopicDeletions(ClusterInstance) > testMigrateTopicDeletions [8] Type=ZK, MetadataVersion=3.8-IV0,Security=PLAINTEXT PASSED
Gradle Test Run :core:test > Gradle Test Executor 26 > ZkMigrationIntegrationTest > testMigrateTopicDeletions(ClusterInstance) > testMigrateTopicDeletions [9] Type=ZK, MetadataVersion=3.9-IV0,Security=PLAINTEXT PASSED
Gradle Test Run :core:test > Gradle Test Executor 26 > ZkMigrationIntegrationTest > testMigrateTopicDeletions(ClusterInstance) > testMigrateTopicDeletions [10] Type=ZK, MetadataVersion=3.9-IV1,Security=PLAINTEXT PASSED
> Task :streams:test
Gradle Test Run :streams:test > Gradle Test Executor 21 > SmokeTestDriverIntegrationTest > shouldWorkWithRebalance(boolean, boolean) > "shouldWorkWithRebalance(boolean, boolean).stateUpdaterEnabled=true, processingThreadsEnabled=false" PASSED
Gradle Test Run :streams:test > Gradle Test Executor 21 > SmokeTestDriverIntegrationTest > shouldWorkWithRebalance(boolean, boolean) > "shouldWorkWithRebalance(boolean, boolean).stateUpdaterEnabled=true, processingThreadsEnabled=true" PASSED
streams-2: SMOKE-TEST-CLIENT-CLOSED
streams-5: SMOKE-TEST-CLIENT-CLOSED
streams-3: SMOKE-TEST-CLIENT-CLOSED
streams-1: SMOKE-TEST-CLIENT-CLOSED
streams-7: SMOKE-TEST-CLIENT-CLOSED
streams-3: SMOKE-TEST-CLIENT-CLOSED
streams-2: SMOKE-TEST-CLIENT-CLOSED
streams-1: SMOKE-TEST-CLIENT-CLOSED
streams-2: SMOKE-TEST-CLIENT-CLOSED
streams-8: SMOKE-TEST-CLIENT-CLOSED
streams-0: SMOKE-TEST-CLIENT-CLOSED
streams-6: SMOKE-TEST-CLIENT-CLOSED
streams-6: SMOKE-TEST-CLIENT-CLOSED
streams-6: SMOKE-TEST-CLIENT-CLOSED
streams-0: SMOKE-TEST-CLIENT-CLOSED
streams-9: SMOKE-TEST-CLIENT-CLOSED
streams-5: SMOKE-TEST-CLIENT-CLOSED
streams-4: SMOKE-TEST-CLIENT-CLOSED
streams-3: SMOKE-TEST-CLIENT-CLOSED
streams-4: SMOKE-TEST-CLIENT-CLOSED
streams-1: SMOKE-TEST-CLIENT-CLOSED
streams-0: SMOKE-TEST-CLIENT-CLOSED
streams-4: SMOKE-TEST-CLIENT-CLOSED
streams-5: SMOKE-TEST-CLIENT-CLOSED
Deprecated Gradle features were used in this build, making it incompatible with Gradle 9.0.
You can use '--warning-mode all' to show the individual deprecation warnings and determine if they come from your own scripts or plugins.
For more on this, please refer to https://docs.gradle.org/8.8/userguide/command_line_interface.html#sec:command_line_warnings in the Gradle documentation.
BUILD SUCCESSFUL in 5m 46s
192 actionable tasks: 102 executed, 90 up-to-date
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscribe@kafka.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [PR] KAFKA-17372: Move `ThrottledChannelExpirationTest#testThrottledChannelDelay` and `ThrottledChannel` to server module [kafka]
Posted by "chia7712 (via GitHub)" <gi...@apache.org>.
chia7712 commented on code in PR #16935:
URL: https://github.com/apache/kafka/pull/16935#discussion_r1724004600
##########
core/src/test/scala/unit/kafka/server/ThrottledChannelExpirationTest.scala:
##########
@@ -23,6 +23,7 @@ import java.util.concurrent.{DelayQueue, TimeUnit}
import org.apache.kafka.common.metrics.MetricConfig
import org.apache.kafka.common.utils.MockTime
import org.apache.kafka.server.config.ClientQuotaManagerConfig
+import org.apache.kafka.server.{ThrottledChannel, ThrottleCallback}
import org.junit.jupiter.api.Assertions._
import org.junit.jupiter.api.{BeforeEach, Test}
Review Comment:
please remove duplicate test `testThrottledChannelDelay`
##########
server/src/main/java/org/apache/kafka/server/ThrottledChannel.java:
##########
@@ -0,0 +1,71 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.kafka.server;
+
+import org.apache.kafka.common.utils.Time;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.util.concurrent.Delayed;
+import java.util.concurrent.TimeUnit;
+
+public class ThrottledChannel implements Delayed {
+
+ private final Logger log = LoggerFactory.getLogger(getClass().getName());
Review Comment:
`private static final Logger LOGGER = LoggerFactory.getLogger(ThrottledChannel.class);`
##########
server/src/main/java/org/apache/kafka/server/ThrottleCallback.java:
##########
@@ -0,0 +1,22 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.kafka.server;
Review Comment:
Could you please move it to `org.apache.kafka.server.quota`? There are other quota-related classes which will be moved to there
##########
server/src/main/java/org/apache/kafka/server/ThrottledChannel.java:
##########
@@ -0,0 +1,71 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.kafka.server;
+
+import org.apache.kafka.common.utils.Time;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.util.concurrent.Delayed;
+import java.util.concurrent.TimeUnit;
+
+public class ThrottledChannel implements Delayed {
+
+ private final Logger log = LoggerFactory.getLogger(getClass().getName());
+ private final Time time;
+ private final long throttleTimeMs;
+ private final ThrottleCallback callback;
+ private final long endTimeNanos;
+
+ /**
+ * Represents a request whose response has been delayed.
+ * @param time Time instance to use
+ * @param throttleTimeMs Delay associated with this request
+ * @param callback Callback for channel throttling
+ */
+ public ThrottledChannel(Time time, int throttleTimeMs, ThrottleCallback callback) {
+ this.time = time;
+ this.throttleTimeMs = throttleTimeMs;
+ this.callback = callback;
+ this.endTimeNanos = time.nanoseconds() + TimeUnit.MILLISECONDS.toNanos(throttleTimeMs);
+
+ // Notify the socket server that throttling has started for this channel.
+ callback.startThrottling();
+ }
+
+ // Notify the socket server that throttling has been done for this channel.
+ public void notifyThrottlingDone() {
+ log.trace(String.format("Channel throttled for: %d ms", throttleTimeMs));
+ callback.endThrottling();
+ }
+
+ @Override
+ public long getDelay(TimeUnit unit) {
+ return unit.convert(endTimeNanos - time.nanoseconds(), TimeUnit.NANOSECONDS);
+ }
+
+ @Override
+ public int compareTo(Delayed other) {
+ ThrottledChannel otherChannel = (ThrottledChannel) other;
+ return Long.compare(this.endTimeNanos, otherChannel.endTimeNanos);
+ }
+
+ public long throttleTimeMs() {
Review Comment:
`int`
##########
server/src/main/java/org/apache/kafka/server/ThrottledChannel.java:
##########
@@ -0,0 +1,71 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.kafka.server;
+
+import org.apache.kafka.common.utils.Time;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.util.concurrent.Delayed;
+import java.util.concurrent.TimeUnit;
+
+public class ThrottledChannel implements Delayed {
+
+ private final Logger log = LoggerFactory.getLogger(getClass().getName());
+ private final Time time;
+ private final long throttleTimeMs;
Review Comment:
`int`
##########
server/src/main/java/org/apache/kafka/server/ThrottledChannel.java:
##########
@@ -0,0 +1,71 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.kafka.server;
+
+import org.apache.kafka.common.utils.Time;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.util.concurrent.Delayed;
+import java.util.concurrent.TimeUnit;
+
+public class ThrottledChannel implements Delayed {
+
+ private final Logger log = LoggerFactory.getLogger(getClass().getName());
+ private final Time time;
+ private final long throttleTimeMs;
+ private final ThrottleCallback callback;
+ private final long endTimeNanos;
+
+ /**
+ * Represents a request whose response has been delayed.
+ * @param time Time instance to use
+ * @param throttleTimeMs Delay associated with this request
+ * @param callback Callback for channel throttling
+ */
+ public ThrottledChannel(Time time, int throttleTimeMs, ThrottleCallback callback) {
+ this.time = time;
+ this.throttleTimeMs = throttleTimeMs;
+ this.callback = callback;
+ this.endTimeNanos = time.nanoseconds() + TimeUnit.MILLISECONDS.toNanos(throttleTimeMs);
+
+ // Notify the socket server that throttling has started for this channel.
+ callback.startThrottling();
+ }
+
+ // Notify the socket server that throttling has been done for this channel.
+ public void notifyThrottlingDone() {
+ log.trace(String.format("Channel throttled for: %d ms", throttleTimeMs));
Review Comment:
`log.trace("Channel throttled for: {} ms", throttleTimeMs);`
##########
server/src/main/java/org/apache/kafka/server/ThrottledChannel.java:
##########
@@ -0,0 +1,71 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.kafka.server;
+
+import org.apache.kafka.common.utils.Time;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.util.concurrent.Delayed;
+import java.util.concurrent.TimeUnit;
+
+public class ThrottledChannel implements Delayed {
+
+ private final Logger log = LoggerFactory.getLogger(getClass().getName());
+ private final Time time;
+ private final long throttleTimeMs;
+ private final ThrottleCallback callback;
+ private final long endTimeNanos;
+
+ /**
+ * Represents a request whose response has been delayed.
+ * @param time Time instance to use
+ * @param throttleTimeMs Delay associated with this request
+ * @param callback Callback for channel throttling
+ */
+ public ThrottledChannel(Time time, int throttleTimeMs, ThrottleCallback callback) {
+ this.time = time;
+ this.throttleTimeMs = throttleTimeMs;
+ this.callback = callback;
+ this.endTimeNanos = time.nanoseconds() + TimeUnit.MILLISECONDS.toNanos(throttleTimeMs);
+
+ // Notify the socket server that throttling has started for this channel.
+ callback.startThrottling();
+ }
+
+ // Notify the socket server that throttling has been done for this channel.
Review Comment:
```java
/**
* Notify the socket server that throttling has been done for this channel.
*/
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscribe@kafka.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org