This is an automated email from the ASF dual-hosted git repository.
xiangfu pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pinot.git
from afbc9d15e85 Bump com.github.luben:zstd-jni from 1.5.7-5 to 1.5.7-6
(#17050)
add 597f608a31f Implement multi-level Kafka admin client reuse for optimal
performance (#16620)
No new revisions were added by this update.
Summary of changes:
.../KafkaPartitionLevelConnectionHandler.java | 53 ++++++
.../kafka20/KafkaStreamMetadataProvider.java | 18 +-
.../kafka20/KafkaAdminClientManagerTest.java | 130 +++++++++++++++
.../KafkaPartitionLevelConnectionHandlerTest.java | 103 ++++++++++++
.../KafkaPartitionLevelConnectionHandler.java | 54 ++++++
.../kafka30/KafkaStreamMetadataProvider.java | 18 +-
.../kafka30/KafkaAdminClientManagerTest.java | 130 +++++++++++++++
.../KafkaPartitionLevelConnectionHandlerTest.java | 103 ++++++++++++
.../pinot-kafka-base/pom.xml | 12 ++
.../stream/kafka/KafkaAdminClientManager.java | 181 +++++++++++++++++++++
.../KafkaAdminClientManagerExactOnceTest.java | 129 +++++++++++++++
11 files changed, 924 insertions(+), 7 deletions(-)
create mode 100644
pinot-plugins/pinot-stream-ingestion/pinot-kafka-2.0/src/test/java/org/apache/pinot/plugin/stream/kafka20/KafkaAdminClientManagerTest.java
create mode 100644
pinot-plugins/pinot-stream-ingestion/pinot-kafka-2.0/src/test/java/org/apache/pinot/plugin/stream/kafka20/KafkaPartitionLevelConnectionHandlerTest.java
create mode 100644
pinot-plugins/pinot-stream-ingestion/pinot-kafka-3.0/src/test/java/org/apache/pinot/plugin/stream/kafka30/KafkaAdminClientManagerTest.java
create mode 100644
pinot-plugins/pinot-stream-ingestion/pinot-kafka-3.0/src/test/java/org/apache/pinot/plugin/stream/kafka30/KafkaPartitionLevelConnectionHandlerTest.java
create mode 100644
pinot-plugins/pinot-stream-ingestion/pinot-kafka-base/src/main/java/org/apache/pinot/plugin/stream/kafka/KafkaAdminClientManager.java
create mode 100644
pinot-plugins/pinot-stream-ingestion/pinot-kafka-base/src/test/java/org/apache/pinot/plugin/stream/kafka/KafkaAdminClientManagerExactOnceTest.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
