[
https://issues.apache.org/jira/browse/KAFKA-12506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17827837#comment-17827837
]
Arpit Goyal commented on KAFKA-12506:
-
[~ableegoldman] Is this ticket still open to work upon ? I
github-actions[bot] commented on PR #14950:
URL: https://github.com/apache/kafka/pull/14950#issuecomment-2002866951
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
chiacyu opened a new pull request, #15552:
URL: https://github.com/apache/kafka/pull/15552
The current document about Zookeeper to kraft migration is depreciated.
Accord to [KIP-833: Mark KRaft as Production
[
https://issues.apache.org/jira/browse/KAFKA-16376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17827825#comment-17827825
]
Chia-Ping Tsai commented on KAFKA-16376:
[~brandboat] you are right. will close this as
[
https://issues.apache.org/jira/browse/KAFKA-16376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai resolved KAFKA-16376.
Resolution: Duplicate
> Fix flaky ReplicaManagerTest.testRemoteFetchExpiresPerSecMetric
>
[
https://issues.apache.org/jira/browse/KAFKA-16376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17827824#comment-17827824
]
Kuan Po Tseng commented on KAFKA-16376:
---
Correct me if I'm wrong, but this appears to be a
[
https://issues.apache.org/jira/browse/KAFKA-16376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
PoAn Yang reassigned KAFKA-16376:
-
Assignee: PoAn Yang
> Fix flaky ReplicaManagerTest.testRemoteFetchExpiresPerSecMetric
>
[
https://issues.apache.org/jira/browse/KAFKA-16376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17827821#comment-17827821
]
Chia-Ping Tsai commented on KAFKA-16376:
[~yangpoan] go ahead :)
> Fix flaky
[
https://issues.apache.org/jira/browse/KAFKA-16376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17827820#comment-17827820
]
PoAn Yang commented on KAFKA-16376:
---
Hi [~chia7712], may I take this issue? I would like to try this.
[
https://issues.apache.org/jira/browse/KAFKA-16376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17827819#comment-17827819
]
Chris Holland commented on KAFKA-16376:
---
Hey, I un-assigned myself for now as I am unfamiliar with
TaiJuWu commented on code in PR #15551:
URL: https://github.com/apache/kafka/pull/15551#discussion_r1527638304
##
server-common/src/main/java/org/apache/kafka/queue/KafkaEventQueue.java:
##
@@ -260,6 +260,7 @@ private void handleEvents() throws InterruptedException {
TaiJuWu closed pull request #15551: MINOR: unlock before closing queue
URL: https://github.com/apache/kafka/pull/15551
--
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
chia7712 commented on code in PR #15551:
URL: https://github.com/apache/kafka/pull/15551#discussion_r1527631191
##
server-common/src/main/java/org/apache/kafka/queue/KafkaEventQueue.java:
##
@@ -260,6 +260,7 @@ private void handleEvents() throws InterruptedException {
TaiJuWu opened a new pull request, #15551:
URL: https://github.com/apache/kafka/pull/15551
*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
chia7712 commented on code in PR #15483:
URL: https://github.com/apache/kafka/pull/15483#discussion_r1527554674
##
clients/src/main/java/org/apache/kafka/common/metrics/KafkaMetric.java:
##
@@ -78,6 +111,10 @@ public Measurable measurable() {
}
}
+/**
+
johnnychhsu commented on code in PR #15483:
URL: https://github.com/apache/kafka/pull/15483#discussion_r1527554056
##
clients/src/main/java/org/apache/kafka/common/metrics/KafkaMetric.java:
##
@@ -40,15 +48,30 @@ public KafkaMetric(Object lock, MetricName metricName,
johnnychhsu opened a new pull request, #15550:
URL: https://github.com/apache/kafka/pull/15550
## Context
In KafkaMetirc.java, the config getter is
```
@Override
public MetricName metricName()
{ return this.metricName; }
```
and there is a setter
```
johnnychhsu commented on code in PR #15483:
URL: https://github.com/apache/kafka/pull/15483#discussion_r1527553634
##
clients/src/main/java/org/apache/kafka/common/metrics/KafkaMetric.java:
##
@@ -40,15 +48,30 @@ public KafkaMetric(Object lock, MetricName metricName,
Johnny Hsu created KAFKA-16381:
--
Summary: We should use a lock to protect the config getter in
KafkaMetric
Key: KAFKA-16381
URL: https://issues.apache.org/jira/browse/KAFKA-16381
Project: Kafka
chia7712 commented on code in PR #15483:
URL: https://github.com/apache/kafka/pull/15483#discussion_r1527537826
##
clients/src/main/java/org/apache/kafka/common/metrics/KafkaMetric.java:
##
@@ -40,15 +48,30 @@ public KafkaMetric(Object lock, MetricName metricName,
johnnychhsu commented on PR #15483:
URL: https://github.com/apache/kafka/pull/15483#issuecomment-2002480150
tested with
```
./gradlew cleanTest core:test --tests ConnectionQuotasTest --tests
ControllerMutationQuotaTest stream:test --tests StandbyTaskTest --tests
StreamTaskTest
johnnychhsu commented on code in PR #15483:
URL: https://github.com/apache/kafka/pull/15483#discussion_r1527503839
##
clients/src/main/java/org/apache/kafka/common/metrics/KafkaMetric.java:
##
@@ -40,15 +48,28 @@ public KafkaMetric(Object lock, MetricName metricName,
johnnychhsu commented on PR #15476:
URL: https://github.com/apache/kafka/pull/15476#issuecomment-2002453829
@chia7712 thanks for the reminder.
Below are the failed tests from the build
> [Build / JDK 17 and Scala 2.13 /
[
https://issues.apache.org/jira/browse/KAFKA-16263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17827779#comment-17827779
]
Kuan Po Tseng commented on KAFKA-16263:
---
May I take over this issue ? I'm quite interested in
jinyongchoi commented on code in PR #15495:
URL: https://github.com/apache/kafka/pull/15495#discussion_r1527474042
##
docs/streams/developer-guide/memory-mgmt.html:
##
@@ -151,6 +151,10 @@
Serdes.Long())
.withCachingEnabled();
Record caches are not supported for
chia7712 commented on PR #15476:
URL: https://github.com/apache/kafka/pull/15476#issuecomment-2002394407
@johnnychhsu Could you check the failed tests?
--
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
brandboat opened a new pull request, #15549:
URL: https://github.com/apache/kafka/pull/15549
This is part of
[KAFKA-16232](https://issues.apache.org/jira/browse/KAFKA-16232)
> 2. add logs before and after future waiting, to allow admin to know we're
waiting for the authorizer future.
[
https://issues.apache.org/jira/browse/KAFKA-15538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17827769#comment-17827769
]
Phuc Hong Tran commented on KAFKA-15538:
nvm I figured out what you meant
> Client support for
28 matches
Mail list logo
