This is an automated email from the ASF dual-hosted git repository.
chia7712 pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from 51ef2903f76 KAFKA-19178 Replace Vector by ArrayList for
PluginClassLoader#getResources (#19529)
add 7293f3a90e6 KAFKA-19183 Replace Pool with ConcurrentHashMap (#19535)
No new revisions were added by this update.
Summary of changes:
checkstyle/import-control-jmh-benchmarks.xml | 1 -
core/src/main/scala/kafka/cluster/Partition.scala | 13 ++-
.../transaction/TransactionStateManager.scala | 48 +++++------
core/src/main/scala/kafka/log/LogManager.scala | 4 +-
.../kafka/server/AbstractFetcherManager.scala | 3 +-
.../scala/kafka/server/AbstractFetcherThread.scala | 13 ++-
.../main/scala/kafka/server/DelayedProduce.scala | 16 ++--
.../main/scala/kafka/server/ReplicaManager.scala | 18 ++--
core/src/main/scala/kafka/utils/Pool.scala | 99 ----------------------
.../TransactionCoordinatorConcurrencyTest.scala | 5 +-
.../transaction/TransactionStateManagerTest.scala | 42 ++++-----
.../unit/kafka/server/ReplicaManagerTest.scala | 6 +-
.../src/test/scala/unit/kafka/utils/PoolTest.scala | 40 ---------
.../jmh/fetcher/ReplicaFetcherThreadBenchmark.java | 10 +--
14 files changed, 85 insertions(+), 233 deletions(-)
delete mode 100644 core/src/main/scala/kafka/utils/Pool.scala
delete mode 100644 core/src/test/scala/unit/kafka/utils/PoolTest.scala
