apoorvmittal10 commented on code in PR #14620:
URL: https://github.com/apache/kafka/pull/14620#discussion_r1390718727
##
clients/src/main/java/org/apache/kafka/common/telemetry/internals/LastValueTracker.java:
##
@@ -0,0 +1,88 @@
+/*
+ * Licensed to the Apache Software
apoorvmittal10 commented on code in PR #14620:
URL: https://github.com/apache/kafka/pull/14620#discussion_r1390714375
##
clients/src/main/java/org/apache/kafka/common/telemetry/internals/KafkaMetricsCollector.java:
##
@@ -0,0 +1,341 @@
+/*
+ * Licensed to the Apache Software
apoorvmittal10 commented on code in PR #14620:
URL: https://github.com/apache/kafka/pull/14620#discussion_r1390713867
##
clients/src/main/java/org/apache/kafka/common/telemetry/internals/MetricsProvider.java:
##
@@ -0,0 +1,63 @@
+/*
+ * Licensed to the Apache Software
[
https://issues.apache.org/jira/browse/KAFKA-15785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Apoorv Mittal updated KAFKA-15785:
--
Summary: Flaky Test -
testTransactionAfterTransactionIdExpiresButProducerIdRemains (was:
[
https://issues.apache.org/jira/browse/KAFKA-15785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Apoorv Mittal updated KAFKA-15785:
--
Parent: (was: KAFKA-15601)
Issue Type: Bug (was: Sub-task)
> Investigate new
[
https://issues.apache.org/jira/browse/KAFKA-15786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Apoorv Mittal updated KAFKA-15786:
--
Parent: (was: KAFKA-15601)
Issue Type: Bug (was: Sub-task)
> Investigate new
[
https://issues.apache.org/jira/browse/KAFKA-15786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Apoorv Mittal updated KAFKA-15786:
--
Summary: Flaky Test - testBumpTransactionalEpoch (was: Investigate new
test case failure -
[
https://issues.apache.org/jira/browse/KAFKA-15788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Apoorv Mittal updated KAFKA-15788:
--
Parent: (was: KAFKA-15601)
Issue Type: Bug (was: Sub-task)
> Investigate new
[
https://issues.apache.org/jira/browse/KAFKA-15788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Apoorv Mittal updated KAFKA-15788:
--
Summary: Flaky Test - testDeleteCmdNonExistingGroup (was: Investigate new
test case failure
[
https://issues.apache.org/jira/browse/KAFKA-15790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Apoorv Mittal updated KAFKA-15790:
--
Summary: Flaky Test - testHighWaterMarkAfterPartitionReassignment (was:
Investigate new test
[
https://issues.apache.org/jira/browse/KAFKA-15790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Apoorv Mittal updated KAFKA-15790:
--
Parent: (was: KAFKA-15601)
Issue Type: Bug (was: Sub-task)
> Investigate new
[
https://issues.apache.org/jira/browse/KAFKA-15791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Apoorv Mittal updated KAFKA-15791:
--
Summary: Flaky test -
MirrorConnectorsWithCustomForwardingAdminIntegrationTest -
[
https://issues.apache.org/jira/browse/KAFKA-15791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Apoorv Mittal updated KAFKA-15791:
--
Parent: (was: KAFKA-15601)
Issue Type: Bug (was: Sub-task)
> Investigate new
[
https://issues.apache.org/jira/browse/KAFKA-15789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Apoorv Mittal updated KAFKA-15789:
--
Summary: Flaky Test - testTimeouts - QuorumControllerTest (was:
Investigate new test case
[
https://issues.apache.org/jira/browse/KAFKA-15789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Apoorv Mittal updated KAFKA-15789:
--
Parent: (was: KAFKA-15601)
Issue Type: Bug (was: Sub-task)
> Investigate new
apoorvmittal10 commented on code in PR #14620:
URL: https://github.com/apache/kafka/pull/14620#discussion_r1390693105
##
clients/src/main/java/org/apache/kafka/common/telemetry/internals/KafkaMetricsCollector.java:
##
@@ -0,0 +1,341 @@
+/*
+ * Licensed to the Apache Software
apoorvmittal10 commented on code in PR #14620:
URL: https://github.com/apache/kafka/pull/14620#discussion_r1390692901
##
clients/src/main/java/org/apache/kafka/common/telemetry/internals/KafkaMetricsCollector.java:
##
@@ -0,0 +1,341 @@
+/*
+ * Licensed to the Apache Software
apoorvmittal10 commented on code in PR #14620:
URL: https://github.com/apache/kafka/pull/14620#discussion_r1390692648
##
clients/src/main/java/org/apache/kafka/common/telemetry/internals/SinglePointMetric.java:
##
@@ -16,22 +16,135 @@
*/
package
apoorvmittal10 commented on code in PR #14620:
URL: https://github.com/apache/kafka/pull/14620#discussion_r1390692468
##
clients/src/main/java/org/apache/kafka/common/telemetry/internals/KafkaMetricsCollector.java:
##
@@ -0,0 +1,341 @@
+/*
+ * Licensed to the Apache Software
apoorvmittal10 commented on code in PR #14620:
URL: https://github.com/apache/kafka/pull/14620#discussion_r1390691654
##
clients/src/main/java/org/apache/kafka/common/telemetry/internals/KafkaMetricsCollector.java:
##
@@ -0,0 +1,341 @@
+/*
+ * Licensed to the Apache Software
apoorvmittal10 commented on code in PR #14620:
URL: https://github.com/apache/kafka/pull/14620#discussion_r1390691332
##
clients/src/main/java/org/apache/kafka/common/telemetry/internals/KafkaMetricsCollector.java:
##
@@ -0,0 +1,341 @@
+/*
+ * Licensed to the Apache Software
apoorvmittal10 commented on code in PR #14620:
URL: https://github.com/apache/kafka/pull/14620#discussion_r1390690505
##
clients/src/main/java/org/apache/kafka/common/telemetry/internals/KafkaMetricsCollector.java:
##
@@ -0,0 +1,347 @@
+/*
+ * Licensed to the Apache Software
apoorvmittal10 commented on code in PR #14620:
URL: https://github.com/apache/kafka/pull/14620#discussion_r1390690071
##
clients/src/main/java/org/apache/kafka/common/telemetry/internals/LastValueTracker.java:
##
@@ -0,0 +1,88 @@
+/*
+ * Licensed to the Apache Software
apoorvmittal10 commented on code in PR #14620:
URL: https://github.com/apache/kafka/pull/14620#discussion_r1390688746
##
clients/src/main/java/org/apache/kafka/common/telemetry/internals/SinglePointMetric.java:
##
@@ -0,0 +1,157 @@
+/*
+ * Licensed to the Apache Software
Apoorv Mittal created KAFKA-15812:
-
Summary: Add support to send only sparse metrics, only non-zero
values
Key: KAFKA-15812
URL: https://issues.apache.org/jira/browse/KAFKA-15812
Project: Kafka
Apoorv Mittal created KAFKA-15811:
-
Summary: implement capturing client port information from Socket
Server
Key: KAFKA-15811
URL: https://issues.apache.org/jira/browse/KAFKA-15811
Project: Kafka
rain.liang created KAFKA-15810:
--
Summary: Is there a solution to build Kafka-2.7 with gradle-8.4
and jdk-21?
Key: KAFKA-15810
URL: https://issues.apache.org/jira/browse/KAFKA-15810
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-15809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Phuc Hong Tran updated KAFKA-15809:
---
Fix Version/s: 3.7.0
> Adding TS to broker's features list and updating broker's metadata
[
https://issues.apache.org/jira/browse/KAFKA-15809?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17785379#comment-17785379
]
Phuc Hong Tran edited comment on KAFKA-15809 at 11/13/23 6:23 AM:
--
[
https://issues.apache.org/jira/browse/KAFKA-15809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Phuc Hong Tran updated KAFKA-15809:
---
Labels: KIP-405 (was: )
> Adding TS to broker's features list and updating broker's
[
https://issues.apache.org/jira/browse/KAFKA-15809?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17785379#comment-17785379
]
Phuc Hong Tran commented on KAFKA-15809:
[~divijvaidya], since we're updating the
[
https://issues.apache.org/jira/browse/KAFKA-15686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiahongchao closed KAFKA-15686.
---
> Consumer should be able to detect network problem
> -
Vaibhav-Nazare commented on PR #13817:
URL: https://github.com/apache/kafka/pull/13817#issuecomment-1807487012
Hi @mimaison Can we rerun the job now, jdk_21_latest has been installed on
the shared power nodes by ASF infra.
--
This is an automated message from the Apache Git Service.
To
ableegoldman commented on PR #14708:
URL: https://github.com/apache/kafka/pull/14708#issuecomment-1807479243
Ah shoot, sorry everyone, I just clicked immediately on the test failure tab
and glossed over the build report on the landing page. Wish we still had the
individual version builds
github-actions[bot] commented on PR #14168:
URL: https://github.com/apache/kafka/pull/14168#issuecomment-1807425026
This PR is being marked as stale since it has not had any activity in 90
days. If you would like to keep this PR alive, please ask a committer for
review. If the PR has
github-actions[bot] commented on PR #14109:
URL: https://github.com/apache/kafka/pull/14109#issuecomment-1807425064
This PR is being marked as stale since it has not had any activity in 90
days. If you would like to keep this PR alive, please ask a committer for
review. If the PR has
lianetm commented on code in PR #14690:
URL: https://github.com/apache/kafka/pull/14690#discussion_r1390590490
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/MembershipManagerImpl.java:
##
@@ -181,33 +256,465 @@ public void
lianetm commented on code in PR #14690:
URL: https://github.com/apache/kafka/pull/14690#discussion_r1390583612
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/MemberState.java:
##
@@ -17,57 +17,111 @@
package org.apache.kafka.clients.consumer.internals;
lianetm commented on code in PR #14690:
URL: https://github.com/apache/kafka/pull/14690#discussion_r1390582429
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/TopicMetadataRequestManager.java:
##
@@ -96,7 +96,7 @@ public NetworkClientDelegate.PollResult
linzihao1999 commented on PR #14715:
URL: https://github.com/apache/kafka/pull/14715#issuecomment-1807392262
Passed the CI build.
https://ci-builds.apache.org/blue/organizations/jenkins/Kafka%2Fkafka-pr/detail/PR-14715/2/pipeline
--
This is an automated message from the Apache Git
linzihao1999 commented on PR #14668:
URL: https://github.com/apache/kafka/pull/14668#issuecomment-1807388570
@dengziming Hi, I re-trigger the CI build and passed.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
[
https://issues.apache.org/jira/browse/KAFKA-15341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17785337#comment-17785337
]
Phuc Hong Tran edited comment on KAFKA-15341 at 11/12/23 11:27 PM:
---
[
https://issues.apache.org/jira/browse/KAFKA-15341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17785337#comment-17785337
]
Phuc Hong Tran commented on KAFKA-15341:
[~divijvaidya] I have created subtask
Phuc Hong Tran created KAFKA-15809:
--
Summary: Adding TS to broker's features list and updating broker's
metadata schema to include TS enable status
Key: KAFKA-15809
URL:
hanyuzheng7 opened a new pull request, #14745:
URL: https://github.com/apache/kafka/pull/14745
KIP-997:
https://cwiki.apache.org/confluence/display/KAFKA/KIP-997%3A++Support+fetch%28fromKey%2C+toKey%2C+from%2C+to%29+to+WindowRangeQuery+and+unify+WindowKeyQuery+and+WindowRangeQuery
We
jolshan commented on PR #14506:
URL: https://github.com/apache/kafka/pull/14506#issuecomment-1807174506
Thanks @showuon for taking a look. Makes sense to me.
I also saw the conversation here. https://github.com/apache/kafka/pull/14741
--
This is an automated message from the Apache
runom opened a new pull request, #14744:
URL: https://github.com/apache/kafka/pull/14744
This PR fixed the position of the assertion that checks that `BytesOut`
doesn't include replication.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and
runom commented on code in PR #14661:
URL: https://github.com/apache/kafka/pull/14661#discussion_r1390407748
##
tools/src/main/java/org/apache/kafka/tools/TopicCommand.java:
##
@@ -469,7 +469,7 @@ public void createTopic(CommandTopicPartition topic) throws
Exception {
runom commented on PR #14661:
URL: https://github.com/apache/kafka/pull/14661#issuecomment-1807117335
I've updated the pull request. `TopicCommandTest` and
`TopicCommandIntegrationTest` are passing.
--
This is an automated message from the Apache Git Service.
To respond to the message,
[
https://issues.apache.org/jira/browse/KAFKA-15341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17785136#comment-17785136
]
Phuc Hong Tran edited comment on KAFKA-15341 at 11/12/23 9:49 AM:
--
dajac opened a new pull request, #14743:
URL: https://github.com/apache/kafka/pull/14743
*More detailed description of your change,
if necessary. The PR title and PR message become
the squashed commit message, so use a separate
comment to ping reviewers.*
*Summary of testing
dajac commented on PR #14728:
URL: https://github.com/apache/kafka/pull/14728#issuecomment-1807054468
Thanks for the PR. I believe that isolating the workload from the
produce/fetch workload (running in the api handlers) is actually a good thing
but we would need to measure to compare both
vamossagar12 commented on PR #14742:
URL: https://github.com/apache/kafka/pull/14742#issuecomment-1807053171
Yes, I realised it later on :D
--
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
vamossagar12 commented on PR #14741:
URL: https://github.com/apache/kafka/pull/14741#issuecomment-1807052792
> @showuon , I noticed the JDK21 build failed with `[this-escape] possible
'this' escape before subclass is fully initialized`. I created [this
vamossagar12 closed pull request #14742: Adding this-escape for
MaterializedStoreFactory implementors
URL: https://github.com/apache/kafka/pull/14742
--
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
dajac commented on PR #14742:
URL: https://github.com/apache/kafka/pull/14742#issuecomment-1807052588
Thanks for looking into this but I just merged
https://github.com/apache/kafka/pull/14740 to fix it.
--
This is an automated message from the Apache Git Service.
To respond to the
vamossagar12 commented on PR #14741:
URL: https://github.com/apache/kafka/pull/14741#issuecomment-1807052287
@showuon , I noticed the JDK21 build failed with `[this-escape] possible
'this' escape before subclass is fully initialized`. I created [this
vamossagar12 opened a new pull request, #14742:
URL: https://github.com/apache/kafka/pull/14742
Noticed the latest https://github.com/apache/kafka/pull/14741 [failed
compileJava on JDK
21](https://ci-builds.apache.org/blue/organizations/jenkins/Kafka%2Fkafka-pr/detail/PR-14741/1/pipeline/)
58 matches
Mail list logo
