dengziming commented on code in PR #14295:
URL: https://github.com/apache/kafka/pull/14295#discussion_r1308292372
##
core/src/test/scala/integration/kafka/api/ProducerFailureHandlingTest.scala:
##
@@ -38,6 +40,7 @@ class ProducerFailureHandlingTest extends
KafkaServerTestHarnes
dengziming merged PR #14294:
URL: https://github.com/apache/kafka/pull/14294
--
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.apac
dengziming commented on PR #14294:
URL: https://github.com/apache/kafka/pull/14294#issuecomment-1696856670
LGTM, test failures are unrelated.
--
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 s
cmccabe opened a new pull request, #14306:
URL: https://github.com/apache/kafka/pull/14306
Implement KIP-919: Allow AdminClient to Talk Directly with the KRaft
Controller Quorum and add Controller Registration. This KIP adds a new version
of DescribeClusterRequest which is supported by KRaf
rreddy-22 commented on code in PR #14182:
URL: https://github.com/apache/kafka/pull/14182#discussion_r1308181709
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/OptimizedUniformAssignmentBuilder.java:
##
@@ -0,0 +1,390 @@
+/*
+ * Licensed to the Ap
rreddy-22 commented on code in PR #14182:
URL: https://github.com/apache/kafka/pull/14182#discussion_r1308179490
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/OptimizedUniformAssignmentBuilder.java:
##
@@ -0,0 +1,390 @@
+/*
+ * Licensed to the Ap
rreddy-22 commented on code in PR #14182:
URL: https://github.com/apache/kafka/pull/14182#discussion_r1308177084
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/OptimizedUniformAssignmentBuilder.java:
##
@@ -0,0 +1,390 @@
+/*
+ * Licensed to the Ap
rreddy-22 commented on code in PR #14182:
URL: https://github.com/apache/kafka/pull/14182#discussion_r1308174694
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/OptimizedUniformAssignmentBuilder.java:
##
@@ -0,0 +1,390 @@
+/*
+ * Licensed to the Ap
rreddy-22 commented on code in PR #14182:
URL: https://github.com/apache/kafka/pull/14182#discussion_r1308174183
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/OptimizedUniformAssignmentBuilder.java:
##
@@ -0,0 +1,390 @@
+/*
+ * Licensed to the Ap
rreddy-22 commented on code in PR #14182:
URL: https://github.com/apache/kafka/pull/14182#discussion_r1308173397
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/OptimizedUniformAssignmentBuilder.java:
##
@@ -0,0 +1,390 @@
+/*
+ * Licensed to the Ap
rreddy-22 commented on code in PR #14182:
URL: https://github.com/apache/kafka/pull/14182#discussion_r1308173102
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/OptimizedUniformAssignmentBuilder.java:
##
@@ -0,0 +1,390 @@
+/*
+ * Licensed to the Ap
rreddy-22 commented on code in PR #14182:
URL: https://github.com/apache/kafka/pull/14182#discussion_r1308172074
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/OptimizedUniformAssignmentBuilder.java:
##
@@ -0,0 +1,390 @@
+/*
+ * Licensed to the Ap
rreddy-22 commented on code in PR #14182:
URL: https://github.com/apache/kafka/pull/14182#discussion_r1308171085
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/OptimizedUniformAssignmentBuilder.java:
##
@@ -0,0 +1,390 @@
+/*
+ * Licensed to the Ap
rreddy-22 commented on code in PR #14182:
URL: https://github.com/apache/kafka/pull/14182#discussion_r1308169146
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/OptimizedUniformAssignmentBuilder.java:
##
@@ -0,0 +1,390 @@
+/*
+ * Licensed to the Ap
rreddy-22 commented on code in PR #14182:
URL: https://github.com/apache/kafka/pull/14182#discussion_r1308167658
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/OptimizedUniformAssignmentBuilder.java:
##
@@ -0,0 +1,390 @@
+/*
+ * Licensed to the Ap
rreddy-22 commented on code in PR #14182:
URL: https://github.com/apache/kafka/pull/14182#discussion_r1308167128
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/OptimizedUniformAssignmentBuilder.java:
##
@@ -0,0 +1,390 @@
+/*
+ * Licensed to the Ap
rreddy-22 commented on code in PR #14182:
URL: https://github.com/apache/kafka/pull/14182#discussion_r1308166084
##
reviewers.py:
##
@@ -28,7 +28,7 @@
def prompt_for_user():
while True:
try:
-user_input = input("\nName or email (case insensitive): ")
rreddy-22 commented on code in PR #14182:
URL: https://github.com/apache/kafka/pull/14182#discussion_r1308165924
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/assignor/RangeAssignorTest.java:
##
@@ -103,9 +102,9 @@ public void testOneConsumerSubscribedToN
rreddy-22 commented on code in PR #14182:
URL: https://github.com/apache/kafka/pull/14182#discussion_r1308165291
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/common/TopicIdPartition.java:
##
@@ -0,0 +1,74 @@
+/*
+ * Licensed to the Apache Software Founda
rreddy-22 commented on code in PR #14182:
URL: https://github.com/apache/kafka/pull/14182#discussion_r1308164291
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/UniformAssignor.java:
##
@@ -0,0 +1,241 @@
+/*
+ * Licensed to the Apache Software Foun
satishd commented on code in PR #13561:
URL: https://github.com/apache/kafka/pull/13561#discussion_r1308153773
##
core/src/main/java/kafka/log/remote/RemoteLogManager.java:
##
@@ -761,11 +784,385 @@ public void run() {
}
}
+public void handleLogSt
github-actions[bot] commented on PR #13493:
URL: https://github.com/apache/kafka/pull/13493#issuecomment-1696716259
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 merge
github-actions[bot] commented on PR #13558:
URL: https://github.com/apache/kafka/pull/13558#issuecomment-1696716224
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 merge
github-actions[bot] commented on PR #13768:
URL: https://github.com/apache/kafka/pull/13768#issuecomment-1696716168
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 merge
[
https://issues.apache.org/jira/browse/KAFKA-15414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17759792#comment-17759792
]
Satish Duggana commented on KAFKA-15414:
Rebalance will be tried out after the t
[
https://issues.apache.org/jira/browse/KAFKA-15414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17759791#comment-17759791
]
Satish Duggana commented on KAFKA-15414:
[~fvisconte] There are a few pending ch
rreddy-22 commented on code in PR #14182:
URL: https://github.com/apache/kafka/pull/14182#discussion_r1308155008
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/UniformAssignor.java:
##
@@ -0,0 +1,241 @@
+/*
+ * Licensed to the Apache Software Foun
satishd commented on code in PR #13561:
URL: https://github.com/apache/kafka/pull/13561#discussion_r1308153773
##
core/src/main/java/kafka/log/remote/RemoteLogManager.java:
##
@@ -761,11 +784,385 @@ public void run() {
}
}
+public void handleLogSt
rreddy-22 commented on code in PR #14182:
URL: https://github.com/apache/kafka/pull/14182#discussion_r1308152462
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/UniformAssignor.java:
##
@@ -0,0 +1,241 @@
+/*
+ * Licensed to the Apache Software Foun
rreddy-22 commented on code in PR #14182:
URL: https://github.com/apache/kafka/pull/14182#discussion_r1308151486
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/UniformAssignor.java:
##
@@ -0,0 +1,241 @@
+/*
+ * Licensed to the Apache Software Foun
rreddy-22 commented on code in PR #14182:
URL: https://github.com/apache/kafka/pull/14182#discussion_r1308150974
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/UniformAssignor.java:
##
@@ -0,0 +1,241 @@
+/*
+ * Licensed to the Apache Software Foun
rreddy-22 commented on code in PR #14182:
URL: https://github.com/apache/kafka/pull/14182#discussion_r1308150557
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/UniformAssignor.java:
##
@@ -0,0 +1,241 @@
+/*
+ * Licensed to the Apache Software Foun
showuon commented on code in PR #13561:
URL: https://github.com/apache/kafka/pull/13561#discussion_r1308148879
##
core/src/main/java/kafka/log/remote/RemoteLogManager.java:
##
@@ -761,11 +784,385 @@ public void run() {
}
}
+public void handleLogSt
Luke Chen created KAFKA-15414:
-
Summary: remote logs get deleted after partition reassignment
Key: KAFKA-15414
URL: https://issues.apache.org/jira/browse/KAFKA-15414
Project: Kafka
Issue Type: Bu
rreddy-22 commented on code in PR #14182:
URL: https://github.com/apache/kafka/pull/14182#discussion_r1308143447
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/UniformAssignor.java:
##
@@ -0,0 +1,241 @@
+/*
+ * Licensed to the Apache Software Foun
rreddy-22 commented on code in PR #14182:
URL: https://github.com/apache/kafka/pull/14182#discussion_r1308140708
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/RangeAssignor.java:
##
@@ -17,6 +17,8 @@
package org.apache.kafka.coordinator.group.as
rreddy-22 commented on code in PR #14182:
URL: https://github.com/apache/kafka/pull/14182#discussion_r1308137334
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/OptimizedUniformAssignmentBuilder.java:
##
@@ -0,0 +1,399 @@
+/*
+ * Licensed to the Ap
kirktrue commented on code in PR #14305:
URL: https://github.com/apache/kafka/pull/14305#discussion_r1308117301
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractFetch.java:
##
Review Comment:
Author’s note: most of these changes are related to th
kirktrue commented on code in PR #14305:
URL: https://github.com/apache/kafka/pull/14305#discussion_r1308116494
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/CompletedFetch.java:
##
Review Comment:
Author’s note: mostly encapsulating the instance vari
kirktrue commented on code in PR #14305:
URL: https://github.com/apache/kafka/pull/14305#discussion_r1308113122
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/RequestState.java:
##
@@ -27,26 +31,21 @@ class RequestState {
private int numAttempts = 0;
kirktrue commented on code in PR #14305:
URL: https://github.com/apache/kafka/pull/14305#discussion_r1308113100
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/RequestState.java:
##
@@ -27,26 +31,21 @@ class RequestState {
private int numAttempts = 0;
kirktrue commented on code in PR #14305:
URL: https://github.com/apache/kafka/pull/14305#discussion_r1308112596
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/RequestState.java:
##
@@ -66,13 +65,19 @@ public boolean canSendRequest(final long currentTimeMs)
kirktrue commented on code in PR #14305:
URL: https://github.com/apache/kafka/pull/14305#discussion_r1308111718
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/RequestState.java:
##
@@ -66,13 +65,19 @@ public boolean canSendRequest(final long currentTimeMs)
kirktrue commented on code in PR #14305:
URL: https://github.com/apache/kafka/pull/14305#discussion_r1308111377
##
clients/src/main/java/org/apache/kafka/common/utils/ExponentialBackoff.java:
##
Review Comment:
Author’s note: adding `toString()` implementations is helpful i
kirktrue commented on code in PR #14305:
URL: https://github.com/apache/kafka/pull/14305#discussion_r1308109624
##
clients/src/main/java/org/apache/kafka/clients/NetworkClientUtils.java:
##
Review Comment:
Author’s note: The two new methods in this file were moved here from
kirktrue commented on code in PR #14305:
URL: https://github.com/apache/kafka/pull/14305#discussion_r1308109624
##
clients/src/main/java/org/apache/kafka/clients/NetworkClientUtils.java:
##
Review Comment:
Reviewer’s note: The two new methods in this file were moved here fr
kirktrue opened a new pull request, #14305:
URL: https://github.com/apache/kafka/pull/14305
This change introduces some basic clean up and refactoring for forthcoming
commits related to the revised fetch code for the consumer threading refactor
project.
See KAFKA-14274 for more backg
junrao commented on code in PR #14118:
URL: https://github.com/apache/kafka/pull/14118#discussion_r1308049575
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/WakeupTrigger.java:
##
@@ -0,0 +1,105 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) un
philipnee commented on code in PR #14118:
URL: https://github.com/apache/kafka/pull/14118#discussion_r1308028327
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/WakeupTrigger.java:
##
@@ -0,0 +1,105 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
jolshan commented on PR #14302:
URL: https://github.com/apache/kafka/pull/14302#issuecomment-1696520592
Hey @mannoopj can we include the name of the ticket in the PR title?
> Reading an unknown version of quorum-state-file should trigger an error
--
This is an automated message fro
philipnee commented on code in PR #14118:
URL: https://github.com/apache/kafka/pull/14118#discussion_r1308022177
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/WakeupTrigger.java:
##
@@ -0,0 +1,105 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
jolshan commented on PR #14296:
URL: https://github.com/apache/kafka/pull/14296#issuecomment-1696516543
@kamalcph so it looks like it isn't a kraft specific issue. Are you saying
you also disabled other tests? I believe there is a way to run tests all on
their own via Jenkins. I do wonder i
jolshan closed pull request #10461: KAFKA-12603: Add benchmarks for
handleFetchRequest and FetchContext
URL: https://github.com/apache/kafka/pull/10461
--
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 t
jolshan closed pull request #10071: KAFKA-12298: Create
LeaderAndIsrRequestBenchmark
URL: https://github.com/apache/kafka/pull/10071
--
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 comm
junrao commented on code in PR #14118:
URL: https://github.com/apache/kafka/pull/14118#discussion_r1308011131
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/WakeupTrigger.java:
##
@@ -0,0 +1,105 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) un
gharris1727 commented on code in PR #14303:
URL: https://github.com/apache/kafka/pull/14303#discussion_r1307943936
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectorConfig.java:
##
@@ -429,7 +429,9 @@ void enrich(ConfigDef newDef) {
fina
tanay27 commented on PR #14229:
URL: https://github.com/apache/kafka/pull/14229#issuecomment-1696392904
> Thank you for making this change @tanay27. Couple of remaining actions:
>
> 1. Please add a README.md in the release folder mentioning what you added
in the description here, i.e.
tanay27 commented on PR #14229:
URL: https://github.com/apache/kafka/pull/14229#issuecomment-1696389809
> ```python3 version_change.py --version 3.6.2
WARNING: Couldn't write lextab module . Won't
overwrite existing lextab module
WARNING: yacc table file version is out of date
WARNI
C0urante opened a new pull request, #14304:
URL: https://github.com/apache/kafka/pull/14304
[Jira 1](https://issues.apache.org/jira/browse/KAFKA-13328), [Jira
2](https://issues.apache.org/jira/browse/KAFKA-13329)
Adds preflight validation checks for key, value, and header converter
c
C0urante commented on code in PR #14303:
URL: https://github.com/apache/kafka/pull/14303#discussion_r1307910654
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectorConfig.java:
##
@@ -429,7 +429,9 @@ void enrich(ConfigDef newDef) {
final C
dopuskh3 commented on code in PR #13561:
URL: https://github.com/apache/kafka/pull/13561#discussion_r1307788374
##
core/src/main/java/kafka/log/remote/RemoteLogManager.java:
##
@@ -761,11 +784,385 @@ public void run() {
}
}
+public void handleLogS
dopuskh3 commented on code in PR #13561:
URL: https://github.com/apache/kafka/pull/13561#discussion_r1307788374
##
core/src/main/java/kafka/log/remote/RemoteLogManager.java:
##
@@ -761,11 +784,385 @@ public void run() {
}
}
+public void handleLogS
gharris1727 commented on code in PR #14303:
URL: https://github.com/apache/kafka/pull/14303#discussion_r1307738833
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectorConfig.java:
##
@@ -429,7 +429,9 @@ void enrich(ConfigDef newDef) {
fina
Taher-Ghaleb commented on PR #14264:
URL: https://github.com/apache/kafka/pull/14264#issuecomment-1696099110
Hi @jolshan. I resolved the conflict and removed the extra space. Thanks.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Gi
philipnee commented on code in PR #14118:
URL: https://github.com/apache/kafka/pull/14118#discussion_r1307729523
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/WakeupTrigger.java:
##
@@ -0,0 +1,105 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
philipnee commented on code in PR #14118:
URL: https://github.com/apache/kafka/pull/14118#discussion_r1307713180
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/WakeupTrigger.java:
##
@@ -0,0 +1,105 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
[
https://issues.apache.org/jira/browse/KAFKA-15411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya updated KAFKA-15411:
-
Labels: flaky-test (was: )
> DelegationTokenEndToEndAuthorizationWithOwnerTest is Flaky
>
[
https://issues.apache.org/jira/browse/KAFKA-14517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17759655#comment-17759655
]
Jimmy Wang commented on KAFKA-14517:
Can I pick up this? Interested in this issue a
[
https://issues.apache.org/jira/browse/KAFKA-15372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Harris reassigned KAFKA-15372:
---
Assignee: Greg Harris
> MM2 rolling restart can drop configuration changes silently
> -
[
https://issues.apache.org/jira/browse/KAFKA-15408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17759648#comment-17759648
]
Sagar Rao commented on KAFKA-15408:
---
Hi, the steps are outline here:
https://cwiki.ap
[
https://issues.apache.org/jira/browse/KAFKA-15411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17759643#comment-17759643
]
Proven Provenzano commented on KAFKA-15411:
---
Ran a loop and couldn't get it to
[
https://issues.apache.org/jira/browse/KAFKA-13329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton updated KAFKA-13329:
--
Description:
Users may specify a key and/or value converter class for their connector
directl
C0urante commented on code in PR #14303:
URL: https://github.com/apache/kafka/pull/14303#discussion_r1307643119
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectorConfig.java:
##
@@ -429,7 +429,9 @@ void enrich(ConfigDef newDef) {
final C
jolshan commented on PR #14264:
URL: https://github.com/apache/kafka/pull/14264#issuecomment-1695959642
@Taher-Ghaleb can you pull in the latest changes from master and resolve
conflicts?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
jolshan commented on code in PR #14264:
URL: https://github.com/apache/kafka/pull/14264#discussion_r1307621341
##
streams/src/test/java/org/apache/kafka/streams/processor/internals/StoreToProcessorContextAdapterTest.java:
##
@@ -26,10 +26,12 @@
import org.easymock.MockType;
im
C0urante closed pull request #11369: KAFKA-13327, KAFKA-13328, KAFKA-13329:
Clean up preflight connector validation
URL: https://github.com/apache/kafka/pull/11369
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL a
C0urante commented on PR #11369:
URL: https://github.com/apache/kafka/pull/11369#issuecomment-1695946733
A lot of merge conflicts have accrued on this one. Instead of resolving them
all at once, I've decided to split this PR out into three smaller PRs, which
should also make the review proc
C0urante commented on PR #14303:
URL: https://github.com/apache/kafka/pull/14303#issuecomment-1695943788
@gharris1727 since you reviewed https://github.com/apache/kafka/pull/11369,
would you be interested in taking a look at its new successor?
--
This is an automated message from the Apac
C0urante opened a new pull request, #14303:
URL: https://github.com/apache/kafka/pull/14303
[Jira](https://issues.apache.org/jira/browse/KAFKA-13327)
Background context: this is split off from
https://github.com/apache/kafka/pull/11369, which addressed this issue and two
others. Not
mannoopj opened a new pull request, #14302:
URL: https://github.com/apache/kafka/pull/14302
Reading an unknown version of quorum-state-file should trigger an error.
Currently the only known version is 0. Reading any other version should cause
an error.
--
This is an automated message fr
satishd merged PR #14297:
URL: https://github.com/apache/kafka/pull/14297
--
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.
satishd commented on PR #14297:
URL: https://github.com/apache/kafka/pull/14297#issuecomment-1695842125
There are a few test failures that are unrelated to this change. Merging to
trunk and 3.6 branches.
--
This is an automated message from the Apache Git Service.
To respond to the messag
}}
is set on Ubuntu.
{*}Steps to reproduce{*}:
kafka/zookeeper.properties
{noformat}
dataDir=/tmp/kafka-test-20230828-15217-1lop1tk/zookeeper
clientPort=34461
maxClientCnxns=0
admin.enableServer=false
{noformat}
kafka/server.properties
{noformat}
broker.id=0
listeners=PLAINTEXT://:46161
num.network
John Mannooparambil created KAFKA-15412:
---
Summary: Reading an unknown version of quorum-state-file should
trigger an error
Key: KAFKA-15412
URL: https://issues.apache.org/jira/browse/KAFKA-15412
dajac commented on code in PR #14271:
URL: https://github.com/apache/kafka/pull/14271#discussion_r1307484913
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java:
##
@@ -426,9 +429,43 @@ public CompletableFuture
listGroups(
dajac commented on code in PR #14271:
URL: https://github.com/apache/kafka/pull/14271#discussion_r1307484913
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java:
##
@@ -426,9 +429,43 @@ public CompletableFuture
listGroups(
dajac commented on code in PR #14271:
URL: https://github.com/apache/kafka/pull/14271#discussion_r1307483188
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java:
##
@@ -426,9 +429,43 @@ public CompletableFuture
listGroups(
dajac commented on code in PR #14271:
URL: https://github.com/apache/kafka/pull/14271#discussion_r1307482348
##
clients/src/main/resources/common/message/ListGroupsRequest.json:
##
@@ -23,11 +23,15 @@
// Version 3 is the first flexible version.
//
// Version 4 adds the
dajac merged PR #14120:
URL: https://github.com/apache/kafka/pull/14120
--
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
[
https://issues.apache.org/jira/browse/KAFKA-15353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison updated KAFKA-15353:
---
Affects Version/s: 3.5.1
> Empty ISR returned from controller after AlterPartition request
>
pprovenzano commented on PR #14083:
URL: https://github.com/apache/kafka/pull/14083#issuecomment-1695736206
> DelegationTokenEndToEndAuthorizationWithOwnerTest
I created https://issues.apache.org/jira/browse/KAFKA-15411 and will start
looking at it today.
--
This is an automated me
Proven Provenzano created KAFKA-15411:
-
Summary: DelegationTokenEndToEndAuthorizationWithOwnerTest is
Flaky
Key: KAFKA-15411
URL: https://issues.apache.org/jira/browse/KAFKA-15411
Project: Kafka
satishd commented on code in PR #14301:
URL: https://github.com/apache/kafka/pull/14301#discussion_r1307433933
##
storage/src/test/java/org/apache/kafka/tiered/storage/integration/OffloadAndConsumeFromLeaderTest.java:
##
@@ -127,7 +127,7 @@ protected void
writeTestSpecification
satishd commented on code in PR #14301:
URL: https://github.com/apache/kafka/pull/14301#discussion_r1307431851
##
storage/src/test/java/org/apache/kafka/tiered/storage/integration/OffloadAndConsumeFromLeaderTest.java:
##
@@ -127,7 +127,7 @@ protected void
writeTestSpecification
Kamal Chandraprakash created KAFKA-15410:
Summary: Add basic functionality integration test with tiered
storage
Key: KAFKA-15410
URL: https://issues.apache.org/jira/browse/KAFKA-15410
Project:
[
https://issues.apache.org/jira/browse/KAFKA-15410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kamal Chandraprakash updated KAFKA-15410:
-
Parent: KAFKA-7739
Issue Type: Sub-task (was: Task)
> Add basic functio
[
https://issues.apache.org/jira/browse/KAFKA-14954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17759558#comment-17759558
]
Arpit Goyal commented on KAFKA-14954:
-
[~abhijeetkumar] Can i pick this up or you a
kamalcph commented on PR #14301:
URL: https://github.com/apache/kafka/pull/14301#issuecomment-1695539631
### Test Report
```scala
[SUCCESS] (1) create topic: Topic[name=topicA partition-count=1
replication-factor=1 segment-size=1 assignment=null
properties={remote.storage.enable=t
divijvaidya commented on PR #14229:
URL: https://github.com/apache/kafka/pull/14229#issuecomment-1695535002
The output of the script has an indentation problem in the following diff,
it is not having the correct indentation for ""
```
diff --git a/streams/quickstart/java/pom.xml
b/str
divijvaidya commented on PR #14229:
URL: https://github.com/apache/kafka/pull/14229#issuecomment-1695531757
@tanay27 When I run this script, I get the following warnings:
```
python3 version_change.py --version 3.6.2
WARNING: Couldn't write lextab module . Won't
overwrite existing l
1 - 100 of 152 matches
Mail list logo
