TaiJuWu commented on code in PR #20068:
URL: https://github.com/apache/kafka/pull/20068#discussion_r2199668697
##
core/src/test/scala/integration/kafka/api/PlaintextAdminIntegrationTest.scala:
##
@@ -2850,6 +2851,21 @@ class PlaintextAdminIntegrationTest extends
BaseAdminIntegr
lucasbru commented on code in PR #20147:
URL: https://github.com/apache/kafka/pull/20147#discussion_r2199779001
##
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/KafkaStreamsTelemetryIntegrationTest.java:
##
@@ -279,18 +281,28 @@ public void shouldP
adixitconfluent commented on code in PR #20124:
URL: https://github.com/apache/kafka/pull/20124#discussion_r2199764435
##
core/src/main/java/kafka/server/share/SharePartition.java:
##
@@ -2054,7 +2054,15 @@ void rollbackOrProcessStateUpdates(
// Log in DEBUG to
TaiJuWu commented on code in PR #20068:
URL: https://github.com/apache/kafka/pull/20068#discussion_r2199668697
##
core/src/test/scala/integration/kafka/api/PlaintextAdminIntegrationTest.scala:
##
@@ -2850,6 +2851,21 @@ class PlaintextAdminIntegrationTest extends
BaseAdminIntegr
TaiJuWu commented on code in PR #20068:
URL: https://github.com/apache/kafka/pull/20068#discussion_r2199668697
##
core/src/test/scala/integration/kafka/api/PlaintextAdminIntegrationTest.scala:
##
@@ -2850,6 +2851,21 @@ class PlaintextAdminIntegrationTest extends
BaseAdminIntegr
TaiJuWu commented on code in PR #20068:
URL: https://github.com/apache/kafka/pull/20068#discussion_r2199668697
##
core/src/test/scala/integration/kafka/api/PlaintextAdminIntegrationTest.scala:
##
@@ -2850,6 +2851,21 @@ class PlaintextAdminIntegrationTest extends
BaseAdminIntegr
TaiJuWu commented on code in PR #20068:
URL: https://github.com/apache/kafka/pull/20068#discussion_r2199668697
##
core/src/test/scala/integration/kafka/api/PlaintextAdminIntegrationTest.scala:
##
@@ -2850,6 +2851,21 @@ class PlaintextAdminIntegrationTest extends
BaseAdminIntegr
shashankhs11 opened a new pull request, #20149:
URL: https://github.com/apache/kafka/pull/20149
This PR addresses [KAFKA-14405
JIRA](https://issues.apache.org/jira/browse/KAFKA-14405) and builds upon
significant work done from #12988.
### Initial Problem
It's too easy for users to
TaiJuWu commented on code in PR #20068:
URL: https://github.com/apache/kafka/pull/20068#discussion_r2199668697
##
core/src/test/scala/integration/kafka/api/PlaintextAdminIntegrationTest.scala:
##
@@ -2850,6 +2851,21 @@ class PlaintextAdminIntegrationTest extends
BaseAdminIntegr
github-actions[bot] commented on PR #20096:
URL: https://github.com/apache/kafka/pull/20096#issuecomment-3060257695
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 #20103:
URL: https://github.com/apache/kafka/pull/20103#issuecomment-3060257665
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
DL1231 opened a new pull request, #20148:
URL: https://github.com/apache/kafka/pull/20148
This patch mainly includes two improvements:
1. Update currentFetch when `pollForFetches()` throws an exception.
2. Add an override `KafkaShareConsumer.acknowledge(String topic, int
partition,
[
https://issues.apache.org/jira/browse/KAFKA-19493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lan Ding reassigned KAFKA-19493:
Assignee: Lan Ding
> Incorrect rate metric with larger window size
>
chia7712 commented on code in PR #20021:
URL: https://github.com/apache/kafka/pull/20021#discussion_r2199017407
##
metadata/src/main/java/org/apache/kafka/image/loader/metrics/MetadataLoaderMetrics.java:
##
@@ -142,16 +176,85 @@ public long handleLoadSnapshotCount() {
r
junrao commented on code in PR #20121:
URL: https://github.com/apache/kafka/pull/20121#discussion_r2198952441
##
core/src/test/scala/unit/kafka/server/LogRecoveryTest.scala:
##
@@ -215,7 +215,7 @@ class LogRecoveryTest extends QuorumTestHarness {
server2.startup()
upda
ezhou413 commented on PR #20134:
URL: https://github.com/apache/kafka/pull/20134#issuecomment-3059361507
I've decided to push a code change since this bug report was made by a user.
We can discuss opening a KIP for the usage of `Properties` as its own separate
thing.
--
This is an autom
mjsax commented on code in PR #20147:
URL: https://github.com/apache/kafka/pull/20147#discussion_r2198869297
##
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/KafkaStreamsTelemetryIntegrationTest.java:
##
@@ -279,18 +281,28 @@ public void shouldPass
mjsax commented on code in PR #20147:
URL: https://github.com/apache/kafka/pull/20147#discussion_r2198869297
##
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/KafkaStreamsTelemetryIntegrationTest.java:
##
@@ -279,18 +281,28 @@ public void shouldPass
mjsax opened a new pull request, #20147:
URL: https://github.com/apache/kafka/pull/20147
The new "streams" protocol behaves slightly different to the "classic"
protocol, and thus we need to update the test to avoid race conditions. In
particular, the first call to `poll()` won't "block" and
ahuang98 commented on code in PR #20136:
URL: https://github.com/apache/kafka/pull/20136#discussion_r2198758987
##
core/src/test/scala/unit/kafka/tools/StorageToolTest.scala:
##
@@ -387,22 +387,32 @@ Found problem:
}
@Test
- def testFormatWithStandaloneAndInitialControl
ahuang98 commented on code in PR #20136:
URL: https://github.com/apache/kafka/pull/20136#discussion_r2198753693
##
core/src/test/scala/unit/kafka/tools/StorageToolTest.scala:
##
@@ -376,6 +376,8 @@ Found problem:
val availableDirs = Seq(TestUtils.tempDir())
val propert
apoorvmittal10 commented on code in PR #20144:
URL: https://github.com/apache/kafka/pull/20144#discussion_r2198617405
##
clients/src/main/java/org/apache/kafka/common/telemetry/internals/ClientTelemetryReporter.java:
##
@@ -717,7 +718,7 @@ private Optional>
createPushRequest(Cl
apoorvmittal10 commented on code in PR #20144:
URL: https://github.com/apache/kafka/pull/20144#discussion_r2198617405
##
clients/src/main/java/org/apache/kafka/common/telemetry/internals/ClientTelemetryReporter.java:
##
@@ -717,7 +718,7 @@ private Optional>
createPushRequest(Cl
apoorvmittal10 commented on code in PR #20124:
URL: https://github.com/apache/kafka/pull/20124#discussion_r2198603871
##
core/src/main/java/kafka/server/share/SharePartition.java:
##
@@ -2054,7 +2054,15 @@ void rollbackOrProcessStateUpdates(
// Log in DEBUG to a
kirktrue opened a new pull request, #20146:
URL: https://github.com/apache/kafka/pull/20146
Adding instrumentation for `KafkaProducer` to detect when the topic a
message was written to changes after it's enqueued.
--
This is an automated message from the Apache Git Service.
To respond to
kirktrue closed pull request #20138: [WIP] KAFKA-19012: Messages ending up on
the wrong topic
URL: https://github.com/apache/kafka/pull/20138
--
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 spec
dongnuo123 commented on PR #20024:
URL: https://github.com/apache/kafka/pull/20024#issuecomment-3058796452
@FrankYang0529 For EndTxnRequest we already have some integration tests in
TransactionTest.scala but I guess we should have one for WriteTxnMarkersRequest
to test the protection on the
ijuma commented on code in PR #19881:
URL: https://github.com/apache/kafka/pull/19881#discussion_r2198543449
##
clients/src/main/java/org/apache/kafka/common/telemetry/internals/ClientTelemetryReporter.java:
##
@@ -718,8 +717,8 @@ private Optional>
createPushRequest(ClientTelem
lucasbru commented on PR #20084:
URL: https://github.com/apache/kafka/pull/20084#issuecomment-3058639838
https://github.com/user-attachments/assets/79a4674e-fcb6-4d8e-9650-616978064bac";
/>
Link to rendering, removed from PR descritpipn
--
This is an automated message from the
Yunyung commented on PR #20145:
URL: https://github.com/apache/kafka/pull/20145#issuecomment-3058631112
Many assume that the files under tests/kafkatest/services can be run
directly, but this is not the case. We should consider adding a note to clarify
this.
--
This is an automated messa
lucasbru commented on PR #18293:
URL: https://github.com/apache/kafka/pull/18293#issuecomment-3058610629
Adding some details as comments and removing from PR description so that
they don't end up in commit message:
Test results doesn't change dramatically
Before
Benchm
Yunyung opened a new pull request, #20145:
URL: https://github.com/apache/kafka/pull/20145
`tests/kafkatest/services/console_consumer.py` cannot be run directly. The
correct way is to run `tests/kafkatest/sanity_checks/test_console_consumer.py`.
--
This is an automated message from the Ap
[
https://issues.apache.org/jira/browse/KAFKA-14405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18004517#comment-18004517
]
Shashank commented on KAFKA-14405:
--
Hi [~ableegoldman], I would like to start working o
kevin-wu24 commented on code in PR #20136:
URL: https://github.com/apache/kafka/pull/20136#discussion_r2198390326
##
core/src/test/scala/unit/kafka/tools/StorageToolTest.scala:
##
@@ -376,6 +376,8 @@ Found problem:
val availableDirs = Seq(TestUtils.tempDir())
val prope
jim0987795064 commented on code in PR #20068:
URL: https://github.com/apache/kafka/pull/20068#discussion_r2198412169
##
core/src/test/scala/integration/kafka/api/PlaintextAdminIntegrationTest.scala:
##
@@ -2850,6 +2851,20 @@ class PlaintextAdminIntegrationTest extends
BaseAdmin
jim0987795064 commented on code in PR #20068:
URL: https://github.com/apache/kafka/pull/20068#discussion_r2198405354
##
core/src/test/scala/integration/kafka/api/PlaintextAdminIntegrationTest.scala:
##
@@ -2850,6 +2851,20 @@ class PlaintextAdminIntegrationTest extends
BaseAdmin
kevin-wu24 commented on code in PR #20136:
URL: https://github.com/apache/kafka/pull/20136#discussion_r2198390326
##
core/src/test/scala/unit/kafka/tools/StorageToolTest.scala:
##
@@ -376,6 +376,8 @@ Found problem:
val availableDirs = Seq(TestUtils.tempDir())
val prope
kevin-wu24 commented on code in PR #20136:
URL: https://github.com/apache/kafka/pull/20136#discussion_r2198387770
##
core/src/main/scala/kafka/tools/StorageTool.scala:
##
@@ -135,6 +135,15 @@ object StorageTool extends Logging {
featureNamesAndLevels(_).foreachEntry {
ahuang98 commented on code in PR #20136:
URL: https://github.com/apache/kafka/pull/20136#discussion_r2198338634
##
core/src/main/scala/kafka/tools/StorageTool.scala:
##
@@ -135,6 +135,15 @@ object StorageTool extends Logging {
featureNamesAndLevels(_).foreachEntry {
kevin-wu24 commented on code in PR #19982:
URL: https://github.com/apache/kafka/pull/19982#discussion_r2198365307
##
raft/src/test/java/org/apache/kafka/raft/KafkaRaftClientReconfigTest.java:
##
@@ -374,26 +428,104 @@ public void testAddVoter() throws Exception {
ap
kevin-wu24 commented on code in PR #19982:
URL: https://github.com/apache/kafka/pull/19982#discussion_r2198357341
##
raft/src/test/java/org/apache/kafka/raft/KafkaRaftClientReconfigTest.java:
##
@@ -374,26 +428,104 @@ public void testAddVoter() throws Exception {
ap
kevin-wu24 commented on code in PR #19982:
URL: https://github.com/apache/kafka/pull/19982#discussion_r2198336453
##
raft/src/test/java/org/apache/kafka/raft/KafkaRaftClientReconfigTest.java:
##
@@ -374,26 +428,104 @@ public void testAddVoter() throws Exception {
ap
Yunyung commented on code in PR #19905:
URL: https://github.com/apache/kafka/pull/19905#discussion_r2198282302
##
tools/src/main/java/org/apache/kafka/tools/LogCompactionTester.java:
##
@@ -0,0 +1,529 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
kevin-wu24 commented on code in PR #19982:
URL: https://github.com/apache/kafka/pull/19982#discussion_r2198357341
##
raft/src/test/java/org/apache/kafka/raft/KafkaRaftClientReconfigTest.java:
##
@@ -374,26 +428,104 @@ public void testAddVoter() throws Exception {
ap
Yunyung commented on code in PR #19905:
URL: https://github.com/apache/kafka/pull/19905#discussion_r2198339311
##
tools/src/main/java/org/apache/kafka/tools/LogCompactionTester.java:
##
@@ -0,0 +1,529 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
junrao commented on code in PR #20138:
URL: https://github.com/apache/kafka/pull/20138#discussion_r2198336561
##
clients/src/main/java/org/apache/kafka/clients/producer/internals/Sender.java:
##
@@ -884,6 +897,8 @@ private void sendProduceRequest(long now, int destination,
shor
kevin-wu24 commented on code in PR #19982:
URL: https://github.com/apache/kafka/pull/19982#discussion_r2198341063
##
raft/src/test/java/org/apache/kafka/raft/KafkaRaftClientReconfigTest.java:
##
@@ -339,27 +340,80 @@ public void testAddVoter() throws Exception {
Map
kevin-wu24 commented on code in PR #19982:
URL: https://github.com/apache/kafka/pull/19982#discussion_r2198336453
##
raft/src/test/java/org/apache/kafka/raft/KafkaRaftClientReconfigTest.java:
##
@@ -374,26 +428,104 @@ public void testAddVoter() throws Exception {
ap
ekuvardin commented on code in PR #18293:
URL: https://github.com/apache/kafka/pull/18293#discussion_r2198335513
##
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/acl/AuthorizerBenchmark.java:
##
@@ -89,13 +90,19 @@ public class AuthorizerBenchmark {
private List actions
ahuang98 commented on code in PR #19982:
URL: https://github.com/apache/kafka/pull/19982#discussion_r2198334121
##
raft/src/test/java/org/apache/kafka/raft/KafkaRaftClientReconfigTest.java:
##
@@ -374,26 +428,104 @@ public void testAddVoter() throws Exception {
apiV
ahuang98 commented on code in PR #19982:
URL: https://github.com/apache/kafka/pull/19982#discussion_r2198332477
##
raft/src/test/java/org/apache/kafka/raft/KafkaRaftClientReconfigTest.java:
##
@@ -374,26 +428,104 @@ public void testAddVoter() throws Exception {
apiV
kevin-wu24 commented on code in PR #19982:
URL: https://github.com/apache/kafka/pull/19982#discussion_r2198329004
##
raft/src/test/java/org/apache/kafka/raft/KafkaRaftClientReconfigTest.java:
##
@@ -339,27 +340,80 @@ public void testAddVoter() throws Exception {
Map
ekuvardin commented on code in PR #18293:
URL: https://github.com/apache/kafka/pull/18293#discussion_r2198319395
##
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/acl/StandardAuthorizerUpdateBenchmark.java:
##
@@ -55,8 +55,8 @@
@State(Scope.Benchmark)
@Fork(value = 1)
-@W
kevin-wu24 commented on code in PR #19982:
URL: https://github.com/apache/kafka/pull/19982#discussion_r2198315211
##
raft/src/test/java/org/apache/kafka/raft/KafkaRaftClientReconfigTest.java:
##
@@ -374,26 +428,104 @@ public void testAddVoter() throws Exception {
ap
Yunyung commented on code in PR #19905:
URL: https://github.com/apache/kafka/pull/19905#discussion_r2198269571
##
tools/src/main/java/org/apache/kafka/tools/LogCompactionTester.java:
##
@@ -0,0 +1,529 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
ahuang98 commented on code in PR #19982:
URL: https://github.com/apache/kafka/pull/19982#discussion_r2198305883
##
raft/src/test/java/org/apache/kafka/raft/KafkaRaftClientReconfigTest.java:
##
@@ -374,26 +428,104 @@ public void testAddVoter() throws Exception {
apiV
Yunyung commented on code in PR #19905:
URL: https://github.com/apache/kafka/pull/19905#discussion_r2198247187
##
tools/src/main/java/org/apache/kafka/tools/LogCompactionTester.java:
##
@@ -0,0 +1,529 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
ahuang98 commented on code in PR #19982:
URL: https://github.com/apache/kafka/pull/19982#discussion_r2198308763
##
raft/src/test/java/org/apache/kafka/raft/KafkaRaftClientReconfigTest.java:
##
@@ -339,27 +340,80 @@ public void testAddVoter() throws Exception {
Map.o
Yunyung commented on code in PR #19905:
URL: https://github.com/apache/kafka/pull/19905#discussion_r2198269571
##
tools/src/main/java/org/apache/kafka/tools/LogCompactionTester.java:
##
@@ -0,0 +1,529 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
ezhou413 commented on PR #20134:
URL: https://github.com/apache/kafka/pull/20134#issuecomment-3058284500
Sounds good to me. In this case, should we continue work on this PR?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
kevin-wu24 commented on PR #20021:
URL: https://github.com/apache/kafka/pull/20021#issuecomment-3058292121
@chia7712 Are you able to take another look? If there is anything else let
me know. Thanks for the reviews.
--
This is an automated message from the Apache Git Service.
To respond to
chia7712 commented on code in PR #20144:
URL: https://github.com/apache/kafka/pull/20144#discussion_r2198274135
##
clients/src/main/java/org/apache/kafka/common/telemetry/internals/ClientTelemetryReporter.java:
##
@@ -717,7 +718,7 @@ private Optional>
createPushRequest(ClientTe
k-raina commented on code in PR #19881:
URL: https://github.com/apache/kafka/pull/19881#discussion_r2198266270
##
clients/src/main/java/org/apache/kafka/common/telemetry/internals/ClientTelemetryReporter.java:
##
@@ -718,8 +717,8 @@ private Optional>
createPushRequest(ClientTel
k-raina commented on code in PR #19881:
URL: https://github.com/apache/kafka/pull/19881#discussion_r2198266270
##
clients/src/main/java/org/apache/kafka/common/telemetry/internals/ClientTelemetryReporter.java:
##
@@ -718,8 +717,8 @@ private Optional>
createPushRequest(ClientTel
k-raina commented on code in PR #19881:
URL: https://github.com/apache/kafka/pull/19881#discussion_r2198254154
##
clients/src/main/java/org/apache/kafka/common/telemetry/internals/ClientTelemetryReporter.java:
##
@@ -718,8 +717,8 @@ private Optional>
createPushRequest(ClientTel
k-raina opened a new pull request, #20144:
URL: https://github.com/apache/kafka/pull/20144
Instead of throwable, use specific error in compression catch handle
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL ab
chia7712 merged PR #19869:
URL: https://github.com/apache/kafka/pull/19869
--
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
chia7712 commented on code in PR #19881:
URL: https://github.com/apache/kafka/pull/19881#discussion_r2198189309
##
clients/src/main/java/org/apache/kafka/common/telemetry/internals/ClientTelemetryReporter.java:
##
@@ -718,8 +717,8 @@ private Optional>
createPushRequest(ClientTe
[
https://issues.apache.org/jira/browse/KAFKA-19493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18004473#comment-18004473
]
Apoorv Mittal edited comment on KAFKA-19493 at 7/10/25 3:59 PM:
--
[
https://issues.apache.org/jira/browse/KAFKA-19493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18004473#comment-18004473
]
Apoorv Mittal commented on KAFKA-19493:
---
[~isding_l] Please go ahead.
> Incorrect
[
https://issues.apache.org/jira/browse/KAFKA-19493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-19493:
Component/s: clients
metrics
> Incorrect rate metric with larger window s
[
https://issues.apache.org/jira/browse/KAFKA-19495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison updated KAFKA-19495:
---
Description:
I built a native image for 4.1.0-rc0
(https://github.com/apache/kafka/actions/
m1a2st commented on code in PR #20068:
URL: https://github.com/apache/kafka/pull/20068#discussion_r2198067365
##
core/src/test/scala/integration/kafka/api/PlaintextAdminIntegrationTest.scala:
##
@@ -2850,6 +2851,20 @@ class PlaintextAdminIntegrationTest extends
BaseAdminIntegra
Mickael Maison created KAFKA-19495:
--
Summary: DefaultJwtRetriever could not be found with Docker native
image
Key: KAFKA-19495
URL: https://issues.apache.org/jira/browse/KAFKA-19495
Project: Kafka
ijuma commented on code in PR #19881:
URL: https://github.com/apache/kafka/pull/19881#discussion_r2198051840
##
clients/src/main/java/org/apache/kafka/common/telemetry/internals/ClientTelemetryReporter.java:
##
@@ -718,8 +717,8 @@ private Optional>
createPushRequest(ClientTelem
adixitconfluent opened a new pull request, #20143:
URL: https://github.com/apache/kafka/pull/20143
(no comment)
--
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 unsubscri
KTKTK-HZ commented on PR #20084:
URL: https://github.com/apache/kafka/pull/20084#issuecomment-3057729468
@lucasbru Thanks for your suggestions. The document has been revised, and
the rendered results of the document have also been updated.
--
This is an automated message from the Apache G
Yunyung commented on PR #20134:
URL: https://github.com/apache/kafka/pull/20134#issuecomment-3057714702
> The usage of `Properties` should be deprecated in the public APIs.
Documentation should be added to suggest users use `Map` instead. Perhaps we
could add warning messages to remind user
squah-confluent commented on code in PR #20055:
URL: https://github.com/apache/kafka/pull/20055#discussion_r2197791218
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java:
##
@@ -3073,7 +3095,7 @@ private static boolean isNotEmpty(Stri
[
https://issues.apache.org/jira/browse/KAFKA-19444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18004433#comment-18004433
]
Ismael Juma commented on KAFKA-19444:
-
Filed KAFKA-19494 for undeprecating these ver
[
https://issues.apache.org/jira/browse/KAFKA-19493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18004427#comment-18004427
]
Lan Ding commented on KAFKA-19493:
--
Hi [~apoorvmittal10], if you're not working on this
ijuma opened a new pull request, #20142:
URL: https://github.com/apache/kafka/pull/20142
We added back support for JoinGroup v0 & v1 in Kafka 4.0.1 and 4.1.0 due to
KAFKA-19444. Given that, we should undeprecate these protocol api versions in
3.x.
--
This is an automated message from the
[
https://issues.apache.org/jira/browse/KAFKA-19494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismael Juma updated KAFKA-19494:
Fix Version/s: 3.7.3
3.8.2
3.9.2
> Undeprecate JoinGroup V0
Ismael Juma created KAFKA-19494:
---
Summary: Undeprecate JoinGroup V0 & V1 in 3.x
Key: KAFKA-19494
URL: https://issues.apache.org/jira/browse/KAFKA-19494
Project: Kafka
Issue Type: Improvement
lucasbru commented on PR #20127:
URL: https://github.com/apache/kafka/pull/20127#issuecomment-3057467823
> It’s likely these tests pass because such a closed-loop scenario is rare.
However, if that scenario does occur, the tests may fail, leading to flakiness.
To avoid introducing flaky tes
ijuma commented on PR #20116:
URL: https://github.com/apache/kafka/pull/20116#issuecomment-3057460501
Thanks @mimaison - that's correct.
--
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 specif
Apoorv Mittal created KAFKA-19493:
-
Summary: Incorrect rate metric with larger window size
Key: KAFKA-19493
URL: https://issues.apache.org/jira/browse/KAFKA-19493
Project: Kafka
Issue Type: B
chia7712 commented on PR #20134:
URL: https://github.com/apache/kafka/pull/20134#issuecomment-3057145239
> Yes, this is also a good alternative for me, but even if we use Map
instead of Properties, as far as I know, we still can’t prevent the user app
from passing in a Properties (unless we
Yunyung commented on PR #20134:
URL: https://github.com/apache/kafka/pull/20134#issuecomment-3057109935
Yes, this is also a good alternative for me, but even if we use Map
instead of Properties, as far as I know, we still can’t prevent the user from
passing in a Properties object (unless we
chia7712 commented on code in PR #19905:
URL: https://github.com/apache/kafka/pull/19905#discussion_r2197479627
##
tools/src/main/java/org/apache/kafka/tools/LogCompactionTester.java:
##
@@ -0,0 +1,529 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
chia7712 commented on PR #17870:
URL: https://github.com/apache/kafka/pull/17870#issuecomment-3057081487
> Yes, I do. It could control the amount of pre-fetching based on how
quickly it is processing the buffered records.
@kirktrue WDYT? it seems #18795 has similar discussion. Howeve
chia7712 commented on PR #20134:
URL: https://github.com/apache/kafka/pull/20134#issuecomment-3057031438
Just an idea: we should avoid using `Properties` in codebase. The
`Properties`'s defaults mechanism has not been used correctly for a while. I
opened https://issues.apache.org/jira/brow
gongxuanzhang commented on code in PR #20140:
URL: https://github.com/apache/kafka/pull/20140#discussion_r2197428759
##
docs/implementation.html:
##
@@ -59,11 +59,14 @@
chia7712 commented on PR #17870:
URL: https://github.com/apache/kafka/pull/17870#issuecomment-3056920837
> Today, it just looks to see whether it has any buffered data rather than
looking at how much buffered data it has. There's a nice KIP in this area one
day I think.
Excuse me, do
AndrewJSchofield commented on PR #17870:
URL: https://github.com/apache/kafka/pull/17870#issuecomment-3056940390
> > Today, it just looks to see whether it has any buffered data rather than
looking at how much buffered data it has. There's a nice KIP in this area one
day I think.
>
>
srdo opened a new pull request, #20141:
URL: https://github.com/apache/kafka/pull/20141
…errors
This exception can occur for a few different reasons, and the exception
message will say exactly why it happened. Debug logging it makes it easier for
people to debug OFFSET_OUT_OF_RANGE e
Stig Rohde Døssing created KAFKA-19492:
--
Summary: ReplicaManager.deleteRecordsOnLocalLog should debug log
the exception message when OffsetOutOfRangeException occurs
Key: KAFKA-19492
URL: https://issues.apach
Yunyung commented on code in PR #20140:
URL: https://github.com/apache/kafka/pull/20140#discussion_r2197359132
##
docs/implementation.html:
##
@@ -59,11 +59,14 @@
AndrewJSchofield commented on PR #17870:
URL: https://github.com/apache/kafka/pull/17870#issuecomment-3056862881
I think there's quite a lot of scope for improving this area in the regular
fetch. For example, the consumer could and currently does not adjust the
`PartitionMaxBytes` to contro
chia7712 commented on PR #17870:
URL: https://github.com/apache/kafka/pull/17870#issuecomment-3056839932
> Having said that, maybe we can think of a logic to perform a retry in both
fetch and share fetch in case the fetchable partitions are not returning enough
data from replica manager.
1 - 100 of 110 matches
Mail list logo
