[kafka] branch trunk updated (c74c0f2facd -> 20e05695f95)
This is an automated email from the ASF dual-hosted git repository. davidarthur pushed a change to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git from c74c0f2facd KAFKA-14758: Extract inner classes from Fetcher for reuse in refactoring (#13301) add 20e05695f95 KAFKA-14447: remove stale TODO comment (#13258) No new revisions were added by this update. Summary of changes: core/src/main/scala/kafka/server/KafkaServer.scala | 2 -- 1 file changed, 2 deletions(-)
[kafka] branch trunk updated: KAFKA-14758: Extract inner classes from Fetcher for reuse in refactoring (#13301)
This is an automated email from the ASF dual-hosted git repository.
guozhang pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new c74c0f2facd KAFKA-14758: Extract inner classes from Fetcher for reuse
in refactoring (#13301)
c74c0f2facd is described below
commit c74c0f2facde2b392ab745144d6ad520575ab9ef
Author: Kirk True
AuthorDate: Fri Mar 10 10:17:14 2023 -0800
KAFKA-14758: Extract inner classes from Fetcher for reuse in refactoring
(#13301)
The Fetcher class is used internally by the KafkaConsumer to fetch records
from the brokers. There is ongoing work to create a new consumer implementation
with a significantly refactored threading model. The threading refactor work
requires a similarly refactored Fetcher.
This task includes refactoring Fetcher by extracting out the inner classes
into top-level (though still in internal) so that those classes can be
referenced by forthcoming refactored fetch logic.
Reviewers: Philip Nee , Guozhang Wang
---
.../kafka/clients/consumer/KafkaConsumer.java | 4 +-
.../clients/consumer/internals/CompletedFetch.java | 365 ++
.../consumer/internals/ConsumerMetrics.java| 4 +-
.../consumer/internals/FetchMetricsAggregator.java | 95
.../consumer/internals/FetchMetricsManager.java| 203
...ricsRegistry.java => FetchMetricsRegistry.java} | 8 +-
.../kafka/clients/consumer/internals/Fetcher.java | 557 ++---
.../clients/consumer/internals/SensorBuilder.java | 115 +
.../consumer/internals/CompletedFetchTest.java | 304 +++
.../internals/FetchMetricsManagerTest.java | 171 +++
.../clients/consumer/internals/FetcherTest.java| 4 +-
.../consumer/internals/OffsetFetcherTest.java | 2 +-
12 files changed, 1300 insertions(+), 532 deletions(-)
diff --git
a/clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java
b/clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java
index 3f966121d69..11ac675cb4b 100644
--- a/clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java
+++ b/clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java
@@ -28,7 +28,7 @@ import
org.apache.kafka.clients.consumer.internals.ConsumerMetadata;
import org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient;
import org.apache.kafka.clients.consumer.internals.Fetch;
import org.apache.kafka.clients.consumer.internals.Fetcher;
-import org.apache.kafka.clients.consumer.internals.FetcherMetricsRegistry;
+import org.apache.kafka.clients.consumer.internals.FetchMetricsRegistry;
import org.apache.kafka.clients.consumer.internals.KafkaConsumerMetrics;
import
org.apache.kafka.clients.consumer.internals.NoOpConsumerRebalanceListener;
import org.apache.kafka.clients.consumer.internals.OffsetFetcher;
@@ -737,7 +737,7 @@ public class KafkaConsumer implements Consumer {
this.metadata.bootstrap(addresses);
String metricGrpPrefix = "consumer";
-FetcherMetricsRegistry metricsRegistry = new
FetcherMetricsRegistry(Collections.singleton(CLIENT_ID_METRIC_TAG),
metricGrpPrefix);
+FetchMetricsRegistry metricsRegistry = new
FetchMetricsRegistry(Collections.singleton(CLIENT_ID_METRIC_TAG),
metricGrpPrefix);
ChannelBuilder channelBuilder =
ClientUtils.createChannelBuilder(config, time, logContext);
this.isolationLevel = IsolationLevel.valueOf(
config.getString(ConsumerConfig.ISOLATION_LEVEL_CONFIG).toUpperCase(Locale.ROOT));
diff --git
a/clients/src/main/java/org/apache/kafka/clients/consumer/internals/CompletedFetch.java
b/clients/src/main/java/org/apache/kafka/clients/consumer/internals/CompletedFetch.java
new file mode 100644
index 000..6a11b846810
--- /dev/null
+++
b/clients/src/main/java/org/apache/kafka/clients/consumer/internals/CompletedFetch.java
@@ -0,0 +1,365 @@
+/*
+ * 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.clients.consumer.internals;
+
+import
[kafka] branch 3.4 updated: MINOR: Remove unnecessary call to asCollection causing eager dependency resolution (#13149)
This is an automated email from the ASF dual-hosted git repository.
mimaison pushed a commit to branch 3.4
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/3.4 by this push:
new 55d7519cf7c MINOR: Remove unnecessary call to asCollection causing
eager dependency resolution (#13149)
55d7519cf7c is described below
commit 55d7519cf7c12ae849b88173356581f102887f66
Author: Eric Haag
AuthorDate: Mon Feb 6 04:28:02 2023 -0600
MINOR: Remove unnecessary call to asCollection causing eager dependency
resolution (#13149)
Reviewers: Mickael Maison , Nelson Osacky
---
build.gradle | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/build.gradle b/build.gradle
index d5d9ffcbf38..e50de72a718 100644
--- a/build.gradle
+++ b/build.gradle
@@ -2732,7 +2732,7 @@ project(':connect:runtime') {
task genConnectOpenAPIDocs(type:
io.swagger.v3.plugins.gradle.tasks.ResolveTask, dependsOn:
setVersionInOpenAPISpec) {
classpath = sourceSets.main.runtimeClasspath
-buildClasspath = classpath + configurations.swagger.asCollection()
+buildClasspath = classpath + configurations.swagger
outputFileName = 'connect_rest'
outputFormat = 'YAML'
prettyPrint = 'TRUE'
[kafka-site] branch asf-site updated: MINOR: Update Chris Egerton's section in committers page (#497)
This is an automated email from the ASF dual-hosted git repository. cegerton pushed a commit to branch asf-site in repository https://gitbox.apache.org/repos/asf/kafka-site.git The following commit(s) were added to refs/heads/asf-site by this push: new 7dd0189c MINOR: Update Chris Egerton's section in committers page (#497) 7dd0189c is described below commit 7dd0189cc76de8571b561eb061902f73717675c6 Author: Chris Egerton AuthorDate: Fri Mar 10 11:27:20 2023 -0500 MINOR: Update Chris Egerton's section in committers page (#497) --- committers.html | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/committers.html b/committers.html index 4a670e89..d1dea41f 100644 --- a/committers.html +++ b/committers.html @@ -385,8 +385,8 @@ Chris Egerton - Committer - https://www.linkedin.com/in/chris-egerton-93886148/;>/in/chris-egerton-93886148 + Committer, and PMC member + https://twitter.com/C0urante;>@C0urante https://github.com/C0urante/;>github.com/C0urante
[kafka-site] branch chris-update created (now bc6ad401)
This is an automated email from the ASF dual-hosted git repository. cegerton pushed a change to branch chris-update in repository https://gitbox.apache.org/repos/asf/kafka-site.git at bc6ad401 MINOR: Update Chris Egerton's section in committers page This branch includes the following new commits: new bc6ad401 MINOR: Update Chris Egerton's section in committers page The 1 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference.
[kafka-site] 01/01: MINOR: Update Chris Egerton's section in committers page
This is an automated email from the ASF dual-hosted git repository. cegerton pushed a commit to branch chris-update in repository https://gitbox.apache.org/repos/asf/kafka-site.git commit bc6ad401222e9e35a256473ddd93fcf94555cfa7 Author: Chris Egerton AuthorDate: Fri Mar 10 11:18:44 2023 -0500 MINOR: Update Chris Egerton's section in committers page --- committers.html | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/committers.html b/committers.html index 6f523ec2..375f9ebe 100644 --- a/committers.html +++ b/committers.html @@ -385,8 +385,8 @@ Chris Egerton - Committer - https://www.linkedin.com/in/chris-egerton-93886148/;>/in/chris-egerton-93886148 + Committer, and PMC member + https://twitter.com/C0urante;>@C0urante https://github.com/C0urante/;>github.com/C0urante
[kafka-site] branch asf-site updated: Add David Arthur's PMC status in committers.html (#496)
This is an automated email from the ASF dual-hosted git repository. davidarthur pushed a commit to branch asf-site in repository https://gitbox.apache.org/repos/asf/kafka-site.git The following commit(s) were added to refs/heads/asf-site by this push: new c8be7cd3 Add David Arthur's PMC status in committers.html (#496) c8be7cd3 is described below commit c8be7cd32aeb33898577b16e8ddf02d9db6ca816 Author: David Arthur AuthorDate: Fri Mar 10 09:55:20 2023 -0500 Add David Arthur's PMC status in committers.html (#496) Reviewers: David Jacot --- committers.html | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/committers.html b/committers.html index 6f523ec2..4a670e89 100644 --- a/committers.html +++ b/committers.html @@ -80,7 +80,7 @@ David Arthur - Committer + Committer, and PMC member https://www.linkedin.com/in/davidrarthur;>/in/davidarthur https://github.com/mumrah;>github.com/mumrah
[kafka-site] branch mumrah-patch-2 created (now 431b7eda)
This is an automated email from the ASF dual-hosted git repository. davidarthur pushed a change to branch mumrah-patch-2 in repository https://gitbox.apache.org/repos/asf/kafka-site.git at 431b7eda Add David Arthur's PMC status in committers.html This branch includes the following new commits: new 431b7eda Add David Arthur's PMC status in committers.html The 1 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference.
[kafka-site] 01/01: Add David Arthur's PMC status in committers.html
This is an automated email from the ASF dual-hosted git repository. davidarthur pushed a commit to branch mumrah-patch-2 in repository https://gitbox.apache.org/repos/asf/kafka-site.git commit 431b7edad214b5e8b84968ac77077c597fc1bfb0 Author: David Arthur AuthorDate: Fri Mar 10 09:30:50 2023 -0500 Add David Arthur's PMC status in committers.html --- committers.html | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/committers.html b/committers.html index 6f523ec2..4a670e89 100644 --- a/committers.html +++ b/committers.html @@ -80,7 +80,7 @@ David Arthur - Committer + Committer, and PMC member https://www.linkedin.com/in/davidrarthur;>/in/davidarthur https://github.com/mumrah;>github.com/mumrah
