chernyih commented on PR #14457:
URL: https://github.com/apache/kafka/pull/14457#issuecomment-1738421193
The test failures do not look related. I compared with a few recent merged
commit tests. For the failed tests that are not found in the recent commit
tests, i ran those tests locally
[
https://issues.apache.org/jira/browse/KAFKA-15493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17769856#comment-17769856
]
Said BOUDJELDA edited comment on KAFKA-15493 at 9/28/23 12:20 AM:
--
[
https://issues.apache.org/jira/browse/KAFKA-15493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17769856#comment-17769856
]
Said BOUDJELDA commented on KAFKA-15493:
{code:java}
➜ kafka git:(trunk) java -version
openjdk
[
https://issues.apache.org/jira/browse/KAFKA-15493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Said BOUDJELDA updated KAFKA-15493:
---
Attachment: image-2023-09-28-02-12-33-807.png
> Ensure system tests work with Java 21
>
[
https://issues.apache.org/jira/browse/KAFKA-15493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Said BOUDJELDA updated KAFKA-15493:
---
Attachment: image-2023-09-28-02-11-49-196.png
> Ensure system tests work with Java 21
>
Chad Preisler created KAFKA-15516:
-
Summary: Provide kafka-client library as a proper java Jigsaw
module
Key: KAFKA-15516
URL: https://issues.apache.org/jira/browse/KAFKA-15516
Project: Kafka
CalvinConfluent opened a new pull request, #14465:
URL: https://github.com/apache/kafka/pull/14465
*More detailed description of your change,
if necessary. The PR title and PR message become
the squashed commit message, so use a separate
comment to ping reviewers.*
*Summary
jeffkbkim commented on code in PR #14408:
URL: https://github.com/apache/kafka/pull/14408#discussion_r1339019021
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/Group.java:
##
@@ -90,4 +92,29 @@ void validateOffsetFetch(
int memberEpoch,
ahuang98 commented on code in PR #14206:
URL: https://github.com/apache/kafka/pull/14206#discussion_r1339228692
##
metadata/src/test/java/org/apache/kafka/image/TopicsImageTest.java:
##
@@ -176,22 +200,30 @@ private PartitionRegistration newPartition(int[]
replicas) {
ahuang98 commented on code in PR #14206:
URL: https://github.com/apache/kafka/pull/14206#discussion_r1339229757
##
metadata/src/test/java/org/apache/kafka/image/ProducerIdsImageTest.java:
##
@@ -54,11 +54,24 @@ public class ProducerIdsImageTest {
setBrokerId(3).
ahuang98 commented on code in PR #14206:
URL: https://github.com/apache/kafka/pull/14206#discussion_r1339224472
##
metadata/src/test/java/org/apache/kafka/image/FeaturesImageTest.java:
##
@@ -96,6 +121,20 @@ public void testImage2RoundTrip() {
testToImage(IMAGE2);
divijvaidya commented on code in PR #14459:
URL: https://github.com/apache/kafka/pull/14459#discussion_r1339202068
##
storage/src/main/java/org/apache/kafka/storage/internals/log/RemoteIndexCache.java:
##
@@ -310,7 +310,7 @@ private T loadIndexFile(File file,
rondagostino commented on code in PR #14206:
URL: https://github.com/apache/kafka/pull/14206#discussion_r1338985779
##
metadata/src/test/java/org/apache/kafka/image/ClusterImageTest.java:
##
@@ -102,14 +115,18 @@ public class ClusterImageTest {
IMAGE1 = new
[
https://issues.apache.org/jira/browse/KAFKA-15327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans updated KAFKA-15327:
---
Description:
In the current implementation of the KafkaConsumer, the ConsumerCoordinator
[
https://issues.apache.org/jira/browse/KAFKA-15327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans updated KAFKA-15327:
---
Description:
In the current implementation of the KafkaConsumer, the ConsumerCoordinator
[
https://issues.apache.org/jira/browse/KAFKA-13882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17769780#comment-17769780
]
ASF GitHub Bot commented on KAFKA-13882:
tombentley commented on PR #410:
URL:
philipnee commented on code in PR #14406:
URL: https://github.com/apache/kafka/pull/14406#discussion_r1339158811
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/BackgroundEventHandler.java:
##
@@ -0,0 +1,52 @@
+/*
+ * Licensed to the Apache Software
philipnee commented on code in PR #14406:
URL: https://github.com/apache/kafka/pull/14406#discussion_r1339158103
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/ApplicationEventProcessor.java:
##
@@ -17,146 +17,195 @@
package
Lianet Magrans created KAFKA-15515:
--
Summary: Remove duplicated integration tests for new consumer
Key: KAFKA-15515
URL: https://issues.apache.org/jira/browse/KAFKA-15515
Project: Kafka
philipnee commented on code in PR #14406:
URL: https://github.com/apache/kafka/pull/14406#discussion_r1339157715
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/ApplicationEventHandler.java:
##
@@ -0,0 +1,122 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/KAFKA-13882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17769769#comment-17769769
]
ASF GitHub Bot commented on KAFKA-13882:
tombentley merged PR #410:
URL:
antonagestam commented on PR #14447:
URL: https://github.com/apache/kafka/pull/14447#issuecomment-1737955955
@kirktrue Related to that, I think it'd make sense to enforce this as well:
https://github.com/apache/kafka/pull/13680, as it allows slightly less parser
complexity. Since we're
antonagestam commented on PR #14447:
URL: https://github.com/apache/kafka/pull/14447#issuecomment-1737946051
@kirktrue [I was pondering that as
well](https://github.com/apache/kafka/pull/14124#discussion_r1336283242). It
seems attractive because it's certainly possible to automate, however
[
https://issues.apache.org/jira/browse/KAFKA-13882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17769732#comment-17769732
]
ASF GitHub Bot commented on KAFKA-13882:
qingwei91 commented on PR #410:
URL:
philipnee commented on code in PR #14406:
URL: https://github.com/apache/kafka/pull/14406#discussion_r1338973379
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractFetch.java:
##
@@ -330,7 +343,7 @@ private Map
prepareCloseFetchSession
philipnee commented on code in PR #14406:
URL: https://github.com/apache/kafka/pull/14406#discussion_r1338972414
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractFetch.java:
##
@@ -92,6 +88,23 @@ public AbstractFetch(final LogContext logContext,
nizhikov commented on PR #14456:
URL: https://github.com/apache/kafka/pull/14456#issuecomment-1737779240
Hello, @showuon
This PR is part of #13247
This is last test of `ReassignPartitionCommand` in scala.
If you have some time, please, join the review.
--
This is an automated
nizhikov commented on PR #13247:
URL: https://github.com/apache/kafka/pull/13247#issuecomment-173703
@mimaison Tests in #14456 are OK. If you have some time, please, join the
review.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
[
https://issues.apache.org/jira/browse/KAFKA-15467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17769707#comment-17769707
]
Steve Jacobs commented on KAFKA-15467:
--
Rolling back to MirrorMaker2 3.4.1 to see if that fixes the
chernyih commented on PR #14457:
URL: https://github.com/apache/kafka/pull/14457#issuecomment-1737747214
@rajinisivaram @divijvaidya @viktorsomogyi Thank you for the review. After
reading the comments and thinking more about it, it won't impact truncation of
fetch since if a leader has
chernyih commented on code in PR #14457:
URL: https://github.com/apache/kafka/pull/14457#discussion_r1338903942
##
core/src/main/scala/kafka/server/AbstractFetcherThread.scala:
##
@@ -364,10 +364,11 @@ abstract class AbstractFetcherThread(name: String,
[
https://issues.apache.org/jira/browse/KAFKA-9774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17068519#comment-17068519
]
Jordan Moore edited comment on KAFKA-9774 at 9/27/23 4:36 PM:
--
Happy to take
[ https://issues.apache.org/jira/browse/KAFKA-9774 ]
Jordan Moore deleted comment on KAFKA-9774:
-
was (Author: cricket007):
Done here
https://github.com/OneCricketeer/apache-kafka-connect-docker#containerized-apache-kafka-connect
> Create
vamossagar12 commented on code in PR #14432:
URL: https://github.com/apache/kafka/pull/14432#discussion_r1338900198
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java:
##
@@ -593,6 +609,9 @@ private void
mimaison opened a new pull request, #14464:
URL: https://github.com/apache/kafka/pull/14464
We bumped the `swagger-gradle-plugin` version in
https://github.com/apache/kafka/commit/d1ad1d7b7013ea2c24a3f71c485a2a914adf1348
This breaks the `genConnectOpenAPIDocs` task:
```
> Task
vamossagar12 commented on PR #14432:
URL: https://github.com/apache/kafka/pull/14432#issuecomment-1737732772
Thanks for the review @kirktrue ! I have addressed the changes.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
[
https://issues.apache.org/jira/browse/KAFKA-15445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17769698#comment-17769698
]
Jordan Moore commented on KAFKA-15445:
--
Adding backlink to KAFKA-9774
> KIP-975: Docker Image for
vamossagar12 commented on code in PR #14432:
URL: https://github.com/apache/kafka/pull/14432#discussion_r1338895795
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java:
##
@@ -593,6 +609,9 @@ private void
kirktrue opened a new pull request, #14463:
URL: https://github.com/apache/kafka/pull/14463
Replacing the use a hardcoded -1 with a constant (`LEAVE_GROUP_EPOCH`) that
provides more clarity. Since static members also have a magic number (-2), this
will motivate future commits to use
kirktrue commented on code in PR #14432:
URL: https://github.com/apache/kafka/pull/14432#discussion_r1338844884
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java:
##
@@ -593,6 +609,9 @@ private void
kirktrue commented on code in PR #1:
URL: https://github.com/apache/kafka/pull/1#discussion_r1338814653
##
clients/src/main/java/org/apache/kafka/common/requests/FetchResponse.java:
##
@@ -254,8 +265,10 @@ private static boolean
cadonna merged PR #14442:
URL: https://github.com/apache/kafka/pull/14442
--
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:
cadonna commented on PR #14442:
URL: https://github.com/apache/kafka/pull/14442#issuecomment-1737665889
Build 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 specific
kirktrue commented on PR #14447:
URL: https://github.com/apache/kafka/pull/14447#issuecomment-1737649876
Thanks for the PR @antonagestam!
Does it make sense (or is it even possible) to write a test case that
verifies the correctness of this change?
Thanks!
--
This is an
kirktrue commented on code in PR #14455:
URL: https://github.com/apache/kafka/pull/14455#discussion_r1338802690
##
clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java:
##
@@ -1546,9 +1546,9 @@ void enqueue(Call call, long now) {
*/
void
[
https://issues.apache.org/jira/browse/KAFKA-15448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17769667#comment-17769667
]
Colt McNealy commented on KAFKA-15448:
--
We have a draft implementation internally, and we will
[
https://issues.apache.org/jira/browse/KAFKA-15513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17769662#comment-17769662
]
Proven Provenzano commented on KAFKA-15513:
---
Thank you for the detailed bug report.
I can
dongnuo123 opened a new pull request, #14462:
URL: https://github.com/apache/kafka/pull/14462
This PR implements DescribeGroups API according to the implementation in the
old GroupCoordinator with the new model.
### JIRA
https://issues.apache.org/jira/browse/KAFKA-14504
###
vamossagar12 opened a new pull request, #14461:
URL: https://github.com/apache/kafka/pull/14461
(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
Igor Soarez created KAFKA-15514:
---
Summary: Controller-side replica management changes
Key: KAFKA-15514
URL: https://issues.apache.org/jira/browse/KAFKA-15514
Project: Kafka
Issue Type:
viktorsomogyi commented on PR #14457:
URL: https://github.com/apache/kafka/pull/14457#issuecomment-1737371455
I also looked at how this `lastFetchedEpoch` is used in the next fetch but I
don't think either it'd trigger truncation. Let's wait for @chernyih 's
response. Since this is a small
[
https://issues.apache.org/jira/browse/KAFKA-15365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Igor Soarez updated KAFKA-15365:
Description:
On the broker side,
* Replica placement (i.e. selection of a log dir) generates
[
https://issues.apache.org/jira/browse/KAFKA-15365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Igor Soarez updated KAFKA-15365:
Summary: Broker-side replica management changes (was: Broker replica
management changes)
>
[
https://issues.apache.org/jira/browse/KAFKA-15365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Igor Soarez updated KAFKA-15365:
Summary: Broker replica management changes (was: Replica management
changes)
> Broker replica
[
https://issues.apache.org/jira/browse/KAFKA-15489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen updated KAFKA-15489:
--
Fix Version/s: (was: 3.6.0)
> split brain in KRaft cluster
> -
>
>
[
https://issues.apache.org/jira/browse/KAFKA-15489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen reopened KAFKA-15489:
---
> split brain in KRaft cluster
> -
>
> Key: KAFKA-15489
>
satishd commented on code in PR #14459:
URL: https://github.com/apache/kafka/pull/14459#discussion_r1338553597
##
core/src/test/scala/unit/kafka/log/remote/RemoteIndexCacheTest.scala:
##
@@ -598,4 +615,11 @@ class RemoteIndexCacheTest {
timeIndex.flush()
}
}
+
+
satishd commented on code in PR #14459:
URL: https://github.com/apache/kafka/pull/14459#discussion_r1338550163
##
core/src/test/scala/unit/kafka/log/remote/RemoteIndexCacheTest.scala:
##
@@ -598,4 +615,11 @@ class RemoteIndexCacheTest {
timeIndex.flush()
}
}
+
+
satishd commented on code in PR #14459:
URL: https://github.com/apache/kafka/pull/14459#discussion_r1338550163
##
core/src/test/scala/unit/kafka/log/remote/RemoteIndexCacheTest.scala:
##
@@ -598,4 +615,11 @@ class RemoteIndexCacheTest {
timeIndex.flush()
}
}
+
+
cadonna commented on code in PR #14442:
URL: https://github.com/apache/kafka/pull/14442#discussion_r1338525255
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java:
##
@@ -1226,7 +1226,9 @@ private void releaseLockedUnassignedTaskDirectories()
Hangleton commented on code in PR #14459:
URL: https://github.com/apache/kafka/pull/14459#discussion_r1338522387
##
storage/src/main/java/org/apache/kafka/storage/internals/log/RemoteIndexCache.java:
##
@@ -310,7 +310,7 @@ private T loadIndexFile(File file,
Hangleton commented on code in PR #14459:
URL: https://github.com/apache/kafka/pull/14459#discussion_r1338522387
##
storage/src/main/java/org/apache/kafka/storage/internals/log/RemoteIndexCache.java:
##
@@ -310,7 +310,7 @@ private T loadIndexFile(File file,
iit2009060 commented on code in PR #14459:
URL: https://github.com/apache/kafka/pull/14459#discussion_r1338517254
##
core/src/test/scala/unit/kafka/log/remote/RemoteIndexCacheTest.scala:
##
@@ -598,4 +615,11 @@ class RemoteIndexCacheTest {
timeIndex.flush()
}
}
+
iit2009060 commented on code in PR #14459:
URL: https://github.com/apache/kafka/pull/14459#discussion_r1338513994
##
storage/src/main/java/org/apache/kafka/storage/internals/log/RemoteIndexCache.java:
##
@@ -310,7 +310,7 @@ private T loadIndexFile(File file,
divijvaidya commented on PR #14457:
URL: https://github.com/apache/kafka/pull/14457#issuecomment-1737266545
> In any case, I think it makes sense to maintain the correct value for
lastFetchedEpoch to avoid relying on timing assumptions that may not hold in
future.
Totally agree. The
divijvaidya commented on code in PR #14459:
URL: https://github.com/apache/kafka/pull/14459#discussion_r1338502969
##
core/src/test/scala/unit/kafka/log/remote/RemoteIndexCacheTest.scala:
##
@@ -598,4 +615,11 @@ class RemoteIndexCacheTest {
timeIndex.flush()
}
}
iit2009060 commented on code in PR #14459:
URL: https://github.com/apache/kafka/pull/14459#discussion_r1338498452
##
core/src/test/scala/unit/kafka/log/remote/RemoteIndexCacheTest.scala:
##
@@ -598,4 +615,11 @@ class RemoteIndexCacheTest {
timeIndex.flush()
}
}
+
lucasbru commented on code in PR #14442:
URL: https://github.com/apache/kafka/pull/14442#discussion_r1338490846
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java:
##
@@ -1226,7 +1226,9 @@ private void releaseLockedUnassignedTaskDirectories()
rajinisivaram commented on PR #14457:
URL: https://github.com/apache/kafka/pull/14457#issuecomment-1737243300
I couldn't think of a case where we might hit an actual truncation issue
since divergence should have been detected in the first request after leader
change, so will wait for
tinaselenge commented on code in PR #14453:
URL: https://github.com/apache/kafka/pull/14453#discussion_r1338486017
##
core/src/test/scala/unit/kafka/log/UnifiedLogTest.scala:
##
@@ -71,6 +72,13 @@ class UnifiedLogTest {
@AfterEach
def tearDown(): Unit = {
tinaselenge commented on code in PR #14453:
URL: https://github.com/apache/kafka/pull/14453#discussion_r1338486393
##
core/src/test/scala/unit/kafka/log/LogLoaderTest.scala:
##
@@ -1800,5 +1822,6 @@ class LogLoaderTest {
isRemoteLogEnabled = isRemoteLogEnabled
tinaselenge commented on code in PR #14453:
URL: https://github.com/apache/kafka/pull/14453#discussion_r1338486017
##
core/src/test/scala/unit/kafka/log/UnifiedLogTest.scala:
##
@@ -71,6 +72,13 @@ class UnifiedLogTest {
@AfterEach
def tearDown(): Unit = {
Hangleton commented on code in PR #14459:
URL: https://github.com/apache/kafka/pull/14459#discussion_r1338467462
##
storage/src/main/java/org/apache/kafka/storage/internals/log/RemoteIndexCache.java:
##
@@ -310,7 +310,7 @@ private T loadIndexFile(File file,
divijvaidya commented on code in PR #14459:
URL: https://github.com/apache/kafka/pull/14459#discussion_r1338463195
##
core/src/test/scala/unit/kafka/log/remote/RemoteIndexCacheTest.scala:
##
@@ -598,4 +615,11 @@ class RemoteIndexCacheTest {
timeIndex.flush()
}
}
iit2009060 commented on code in PR #14459:
URL: https://github.com/apache/kafka/pull/14459#discussion_r1338421535
##
core/src/test/scala/unit/kafka/log/remote/RemoteIndexCacheTest.scala:
##
@@ -598,4 +615,11 @@ class RemoteIndexCacheTest {
timeIndex.flush()
}
}
+
raboof opened a new pull request, #14460:
URL: https://github.com/apache/kafka/pull/14460
Like in most projects, this attack cannot be achieved by an external
attacker in Kafka.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ]
[
https://issues.apache.org/jira/browse/KAFKA-15177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yash Mayya resolved KAFKA-15177.
Fix Version/s: 3.6.0
Resolution: Fixed
> MirrorMaker 2 should implement the alterOffsets
cadonna commented on code in PR #14442:
URL: https://github.com/apache/kafka/pull/14442#discussion_r1338448792
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java:
##
@@ -1226,7 +1226,9 @@ private void releaseLockedUnassignedTaskDirectories()
cadonna commented on code in PR #14442:
URL: https://github.com/apache/kafka/pull/14442#discussion_r1338448490
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java:
##
@@ -1226,7 +1226,9 @@ private void releaseLockedUnassignedTaskDirectories()
showuon commented on PR #14434:
URL: https://github.com/apache/kafka/pull/14434#issuecomment-1737176802
Backported to 3.6 branch.
--
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
showuon merged PR #14434:
URL: https://github.com/apache/kafka/pull/14434
--
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:
showuon commented on PR #14434:
URL: https://github.com/apache/kafka/pull/14434#issuecomment-1737170863
Failed tests 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 specific
showuon commented on code in PR #14434:
URL: https://github.com/apache/kafka/pull/14434#discussion_r1338431502
##
core/src/test/scala/integration/kafka/api/ProducerCompressionTest.scala:
##
@@ -103,12 +123,37 @@ class ProducerCompressionTest extends QuorumTestHarness {
[
https://issues.apache.org/jira/browse/KAFKA-15512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17769537#comment-17769537
]
Aleksandra Drobnjak commented on KAFKA-15512:
-
Thanks [~divijvaidya] !
> EOL zookeeper
iit2009060 commented on code in PR #14459:
URL: https://github.com/apache/kafka/pull/14459#discussion_r1338421761
##
core/src/test/scala/unit/kafka/log/remote/RemoteIndexCacheTest.scala:
##
@@ -598,4 +615,11 @@ class RemoteIndexCacheTest {
timeIndex.flush()
}
}
+
[
https://issues.apache.org/jira/browse/KAFKA-15513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya updated KAFKA-15513:
-
Affects Version/s: 3.6.0
> KRaft cluster fails with SCRAM authentication enabled for
[
https://issues.apache.org/jira/browse/KAFKA-15513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya updated KAFKA-15513:
-
Affects Version/s: 3.5.1
> KRaft cluster fails with SCRAM authentication enabled for
[
https://issues.apache.org/jira/browse/KAFKA-15513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya updated KAFKA-15513:
-
Component/s: kraft
> KRaft cluster fails with SCRAM authentication enabled for control-plane
>
[
https://issues.apache.org/jira/browse/KAFKA-15512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17769529#comment-17769529
]
Divij Vaidya commented on KAFKA-15512:
--
Zk has been upgraded to 3.8.2 in upcoming Kafka release
migruiz4 created KAFKA-15513:
Summary: KRaft cluster fails with SCRAM authentication enabled for
control-plane
Key: KAFKA-15513
URL: https://issues.apache.org/jira/browse/KAFKA-15513
Project: Kafka
divijvaidya commented on code in PR #14459:
URL: https://github.com/apache/kafka/pull/14459#discussion_r1338397666
##
core/src/test/scala/unit/kafka/log/remote/RemoteIndexCacheTest.scala:
##
@@ -598,4 +615,11 @@ class RemoteIndexCacheTest {
timeIndex.flush()
}
}
[
https://issues.apache.org/jira/browse/KAFKA-15511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17769525#comment-17769525
]
Arpit Goyal commented on KAFKA-15511:
-
[~divijvaidya] Can you review this
iit2009060 opened a new pull request, #14459:
URL: https://github.com/apache/kafka/pull/14459
*More detailed description of your change,
if necessary. The PR title and PR message become
the squashed commit message, so use a separate
comment to ping reviewers.*
lucasbru commented on code in PR #14442:
URL: https://github.com/apache/kafka/pull/14442#discussion_r1338367481
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java:
##
@@ -1226,7 +1226,9 @@ private void releaseLockedUnassignedTaskDirectories()
Aleksandra Drobnjak created KAFKA-15512:
---
Summary: EOL zookeeper component in kafka
Key: KAFKA-15512
URL: https://issues.apache.org/jira/browse/KAFKA-15512
Project: Kafka
Issue Type:
divijvaidya commented on code in PR #14457:
URL: https://github.com/apache/kafka/pull/14457#discussion_r1338310531
##
core/src/main/scala/kafka/server/AbstractFetcherThread.scala:
##
@@ -364,10 +364,11 @@ abstract class AbstractFetcherThread(name: String,
vamossagar12 commented on code in PR #14455:
URL: https://github.com/apache/kafka/pull/14455#discussion_r1338305899
##
clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java:
##
@@ -1546,9 +1546,9 @@ void enqueue(Call call, long now) {
*/
hudeqi commented on PR #13930:
URL: https://github.com/apache/kafka/pull/13930#issuecomment-1737000786
@showuon Hi, Could you help to review this PR?
--
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
[
https://issues.apache.org/jira/browse/KAFKA-13882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17769491#comment-17769491
]
ASF GitHub Bot commented on KAFKA-13882:
mimaison commented on PR #410:
URL:
vamossagar12 commented on code in PR #14432:
URL: https://github.com/apache/kafka/pull/14432#discussion_r1338285360
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java:
##
@@ -593,6 +609,9 @@ private void
1 - 100 of 122 matches
Mail list logo
