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 wit
[
https://issues.apache.org/jira/browse/KAFKA-15493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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&focusedCommentId=17769856#comment-17769856
]
Said BOUDJELDA commented on KAFKA-15493:
{code:java}
➜ kafka git:(trunk) java -
[
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 of
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,
l
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) {
publ
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,
RemoteLogSegmentM
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 ClusterImage
[
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
co
[
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
co
[
https://issues.apache.org/jira/browse/KAFKA-13882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17769780#comment-17769780
]
ASF GitHub Bot commented on KAFKA-13882:
tombentley commented on PR #410:
URL: h
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 F
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 org.apache.kafka.clients
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
Issu
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 Software
[
https://issues.apache.org/jira/browse/KAFKA-13882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17769769#comment-17769769
]
ASF GitHub Bot commented on KAFKA-13882:
tombentley merged PR #410:
URL: https:/
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 talk
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&focusedCommentId=17769732#comment-17769732
]
ASF GitHub Bot commented on KAFKA-13882:
qingwei91 commented on PR #410:
URL: ht
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 me
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&focusedCommentId=17769707#comment-17769707
]
Steve Jacobs commented on KAFKA-15467:
--
Rolling back to MirrorMaker2 3.4.1 to see i
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 retu
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&focusedCommentId=17068519#comment-17068519
]
Jordan Moore edited comment on KAFKA-9774 at 9/27/23 4:36 PM:
-
[ 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 offi
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 throwIfConsumerGroupHeartbeatR
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 u
[
https://issues.apache.org/jira/browse/KAFKA-15445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17769698#comment-17769698
]
Jordan Moore commented on KAFKA-15445:
--
Adding backlink to KAFKA-9774
> KIP-975: D
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 throwIfConsumerGroupHeartbeatR
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 constan
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 throwIfConsumerGroupHeartbeatReque
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
matchingTopic(FetchResponseData.Fetchable
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: jira-unsubscr...@kafka.apache.
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 auto
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&focusedCommentId=17769667#comment-17769667
]
Colt McNealy commented on KAFKA-15448:
--
We have a draft implementation internally,
[
https://issues.apache.org/jira/browse/KAFKA-15513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17769662#comment-17769662
]
Proven Provenzano commented on KAFKA-15513:
---
Thank you for the detailed bug re
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 unsubscribe,
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: Sub-task
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 ass
[
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)
> Broke
[
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 ma
[
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,
RemoteLogSegmentMet
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,
RemoteLogSegmentMet
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,
RemoteLogSegmentMe
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 @chern
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 = {
brokerTopicS
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
).load
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 = {
brokerTopicS
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,
RemoteLogSegmentMet
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 KI
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 comm
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: jira-unsubscr...@kafka.apache.
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 co
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&focusedCommentId=17769537#comment-17769537
]
Aleksandra Drobnjak commented on KAFKA-15512:
-
Thanks [~divijvaidya] !
> EO
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 control-pla
[
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 control-pla
[
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&focusedCommentId=17769529#comment-17769529
]
Divij Vaidya commented on KAFKA-15512:
--
Zk has been upgraded to 3.8.2 in upcoming K
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&focusedCommentId=17769525#comment-17769525
]
Arpit Goyal commented on KAFKA-15511:
-
[~divijvaidya] Can you review this
https://g
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.*
*Summary
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: Ta
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) {
*/
v
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&focusedCommentId=17769491#comment-17769491
]
ASF GitHub Bot commented on KAFKA-13882:
mimaison commented on PR #410:
URL: htt
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 throwIfConsumerGroupHeartbeatR
1 - 100 of 117 matches
Mail list logo
