adixitconfluent commented on code in PR #19659:
URL: https://github.com/apache/kafka/pull/19659#discussion_r2084058088
##
core/src/main/java/kafka/server/share/SharePartitionManager.java:
##
@@ -746,6 +747,29 @@ private Consumer>
failedShareAcknowledgeMetricsHandler() {
chia7712 commented on PR #19674:
URL: https://github.com/apache/kafka/pull/19674#issuecomment-2871630063
@Mirai1129 the `log.cleaner.threads` will have new limit in 5.0, so could
you please add warning to it as well?
see mail channel:
https://lists.apache.org/thread/njh18y6jk44ok864z
Mirai1129 commented on PR #19675:
URL: https://github.com/apache/kafka/pull/19675#issuecomment-2871149846
@FrankYang0529 Thanks for the feedback! I’ve updated the documentation, run
the server, and attached a screenshot of the result
 under
dajac commented on code in PR #19515:
URL: https://github.com/apache/kafka/pull/19515#discussion_r2083979793
##
clients/src/test/java/org/apache/kafka/common/requests/OffsetFetchRequestTest.java:
##
@@ -42,17 +43,21 @@ public void testWithMultipleGroups(short version) {
frankvicky commented on code in PR #19515:
URL: https://github.com/apache/kafka/pull/19515#discussion_r2083987875
##
clients/src/test/java/org/apache/kafka/common/requests/OffsetFetchRequestTest.java:
##
@@ -42,17 +43,21 @@ public void testWithMultipleGroups(short version) {
chia7712 commented on code in PR #18929:
URL: https://github.com/apache/kafka/pull/18929#discussion_r2084007870
##
core/src/main/scala/kafka/server/KafkaApis.scala:
##
@@ -3620,7 +3620,50 @@ class KafkaApis(val requestChannel: RequestChannel,
def handleAlterShareGroupOffset
AndrewJSchofield commented on code in PR #18929:
URL: https://github.com/apache/kafka/pull/18929#discussion_r2083621752
##
clients/src/main/java/org/apache/kafka/common/requests/AlterShareGroupOffsetsRequest.java:
##
@@ -65,7 +65,8 @@ public AbstractResponse getErrorResponse(int
AndrewJSchofield commented on code in PR #19666:
URL: https://github.com/apache/kafka/pull/19666#discussion_r2084054302
##
core/src/main/java/kafka/server/share/SharePartitionCache.java:
##
@@ -0,0 +1,87 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or mo
apalan60 opened a new pull request, #19681:
URL: https://github.com/apache/kafka/pull/19681
[Jira: KAFKA-19034](https://issues.apache.org/jira/browse/KAFKA-19034)
This PR rewrites `RemoteTopicCrudTest` in Java using the `@ClusterTest`
framework and moves it to the `storage` module.
apalan60 commented on PR #19681:
URL: https://github.com/apache/kafka/pull/19681#issuecomment-2871799339
I’ve rerun these tests several times locally and verified they pass
consistently, minimizing the risk of flakiness.
--
This is an automated message from the Apache Git Service.
To resp
dajac opened a new pull request, #19683:
URL: https://github.com/apache/kafka/pull/19683
WIP
--
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: jir
[
https://issues.apache.org/jira/browse/KAFKA-19051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrew Schofield resolved KAFKA-19051.
--
Resolution: Won't Fix
Reviewing this issue, it is clear that the behaviour suggested i
ahuang98 opened a new pull request, #19689:
URL: https://github.com/apache/kafka/pull/19689
Reviewers: Colin P. McCabe
```
Conflicts:
clients/src/main/java/org/apache/kafka/common/requests/AlterUserScramCredentialsRequest.java
- import statement
clients/src/main/java/o
cmccabe commented on code in PR #19586:
URL: https://github.com/apache/kafka/pull/19586#discussion_r2085194500
##
metadata/src/main/java/org/apache/kafka/controller/QuorumController.java:
##
@@ -1928,6 +1930,7 @@ public CompletableFuture
processBrokerHeartbeat(
Control
cmccabe commented on code in PR #19586:
URL: https://github.com/apache/kafka/pull/19586#discussion_r2085194087
##
metadata/src/main/java/org/apache/kafka/controller/QuorumController.java:
##
@@ -1781,6 +1782,7 @@ public CompletableFuture unregisterBroker(
ControllerRequ
cmccabe commented on code in PR #19586:
URL: https://github.com/apache/kafka/pull/19586#discussion_r2085194087
##
metadata/src/main/java/org/apache/kafka/controller/QuorumController.java:
##
@@ -1781,6 +1782,7 @@ public CompletableFuture unregisterBroker(
ControllerRequ
ahuang98 opened a new pull request, #19690:
URL: https://github.com/apache/kafka/pull/19690
Reviewers: Colin P. McCabe
```
Conflicts:
clients/src/main/java/org/apache/kafka/common/requests/AlterUserScramCredentialsRequest.java
- import statement
clients/src/main/java/
bbejeck commented on PR #19691:
URL: https://github.com/apache/kafka/pull/19691#issuecomment-2873740208
@aliehsaeedii PTAL
--
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.
bbejeck commented on code in PR #19691:
URL: https://github.com/apache/kafka/pull/19691#discussion_r2085303970
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java:
##
@@ -1983,8 +1984,16 @@ private CoordinatorResult stream
Str
jsancio merged PR #19644:
URL: https://github.com/apache/kafka/pull/19644
--
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-18905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17951043#comment-17951043
]
José Armando García Sancio commented on KAFKA-18905:
When fixing the
[
https://issues.apache.org/jira/browse/KAFKA-9199?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17951044#comment-17951044
]
José Armando García Sancio commented on KAFKA-9199:
---
When fixing the is
[
https://issues.apache.org/jira/browse/KAFKA-9199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
José Armando García Sancio updated KAFKA-9199:
--
Component/s: clients
> Improve handling of out of sequence errors lower
[
https://issues.apache.org/jira/browse/KAFKA-18961?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17951026#comment-17951026
]
Sean Quah commented on KAFKA-18961:
---
It looks like the metadata image mechanism also l
dajac merged PR #19686:
URL: https://github.com/apache/kafka/pull/19686
--
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
apalan60 commented on code in PR #19681:
URL: https://github.com/apache/kafka/pull/19681#discussion_r2085347732
##
storage/src/test/java/org/apache/kafka/admin/RemoteTopicCrudTest.java:
##
@@ -0,0 +1,833 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or mo
apalan60 commented on code in PR #19681:
URL: https://github.com/apache/kafka/pull/19681#discussion_r2085346384
##
storage/src/test/java/org/apache/kafka/admin/RemoteTopicCrudTest.java:
##
@@ -0,0 +1,833 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or mo
apalan60 commented on PR #19681:
URL: https://github.com/apache/kafka/pull/19681#issuecomment-2873812003
> Thank @apalan60 for this patch, left some comments
@m1a2st
Thanks for your review. I’ve made the corresponding changes. PTAL!
--
This is an automated message from the A
junrao commented on code in PR #19661:
URL: https://github.com/apache/kafka/pull/19661#discussion_r2085075108
##
clients/src/main/java/org/apache/kafka/common/record/FileRecords.java:
##
@@ -54,33 +54,52 @@ public class FileRecords extends AbstractRecords implements
Closeable {
chia7712 commented on code in PR #19679:
URL: https://github.com/apache/kafka/pull/19679#discussion_r2085087191
##
clients/src/test/java/org/apache/kafka/clients/admin/internals/ListConsumerGroupOffsetsHandlerTest.java:
##
@@ -158,7 +158,7 @@ public void testBuildRequestWithMult
jsancio commented on code in PR #19668:
URL: https://github.com/apache/kafka/pull/19668#discussion_r2085093925
##
raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java:
##
@@ -2771,16 +2776,17 @@ private RequestSendResult maybeSendRequest(
Supplier requestSuppli
AndrewJSchofield merged PR #19684:
URL: https://github.com/apache/kafka/pull/19684
--
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...@kafk
lianetm commented on code in PR #19515:
URL: https://github.com/apache/kafka/pull/19515#discussion_r2084965325
##
clients/src/main/java/org/apache/kafka/common/requests/OffsetFetchRequest.java:
##
@@ -52,13 +54,37 @@ public static class Builder extends
AbstractRequest.Builder
Lucas Brutschy created KAFKA-19271:
--
Summary: Private interface for injecting test wrappers for
KIP-1071 enabled consumers
Key: KAFKA-19271
URL: https://issues.apache.org/jira/browse/KAFKA-19271
Proj
kirktrue commented on code in PR #19622:
URL: https://github.com/apache/kafka/pull/19622#discussion_r2085243526
##
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/OAuthBearerLoginCallbackHandler.java:
##
@@ -179,55 +180,45 @@ public class OAuthBearerLoginCallb
kirktrue commented on code in PR #19622:
URL: https://github.com/apache/kafka/pull/19622#discussion_r2085243145
##
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/OAuthBearerLoginCallbackHandler.java:
##
@@ -179,55 +180,45 @@ public class OAuthBearerLoginCallb
dajac commented on code in PR #19515:
URL: https://github.com/apache/kafka/pull/19515#discussion_r2085256581
##
core/src/test/scala/unit/kafka/server/KafkaApisTest.scala:
##
@@ -8269,6 +8276,7 @@ class KafkaApisTest extends Logging {
.setGroupId("group-1")
dajac commented on code in PR #19515:
URL: https://github.com/apache/kafka/pull/19515#discussion_r2085262516
##
core/src/test/scala/unit/kafka/server/KafkaApisTest.scala:
##
@@ -8349,23 +8377,168 @@ class KafkaApisTest extends Logging {
.setGroupId("group-4")
.
dajac commented on code in PR #19515:
URL: https://github.com/apache/kafka/pull/19515#discussion_r2085263820
##
core/src/test/scala/unit/kafka/server/ConsumerProtocolMigrationTest.scala:
##
@@ -1197,15 +1201,17 @@ class ConsumerProtocolMigrationTest(cluster:
ClusterInstance) ex
lianetm commented on code in PR #19622:
URL: https://github.com/apache/kafka/pull/19622#discussion_r2085329910
##
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/secured/DefaultJwtValidator.java:
##
@@ -0,0 +1,106 @@
+/*
+ * Licensed to the Apache So
bbejeck commented on code in PR #19691:
URL: https://github.com/apache/kafka/pull/19691#discussion_r2085379528
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java:
##
@@ -1983,8 +1984,16 @@ private CoordinatorResult stream
Str
jsancio merged PR #19658:
URL: https://github.com/apache/kafka/pull/19658
--
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-18345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
José Armando García Sancio updated KAFKA-18345:
---
Fix Version/s: 3.8.2
3.9.2
4.0.
bbejeck commented on code in PR #19691:
URL: https://github.com/apache/kafka/pull/19691#discussion_r2085305508
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java:
##
@@ -1993,6 +2002,7 @@ private CoordinatorResult stream
adixitconfluent commented on PR #19682:
URL: https://github.com/apache/kafka/pull/19682#issuecomment-2872075593
> Thanks @adixitconfluent for this PR. However, I believe it's a duplicate
of #19679.
ahh sorry, thanks for pointing @m1a2st . I'll close my PR in that case.
--
This is a
m1a2st commented on PR #19682:
URL: https://github.com/apache/kafka/pull/19682#issuecomment-2872069859
Thanks @adixitconfluent for this PR. However, I believe it's a duplicate of
https://github.com/apache/kafka/pull/19679.
--
This is an automated message from the Apache Git Service.
To re
adixitconfluent commented on PR #19682:
URL: https://github.com/apache/kafka/pull/19682#issuecomment-2872087480
Duplicate of PR https://github.com/apache/kafka/pull/19679
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
adixitconfluent closed pull request #19682: MINOR: Fix unchecked warnings in
gradle build
URL: https://github.com/apache/kafka/pull/19682
--
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
m1a2st commented on code in PR #19371:
URL: https://github.com/apache/kafka/pull/19371#discussion_r2084656210
##
streams/src/test/java/org/apache/kafka/streams/StreamsConfigTest.java:
##
@@ -248,7 +247,7 @@ public void
consumerConfigMustContainStreamPartitionAssignorConfig() {
chia7712 commented on code in PR #19651:
URL: https://github.com/apache/kafka/pull/19651#discussion_r2084667052
##
clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/consumer/SaslPlainPlaintextConsumerTest.java:
##
@@ -0,0 +1,155 @@
+/*
+ * Licensed to the
apoorvmittal10 commented on code in PR #19661:
URL: https://github.com/apache/kafka/pull/19661#discussion_r208408
##
clients/src/test/java/org/apache/kafka/common/record/MemoryRecordsTest.java:
##
@@ -149,10 +144,29 @@ public void testIterator(Args args) {
new S
[
https://issues.apache.org/jira/browse/KAFKA-17541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17950971#comment-17950971
]
Lan Ding commented on KAFKA-17541:
--
Hi [~schofielaj], maybe after
[KAFKA-19020|https:/
[
https://issues.apache.org/jira/browse/KAFKA-19259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17950972#comment-17950972
]
Lianet Magrans commented on KAFKA-19259:
Hey [~goyarpit], sure, go ahead. I don'
[
https://issues.apache.org/jira/browse/KAFKA-19267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17950978#comment-17950978
]
Ismael Juma commented on KAFKA-19267:
-
We should replace the hardcoded value with
`
dajac merged PR #19631:
URL: https://github.com/apache/kafka/pull/19631
--
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-19267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17950992#comment-17950992
]
Chia-Ping Tsai commented on KAFKA-19267:
{quote}
We should replace the hardcoded
[
https://issues.apache.org/jira/browse/KAFKA-19242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot resolved KAFKA-19242.
-
Fix Version/s: 3.9.2
4.0.1
4.1.0
Resolution: Fixed
dajac commented on PR #19631:
URL: https://github.com/apache/kafka/pull/19631#issuecomment-2872964388
Merged to trunk, 4.0 and 3.9.
--
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 co
dajac opened a new pull request, #19686:
URL: https://github.com/apache/kafka/pull/19686
This patch fixes the version used in the `4.0` branch. It should be `4.0.1`
instead of `4.1.0`.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log o
dajac merged PR #19497:
URL: https://github.com/apache/kafka/pull/19497
--
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-19160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot resolved KAFKA-19160.
-
Fix Version/s: 4.0.1
4.1.0
Resolution: Fixed
> Fetching stable offsets
[
https://issues.apache.org/jira/browse/KAFKA-19164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot resolved KAFKA-19164.
-
Fix Version/s: 4.0.1
4.1.0
Resolution: Fixed
> New group coordinator w
FrankYang0529 commented on code in PR #19523:
URL: https://github.com/apache/kafka/pull/19523#discussion_r2084021758
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/UtilsTest.java:
##
@@ -0,0 +1,201 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF
[
https://issues.apache.org/jira/browse/KAFKA-16394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-16394:
Priority: Minor (was: Major)
> ForeignKey LEFT join propagates null value on foreignKey c
[
https://issues.apache.org/jira/browse/KAFKA-19233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17951059#comment-17951059
]
Travis Bischel commented on KAFKA-19233:
I've released franz-go v1.19 opting out
rreddy-22 commented on code in PR #19539:
URL: https://github.com/apache/kafka/pull/19539#discussion_r2085600309
##
clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java:
##
@@ -1453,7 +1481,15 @@ public void handleResponse(AbstractResponse re
Ritika Reddy created KAFKA-19272:
Summary: Handling different scenarios for
initPid(keepPrepared=true)
Key: KAFKA-19272
URL: https://issues.apache.org/jira/browse/KAFKA-19272
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-19272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ritika Reddy updated KAFKA-19272:
-
Description:
When initPid(keepPrepared = true) is called when a client crashes, there are
quite
ahuang98 opened a new pull request, #19694:
URL: https://github.com/apache/kafka/pull/19694
Reviewers: Colin P. McCabe
```
Conflicts:
checkstyle/import-control.xml - different surrounding imports
clients/src/main/java/org/apache/kafka/common/requests/AlterUserScramCreden
ahuang98 opened a new pull request, #19693:
URL: https://github.com/apache/kafka/pull/19693
Reviewers: Colin P. McCabe
```
Conflicts:
checkstyle/import-control.xml - different surrounding imports
clients/src/main/java/org/apache/kafka/common/requests/AlterUserScramCreden
ahuang98 opened a new pull request, #19695:
URL: https://github.com/apache/kafka/pull/19695
Reviewers: Colin P. McCabe
```
Conflicts:
checkstyle/import-control.xml - different surrounding imports
clients/src/main/java/org/apache/kafka/common/requests/AlterUserScramCreden
[
https://issues.apache.org/jira/browse/KAFKA-19233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17951069#comment-17951069
]
Travis Bischel commented on KAFKA-19233:
I rewired the guts of the client to del
mjsax commented on code in PR #19691:
URL: https://github.com/apache/kafka/pull/19691#discussion_r2085659458
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/StreamsRebalanceData.java:
##
@@ -355,6 +357,9 @@ public Map subtopologies() {
return subtop
rreddy-22 commented on code in PR #19539:
URL: https://github.com/apache/kafka/pull/19539#discussion_r2085687333
##
clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java:
##
@@ -1904,5 +1933,15 @@ private PendingStateTransition(
}
ahuang98 opened a new pull request, #19692:
URL: https://github.com/apache/kafka/pull/19692
Reviewers: Colin P. McCabe
```
Conflicts:
clients/src/main/java/org/apache/kafka/common/requests/AlterUserScramCredentialsRequest.java
- import statement
clients/src/main/java/
ahuang98 opened a new pull request, #19696:
URL: https://github.com/apache/kafka/pull/19696
Reviewers: Colin P. McCabe
```
Conflicts:
checkstyle/import-control.xml - different surrounding imports
clients/src/main/java/org/apache/kafka/common/requests/AlterUserScramCreden
[
https://issues.apache.org/jira/browse/KAFKA-19233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17951065#comment-17951065
]
Lianet Magrans commented on KAFKA-19233:
Hey [~twmb] , sorry busy lately but cat
keemsisi commented on code in PR #19685:
URL: https://github.com/apache/kafka/pull/19685#discussion_r2085622584
##
clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/security/GroupAuthorizerIntegrationTest.java:
##
@@ -0,0 +1,464 @@
+/*
+ * Licensed to the
rreddy-22 commented on code in PR #19539:
URL: https://github.com/apache/kafka/pull/19539#discussion_r2085651776
##
clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java:
##
@@ -1904,5 +1933,15 @@ private PendingStateTransition(
}
apoorvmittal10 commented on code in PR #19666:
URL: https://github.com/apache/kafka/pull/19666#discussion_r2085658297
##
core/src/main/java/kafka/server/share/SharePartitionCache.java:
##
@@ -0,0 +1,87 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
apoorvmittal10 commented on code in PR #19666:
URL: https://github.com/apache/kafka/pull/19666#discussion_r2085658136
##
core/src/main/java/kafka/server/share/SharePartitionCache.java:
##
@@ -0,0 +1,87 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
apoorvmittal10 commented on code in PR #19666:
URL: https://github.com/apache/kafka/pull/19666#discussion_r2085659033
##
core/src/main/java/kafka/server/share/SharePartitionCache.java:
##
@@ -0,0 +1,87 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
m1a2st commented on code in PR #19678:
URL: https://github.com/apache/kafka/pull/19678#discussion_r2085742892
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/assignor/RangeSetTest.java:
##
@@ -32,16 +32,30 @@
public class RangeSetTest {
+@Test
+
chia7712 commented on code in PR #19630:
URL: https://github.com/apache/kafka/pull/19630#discussion_r2085105937
##
core/src/main/scala/kafka/server/RemoteLeaderEndPoint.scala:
##
@@ -154,40 +157,40 @@ class RemoteLeaderEndPoint(logPrefix: String,
val tp = new TopicPar
kevin-wu24 commented on code in PR #19668:
URL: https://github.com/apache/kafka/pull/19668#discussion_r2085111709
##
raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java:
##
@@ -2771,16 +2776,17 @@ private RequestSendResult maybeSendRequest(
Supplier requestSup
junrao commented on code in PR #19635:
URL: https://github.com/apache/kafka/pull/19635#discussion_r2085112789
##
core/src/test/scala/integration/kafka/api/AuthorizerIntegrationTest.scala:
##
@@ -923,8 +925,56 @@ class AuthorizerIntegrationTest extends
AbstractAuthorizerIntegrat
jsancio commented on code in PR #19668:
URL: https://github.com/apache/kafka/pull/19668#discussion_r2085093925
##
raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java:
##
@@ -2771,16 +2776,17 @@ private RequestSendResult maybeSendRequest(
Supplier requestSuppli
squah-confluent commented on code in PR #19678:
URL: https://github.com/apache/kafka/pull/19678#discussion_r2085134123
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/RangeSet.java:
##
@@ -44,6 +44,7 @@ public RangeSet(int from, int to) {
@O
squah-confluent commented on code in PR #19678:
URL: https://github.com/apache/kafka/pull/19678#discussion_r2085132731
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/RangeSet.java:
##
@@ -44,6 +44,7 @@ public RangeSet(int from, int to) {
@O
mjsax commented on code in PR #19580:
URL: https://github.com/apache/kafka/pull/19580#discussion_r2085135474
##
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKTableJoinProcessor.java:
##
@@ -150,7 +150,7 @@ private boolean maybeDropRecord(final Record r
squah-confluent commented on code in PR #19678:
URL: https://github.com/apache/kafka/pull/19678#discussion_r2085136665
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/RangeSet.java:
##
@@ -176,8 +178,18 @@ public boolean equals(Object o) {
@
mjsax commented on code in PR #19580:
URL: https://github.com/apache/kafka/pull/19580#discussion_r2085137272
##
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamKTableLeftJoinTest.java:
##
@@ -45,7 +47,13 @@
import java.util.Random;
import java.util.Set;
dajac commented on code in PR #19515:
URL: https://github.com/apache/kafka/pull/19515#discussion_r2085294443
##
clients/src/main/java/org/apache/kafka/common/requests/OffsetFetchRequest.java:
##
@@ -52,13 +54,37 @@ public static class Builder extends
AbstractRequest.Builder
bbejeck opened a new pull request, #19691:
URL: https://github.com/apache/kafka/pull/19691
This PR adds changes, so the IQ endpoint information is only sent to streams
group members when there has been a change in the assignments requiring an
update in the streams client host-partition owne
[
https://issues.apache.org/jira/browse/KAFKA-13447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot reassigned KAFKA-13447:
---
Assignee: David Jacot (was: Philip Nee)
> Consumer should not reuse committed offset after
FrankYang0529 opened a new pull request, #19699:
URL: https://github.com/apache/kafka/pull/19699
1. Move TransactionMetadata to transaction-coordinator module.
2. Rewrite TransactionMetadata in Java.
--
This is an automated message from the Apache Git Service.
To respond to the message,
xijiu opened a new pull request, #19698:
URL: https://github.com/apache/kafka/pull/19698
Do not print the `"Unexpected error .."` log when the config
`delete.topic.enable` is false
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Git
[
https://issues.apache.org/jira/browse/KAFKA-13192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai resolved KAFKA-13192.
Resolution: Won't Fix
see KAFKA-13224
> broker.id and node.id can be specified inconsiste
[
https://issues.apache.org/jira/browse/KAFKA-13224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai resolved KAFKA-13224.
Fix Version/s: 3.1.0
Assignee: Colin McCabe (was: Ron Dagostino)
Resolutio
1 - 100 of 142 matches
Mail list logo
