[
https://issues.apache.org/jira/browse/KAFKA-19573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen resolved KAFKA-19573.
---
Resolution: Fixed
> Update num.recovery.threads.per.data.dir configs
> -
showuon merged PR #20299:
URL: https://github.com/apache/kafka/pull/20299
--
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 unsubscribe, e-mail: jira-unsubscr...@kafka.apache.
github-actions[bot] commented on PR #18977:
URL: https://github.com/apache/kafka/pull/18977#issuecomment-3162355509
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 leave a comment asking for a
review. If the P
github-actions[bot] commented on PR #20260:
URL: https://github.com/apache/kafka/pull/20260#issuecomment-3162317516
A label of 'needs-attention' was automatically added to this PR in order to
raise the
attention of the committers. Once this issue has been triaged, the `triage`
label
s
github-actions[bot] commented on PR #19204:
URL: https://github.com/apache/kafka/pull/19204#issuecomment-3162318873
A label of 'needs-attention' was automatically added to this PR in order to
raise the
attention of the committers. Once this issue has been triaged, the `triage`
label
s
github-actions[bot] commented on PR #18706:
URL: https://github.com/apache/kafka/pull/18706#issuecomment-3162319226
A label of 'needs-attention' was automatically added to this PR in order to
raise the
attention of the committers. Once this issue has been triaged, the `triage`
label
s
github-actions[bot] commented on PR #19927:
URL: https://github.com/apache/kafka/pull/19927#issuecomment-3162318069
A label of 'needs-attention' was automatically added to this PR in order to
raise the
attention of the committers. Once this issue has been triaged, the `triage`
label
s
TaiJuWu opened a new pull request, #20318:
URL: https://github.com/apache/kafka/pull/20318
Instead of sending out BeginQuorum requests to every voter on a cadence, we
can save on some requests by only sending to those which have not fetched
within the fetch timeout.
--
This is an automat
[
https://issues.apache.org/jira/browse/KAFKA-16926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TaiJuWu reassigned KAFKA-16926:
---
Assignee: TaiJuWu (was: Quoc Phong Dang)
> Optimize BeginQuorumEpoch heartbeat
> -
kirktrue commented on PR #19980:
URL: https://github.com/apache/kafka/pull/19980#issuecomment-3162066628
Here are some preliminary results:
| Metric | CLASSIC (trunk) | CONSUMER (trunk)
| CONSUMER (branch)|
|:---|---
Rob Young created KAFKA-19584:
-
Summary: Native docker image authentication fails with SASL PLAIN
Key: KAFKA-19584
URL: https://issues.apache.org/jira/browse/KAFKA-19584
Project: Kafka
Issue Type
Rob Young created KAFKA-19583:
-
Summary: Native docker image fails to start when using SASL
OAUTHBEARER mechanism
Key: KAFKA-19583
URL: https://issues.apache.org/jira/browse/KAFKA-19583
Project: Kafka
mjsax merged PR #20284:
URL: https://github.com/apache/kafka/pull/20284
--
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 unsubscribe, e-mail: jira-unsubscr...@kafka.apache.or
jsancio commented on code in PR #19589:
URL: https://github.com/apache/kafka/pull/19589#discussion_r2258341169
##
raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java:
##
@@ -3271,13 +3317,46 @@ private long pollFollowerAsVoter(FollowerState state,
long currentTimeMs)
[
https://issues.apache.org/jira/browse/KAFKA-4007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans updated KAFKA-4007:
--
Component/s: clients
> Improve fetch pipelining for low values of max.poll.records
> --
k-raina commented on code in PR #20144:
URL: https://github.com/apache/kafka/pull/20144#discussion_r2258086094
##
clients/src/main/java/org/apache/kafka/common/telemetry/internals/ClientTelemetryReporter.java:
##
@@ -713,14 +716,20 @@ private Optional>
createPushRequest(ClientT
jolshan commented on PR #19699:
URL: https://github.com/apache/kafka/pull/19699#issuecomment-3161284148
@FrankYang0529 @chia7712 How are things going here? I can help review if we
need to get it over the line.
cc: @artemlivshits @rreddy-22
--
This is an automated message from the
k-raina commented on code in PR #20144:
URL: https://github.com/apache/kafka/pull/20144#discussion_r2258038334
##
clients/src/main/java/org/apache/kafka/common/telemetry/internals/ClientTelemetryReporter.java:
##
@@ -379,14 +382,25 @@ public Optional>
createRequest() {
apoorvmittal10 commented on code in PR #20144:
URL: https://github.com/apache/kafka/pull/20144#discussion_r2257849303
##
clients/src/main/java/org/apache/kafka/common/telemetry/internals/ClientTelemetryReporter.java:
##
@@ -713,14 +716,20 @@ private Optional>
createPushRequest(
[
https://issues.apache.org/jira/browse/KAFKA-19558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18012411#comment-18012411
]
Ranuga Disansa commented on KAFKA-19558:
hi, i am looking into this, i will give
[
https://issues.apache.org/jira/browse/KAFKA-19558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ranuga Disansa reassigned KAFKA-19558:
--
Assignee: Ranuga Disansa
> kafka-consumer-groups.sh --describe --all-groups command t
chia7712 commented on PR #19513:
URL: https://github.com/apache/kafka/pull/19513#issuecomment-3160881920
@dejan2609 any update?
--
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 commen
chia7712 merged PR #20313:
URL: https://github.com/apache/kafka/pull/20313
--
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 unsubscribe, e-mail: jira-unsubscr...@kafka.apache
[
https://issues.apache.org/jira/browse/KAFKA-19582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
黃竣陽 reassigned KAFKA-19582:
---
Assignee: 黃竣陽 (was: Chia-Ping Tsai)
> the current assignments shown by ReassignPartitionsCommand should in
apoorvmittal10 commented on code in PR #20290:
URL: https://github.com/apache/kafka/pull/20290#discussion_r2256984922
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ShareConsumerImpl.java:
##
@@ -895,12 +895,14 @@ private void close(final Duration timeout,
chirag-wadhwa5 commented on code in PR #20280:
URL: https://github.com/apache/kafka/pull/20280#discussion_r2257665532
##
core/src/test/java/kafka/server/share/DelayedShareFetchTest.java:
##
@@ -1761,6 +1859,16 @@ public void
testRemoteStorageFetchHappensForAllTopicPartitions()
Programmer-RD-AI commented on code in PR #20213:
URL: https://github.com/apache/kafka/pull/20213#discussion_r2257666156
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ClassicKafkaConsumer.java:
##
@@ -1283,6 +1292,48 @@ private void updateLastSeenEpochIfNew
[
https://issues.apache.org/jira/browse/KAFKA-19582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai reassigned KAFKA-19582:
--
Assignee: Chia-Ping Tsai
> the current assignments shown by ReassignPartitionsCommand
[
https://issues.apache.org/jira/browse/KAFKA-19582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai updated KAFKA-19582:
---
Issue Type: Bug (was: Improvement)
> the current assignments shown by ReassignPartitionsCom
Chia-Ping Tsai created KAFKA-19582:
--
Summary: the current assignments shown by
ReassignPartitionsCommand should include the log directories
Key: KAFKA-19582
URL: https://issues.apache.org/jira/browse/KAFKA-19582
chia7712 merged PR #20312:
URL: https://github.com/apache/kafka/pull/20312
--
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 unsubscribe, e-mail: jira-unsubscr...@kafka.apache
mimaison commented on PR #19762:
URL: https://github.com/apache/kafka/pull/19762#issuecomment-3160754449
@jsancio Can you take another look? Thanks
--
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
mingyen066 opened a new pull request, #20317:
URL: https://github.com/apache/kafka/pull/20317
Fixes a typo in ProducerConfig:
Renames
`PARTITIONER_ADPATIVE_PARTITIONING_ENABLE_CONFIG` →
`PARTITIONER_ADAPTIVE_PARTITIONING_ENABLE_CONFIG`
The old key is retained for backward co
MartinJohannessen commented on PR #11442:
URL: https://github.com/apache/kafka/pull/11442#issuecomment-3160650045
Guys, please. I need this. I'm having to literally make a hundred individual
worker configurations instead of one, because I don't have this.
--
This is an automated message f
chia7712 commented on code in PR #20312:
URL: https://github.com/apache/kafka/pull/20312#discussion_r2257546961
##
core/src/main/java/kafka/server/QuotaFactory.java:
##
@@ -51,61 +51,14 @@ public void record(long value) {
}
};
-public static class QuotaManage
jim0987795064 commented on code in PR #20068:
URL: https://github.com/apache/kafka/pull/20068#discussion_r2257295892
##
core/src/test/scala/integration/kafka/api/PlaintextAdminIntegrationTest.scala:
##
@@ -2850,6 +2851,33 @@ class PlaintextAdminIntegrationTest extends
BaseAdmin
sjhajharia commented on PR #20303:
URL: https://github.com/apache/kafka/pull/20303#issuecomment-3159921077
ccL: @jolshan as you authored KIP-1022 PRs.
--
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
jim0987795064 commented on PR #20199:
URL: https://github.com/apache/kafka/pull/20199#issuecomment-3159776077
> @jim0987795064 could you please fix the conflicts
Thanks for this comment, I've already fixed this conflicts
--
This is an automated message from the Apache Git Service.
T
[
https://issues.apache.org/jira/browse/KAFKA-17243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TaiJuWu reassigned KAFKA-17243:
---
Assignee: TaiJuWu (was: Chu Cheng Li)
> MetadataQuorumCommand describe to include CommittedVoters
jmmonte2 commented on PR #20298:
URL: https://github.com/apache/kafka/pull/20298#issuecomment-3160143725
@squah-confluent Thank you! I noticed the approval did not go through due
to lack of write access. Do you have another reviewer I can add on?
--
This is an automated message from the
apoorvmittal10 commented on PR #20246:
URL: https://github.com/apache/kafka/pull/20246#issuecomment-3160029498
@JimmyWang6 I think we should support both i.e. current and strict
functionality. That means if the acquire method is called with acquire mode as
`strict` then we should only acqui
apoorvmittal10 commented on code in PR #20280:
URL: https://github.com/apache/kafka/pull/20280#discussion_r2257007459
##
core/src/main/java/kafka/server/share/DelayedShareFetch.java:
##
@@ -368,6 +368,12 @@ public boolean tryComplete() {
"topic partition
apoorvmittal10 opened a new pull request, #20316:
URL: https://github.com/apache/kafka/pull/20316
Minor PR to move persister call outside of the lock. The lock is not
required while making the persister call.
--
This is an automated message from the Apache Git Service.
To respond to the m
apoorvmittal10 opened a new pull request, #20315:
URL: https://github.com/apache/kafka/pull/20315
The PR removes unnecessary updates for find next fetch offset. When the
state is in transition and not yet completed then anyways respective offsets
should not be considered for acquisition. Th
[
https://issues.apache.org/jira/browse/KAFKA-19012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18012357#comment-18012357
]
Krzysztof Barczynski edited comment on KAFKA-19012 at 8/6/25 11:41 AM:
---
[
https://issues.apache.org/jira/browse/KAFKA-19012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18012357#comment-18012357
]
Krzysztof Barczynski commented on KAFKA-19012:
--
Today we experienced the sa
[
https://issues.apache.org/jira/browse/KAFKA-19012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Krzysztof Barczynski updated KAFKA-19012:
-
Attachment: image-2025-08-06-13-34-30-830.png
> Messages ending up on the wrong
sjhajharia commented on PR #20214:
URL: https://github.com/apache/kafka/pull/20214#issuecomment-3159376019
Thank you @chia7712 for the review. I have addressed the same.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
sjhajharia commented on code in PR #20214:
URL: https://github.com/apache/kafka/pull/20214#discussion_r2256733952
##
trogdor/src/main/java/org/apache/kafka/trogdor/workload/PartitionsSpec.java:
##
@@ -84,7 +83,9 @@ public List partitionNumbers() {
}
ret
[
https://issues.apache.org/jira/browse/KAFKA-19502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Apoorv Mittal resolved KAFKA-19502.
---
Fix Version/s: 4.2.0
Resolution: Not A Problem
> During write state call processing,
[
https://issues.apache.org/jira/browse/KAFKA-19502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18012331#comment-18012331
]
Apoorv Mittal commented on KAFKA-19502:
---
Closing this ticket as LSO can't be moved
Pankraz76 commented on PR #20314:
URL: https://github.com/apache/kafka/pull/20314#issuecomment-3158121526
```
> Task :rewriteDryRun
No recipes were activated. Activate a recipe with
rewrite.activeRecipe("com.fully.qualified.RecipeClassName") in your build file,
or on the command line
Pankraz76 commented on PR #20219:
URL: https://github.com/apache/kafka/pull/20219#issuecomment-3158149355
kindly request some feedback on enabler:
- https://github.com/apache/kafka/pull/20314
--
This is an automated message from the Apache Git Service.
To respond to the message, ple
Pankraz76 opened a new pull request, #20314:
URL: https://github.com/apache/kafka/pull/20314
enabler for:
- https://github.com/apache/kafka/pull/20219
### PoC: Add `rewrite` support for
`errorprone.refasterrules.FileRulesRecipes`
trying to automate efforts like:
Pankraz76 commented on PR #20278:
URL: https://github.com/apache/kafka/pull/20278#issuecomment-3157819091
reconsider
--
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 uns
Pankraz76 closed pull request #20278: MINOR: Align order on gradle command
URL: https://github.com/apache/kafka/pull/20278
--
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 un
joshua2519 opened a new pull request, #20313:
URL: https://github.com/apache/kafka/pull/20313
The link for the heading Errant Record Reporter is missing the # symbol,
which is causing it to redirect to a 404 Not Found page.
--
This is an automated message from the Apache Git Service.
To r
57 matches
Mail list logo