dajac commented on code in PR #14182:
URL: https://github.com/apache/kafka/pull/14182#discussion_r1326872198
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/AbstractUniformAssignmentBuilder.java:
##
@@ -0,0 +1,227 @@
+/*
+ * Licensed to the Apache
dajac commented on code in PR #14182:
URL: https://github.com/apache/kafka/pull/14182#discussion_r1326871177
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/OptimizedUniformAssignmentBuilder.java:
##
@@ -0,0 +1,413 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/KAFKA-14503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot resolved KAFKA-14503.
-
Fix Version/s: 3.7.0
Reviewer: David Jacot
Resolution: Fixed
> Implement ListGro
dajac merged PR #14271:
URL: https://github.com/apache/kafka/pull/14271
--
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
rreddy-22 commented on code in PR #14182:
URL: https://github.com/apache/kafka/pull/14182#discussion_r1326838235
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/OptimizedUniformAssignmentBuilder.java:
##
@@ -0,0 +1,413 @@
+/*
+ * Licensed to the Ap
dengziming commented on PR #14272:
URL: https://github.com/apache/kafka/pull/14272#issuecomment-1720724302
@cmccabe Yes, `metadataCache.getPartitionReplicaEndpoints` is only used when
handling `FetchRequest`.
--
This is an automated message from the Apache Git Service.
To respond to the m
rreddy-22 commented on code in PR #14182:
URL: https://github.com/apache/kafka/pull/14182#discussion_r1326826466
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/OptimizedUniformAssignmentBuilder.java:
##
@@ -0,0 +1,413 @@
+/*
+ * Licensed to the Ap
rreddy-22 commented on code in PR #14182:
URL: https://github.com/apache/kafka/pull/14182#discussion_r1326819932
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/OptimizedUniformAssignmentBuilder.java:
##
@@ -0,0 +1,413 @@
+/*
+ * Licensed to the Ap
rreddy-22 commented on code in PR #14182:
URL: https://github.com/apache/kafka/pull/14182#discussion_r1326818424
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/AbstractUniformAssignmentBuilder.java:
##
@@ -0,0 +1,227 @@
+/*
+ * Licensed to the Apa
rreddy-22 commented on code in PR #14182:
URL: https://github.com/apache/kafka/pull/14182#discussion_r1326817433
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/AbstractUniformAssignmentBuilder.java:
##
@@ -0,0 +1,227 @@
+/*
+ * Licensed to the Apa
rreddy-22 commented on code in PR #14182:
URL: https://github.com/apache/kafka/pull/14182#discussion_r1326815225
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/assignor/OptimizedUniformAssignmentBuilderTest.java:
##
@@ -0,0 +1,1090 @@
+/*
+ * Licensed to t
drawxy commented on code in PR #13847:
URL: https://github.com/apache/kafka/pull/13847#discussion_r1326808988
##
core/src/main/scala/kafka/server/ReplicaManager.scala:
##
@@ -1808,7 +1809,10 @@ class ReplicaManager(val config: KafkaConfig,
// pause cleaning for part
cmccabe commented on PR #14272:
URL: https://github.com/apache/kafka/pull/14272#issuecomment-1720696964
Thanks for the PR, @dengziming . If I understand correctly, the problem with
returning a fenced broker from `metadataCache.getPartitionReplicaEndpoints` is
that it will then be used as th
philipnee commented on code in PR #14386:
URL: https://github.com/apache/kafka/pull/14386#discussion_r1326800659
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/TopicMetadataRequestManager.java:
##
@@ -0,0 +1,215 @@
+/*
+ * Licensed to the Apache Software Fo
github-actions[bot] commented on PR #13796:
URL: https://github.com/apache/kafka/pull/13796#issuecomment-1720434737
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 #13824:
URL: https://github.com/apache/kafka/pull/13824#issuecomment-1720434714
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-15466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17765426#comment-17765426
]
Deng Ziming commented on KAFKA-15466:
-
We can split this to some separate tickets fo
[
https://issues.apache.org/jira/browse/KAFKA-7739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17765414#comment-17765414
]
Luke Chen commented on KAFKA-7739:
--
This epic is created on Dec. 14, 2018 and is finally
jolshan commented on code in PR #14370:
URL: https://github.com/apache/kafka/pull/14370#discussion_r1326648363
##
clients/src/main/java/org/apache/kafka/common/requests/TxnOffsetCommitResponse.java:
##
@@ -47,6 +47,9 @@
* - {@link Errors#UNKNOWN_MEMBER_ID}
* - {@link Err
junrao commented on code in PR #14386:
URL: https://github.com/apache/kafka/pull/14386#discussion_r1326612426
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/TopicMetadataRequestManager.java:
##
@@ -0,0 +1,210 @@
+/*
+ * Licensed to the Apache Software Found
Justine Olshan created KAFKA-15468:
--
Summary: Prevent transaction coordinator reloads on already loaded
leaders
Key: KAFKA-15468
URL: https://issues.apache.org/jira/browse/KAFKA-15468
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-15468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Justine Olshan updated KAFKA-15468:
---
Description:
I was doing some research on txn coordinator loading and found that on a single
junrao commented on code in PR #14359:
URL: https://github.com/apache/kafka/pull/14359#discussion_r1326602940
##
clients/src/main/java/org/apache/kafka/common/internals/IdempotentCloser.java:
##
@@ -0,0 +1,127 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
CalvinConfluent commented on code in PR #14053:
URL: https://github.com/apache/kafka/pull/14053#discussion_r1326544485
##
core/src/main/scala/kafka/cluster/Replica.scala:
##
@@ -98,14 +103,22 @@ class Replica(val brokerId: Int, val topicPartition:
TopicPartition) extends Log
CalvinConfluent commented on code in PR #14053:
URL: https://github.com/apache/kafka/pull/14053#discussion_r1326544274
##
core/src/main/scala/kafka/cluster/Partition.scala:
##
@@ -137,7 +137,8 @@ object Partition {
delayedOperations = delayedOperations,
metadataCac
kirktrue commented on code in PR #14359:
URL: https://github.com/apache/kafka/pull/14359#discussion_r1326507379
##
clients/src/main/java/org/apache/kafka/common/internals/IdempotentCloser.java:
##
@@ -0,0 +1,127 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under o
kirktrue commented on code in PR #14359:
URL: https://github.com/apache/kafka/pull/14359#discussion_r1326506750
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/FetchBufferTest.java:
##
@@ -0,0 +1,193 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF
kirktrue commented on code in PR #14359:
URL: https://github.com/apache/kafka/pull/14359#discussion_r1326504874
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/CompletedFetchTest.java:
##
@@ -115,13 +122,17 @@ public void testCommittedTransactionRecordsInclu
kirktrue commented on code in PR #14359:
URL: https://github.com/apache/kafka/pull/14359#discussion_r1326504231
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractFetch.java:
##
@@ -421,14 +309,45 @@ Node selectReadReplica(final TopicPartition partition
lianetm commented on code in PR #14364:
URL: https://github.com/apache/kafka/pull/14364#discussion_r1326478655
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestManager.java:
##
@@ -0,0 +1,255 @@
+/*
+ * Licensed to the Apache Software Foundati
lianetm commented on code in PR #14364:
URL: https://github.com/apache/kafka/pull/14364#discussion_r1326463429
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestManager.java:
##
@@ -0,0 +1,255 @@
+/*
+ * Licensed to the Apache Software Foundati
lianetm commented on code in PR #14386:
URL: https://github.com/apache/kafka/pull/14386#discussion_r1326449328
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/TopicMetadataRequestManagerTest.java:
##
@@ -0,0 +1,235 @@
+/*
+ * Licensed to the Apache Software
lianetm commented on code in PR #14386:
URL: https://github.com/apache/kafka/pull/14386#discussion_r1326441512
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/TopicMetadataRequestManager.java:
##
@@ -0,0 +1,215 @@
+/*
+ * Licensed to the Apache Software Foun
lucasbru commented on code in PR #14226:
URL: https://github.com/apache/kafka/pull/14226#discussion_r1326423158
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/PartitionGroup.java:
##
@@ -370,11 +374,30 @@ void clear() {
nonEmptyQueuesByTime.clear(
lucasbru commented on code in PR #14226:
URL: https://github.com/apache/kafka/pull/14226#discussion_r1326421083
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java:
##
@@ -590,6 +590,30 @@ public void prepareRecycle() {
log.info("Closed
lucasbru commented on code in PR #14226:
URL: https://github.com/apache/kafka/pull/14226#discussion_r1326419704
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java:
##
@@ -590,6 +590,30 @@ public void prepareRecycle() {
log.info("Closed
lucasbru commented on code in PR #14226:
URL: https://github.com/apache/kafka/pull/14226#discussion_r1326415866
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java:
##
@@ -590,6 +590,30 @@ public void prepareRecycle() {
log.info("Closed
[
https://issues.apache.org/jira/browse/KAFKA-15467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Steve Jacobs updated KAFKA-15467:
-
Description:
I'm encountering an odd issue with mirrormaker2 with our remote replication
setup
[ https://issues.apache.org/jira/browse/KAFKA-15467 ]
Steve Jacobs deleted comment on KAFKA-15467:
--
was (Author: steveatbat):
Ok I've gone through this and the last 3 occurrences I can find, it's 12 topics
each time that get reset. At differen
[
https://issues.apache.org/jira/browse/KAFKA-15467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17765324#comment-17765324
]
Steve Jacobs commented on KAFKA-15467:
--
Ok I've gone through this and the last 3 oc
Steve Jacobs created KAFKA-15467:
Summary: On reconnect mm2 cannot find offset that exists in remote
cluster and re-syncs the entire topic
Key: KAFKA-15467
URL: https://issues.apache.org/jira/browse/KAFKA-15467
philipnee opened a new pull request, #14391:
URL: https://github.com/apache/kafka/pull/14391
This is a follow up of https://github.com/apache/kafka/pull/14386.
The goal of this PR is to refactor the toString method to reduce duplicated
code.
--
This is an automated message from the
kirktrue commented on code in PR #14386:
URL: https://github.com/apache/kafka/pull/14386#discussion_r1326361661
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/CommitApplicationEvent.java:
##
@@ -19,22 +19,23 @@
import org.apache.kafka.clients.consum
junrao commented on code in PR #14359:
URL: https://github.com/apache/kafka/pull/14359#discussion_r1326276789
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/CompletedFetchTest.java:
##
@@ -115,13 +122,17 @@ public void testCommittedTransactionRecordsInclude
[
https://issues.apache.org/jira/browse/KAFKA-15452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Raghu Baddam reassigned KAFKA-15452:
Assignee: Raghu Baddam
> Custom KafkaPrincipalBuilder Cannot Access SslPrincipalMapper
>
[
https://issues.apache.org/jira/browse/KAFKA-15452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17765305#comment-17765305
]
Raghu Baddam commented on KAFKA-15452:
--
Thanks [~mimaison], Let me take a look and
mannoopj opened a new pull request, #14389:
URL: https://github.com/apache/kafka/pull/14389
Check schema changes to ensure compatibility is not broken. Done through the
use of comparing new json file to historical json file. Assume historical
schemas are recursively compatible.
--
This
fvaleri commented on code in PR #13201:
URL: https://github.com/apache/kafka/pull/13201#discussion_r1326292439
##
build.gradle:
##
@@ -1880,9 +1880,10 @@ project(':tools:tools-api') {
project(':tools') {
archivesBaseName = "kafka-tools"
-
dependencies {
+api libs.sc
kirktrue closed pull request #14359: KAFKA-14274 [2-5/7]: Introduction of more
infrastructure for forthcoming fetch request manager
URL: https://github.com/apache/kafka/pull/14359
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub a
arunmathew88 commented on PR #11438:
URL: https://github.com/apache/kafka/pull/11438#issuecomment-1719780996
@divijvaidya If it helps, we have been running this patch in our primary
cluster which has a lot of topic delete-recreates and has not had a related
issue for almost 2 years.
--
T
philipnee commented on code in PR #14364:
URL: https://github.com/apache/kafka/pull/14364#discussion_r1326232358
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/DefaultBackgroundThread.java:
##
@@ -168,28 +171,41 @@ public DefaultBackgroundThread(final Time
philipnee commented on code in PR #14364:
URL: https://github.com/apache/kafka/pull/14364#discussion_r1326228037
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/DefaultBackgroundThread.java:
##
@@ -168,28 +171,41 @@ public DefaultBackgroundThread(final Time
philipnee commented on code in PR #14364:
URL: https://github.com/apache/kafka/pull/14364#discussion_r1326205537
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestManager.java:
##
@@ -0,0 +1,260 @@
+/*
+ * Licensed to the Apache Software Founda
kirktrue commented on code in PR #14384:
URL: https://github.com/apache/kafka/pull/14384#discussion_r1326170737
##
clients/src/main/java/org/apache/kafka/clients/producer/internals/ProducerBatch.java:
##
@@ -94,9 +100,40 @@ public ProducerBatch(TopicPartition tp,
MemoryRecordsB
OmniaGM commented on code in PR #13201:
URL: https://github.com/apache/kafka/pull/13201#discussion_r1326193756
##
build.gradle:
##
@@ -1880,9 +1880,10 @@ project(':tools:tools-api') {
project(':tools') {
archivesBaseName = "kafka-tools"
-
dependencies {
+api libs.sc
OmniaGM commented on code in PR #13201:
URL: https://github.com/apache/kafka/pull/13201#discussion_r1326193756
##
build.gradle:
##
@@ -1880,9 +1880,10 @@ project(':tools:tools-api') {
project(':tools') {
archivesBaseName = "kafka-tools"
-
dependencies {
+api libs.sc
fvaleri commented on code in PR #13201:
URL: https://github.com/apache/kafka/pull/13201#discussion_r1326137174
##
build.gradle:
##
@@ -1880,9 +1880,10 @@ project(':tools:tools-api') {
project(':tools') {
archivesBaseName = "kafka-tools"
-
dependencies {
+api libs.sc
fvaleri commented on PR #13201:
URL: https://github.com/apache/kafka/pull/13201#issuecomment-1719725886
> > Hi @OmniaGM, thanks. I left some comments.
> > Additionally, this error message is different from previous
implementation:
> > ```shell
> > ### OLD
> > $ bin/kafka-topics.s
[
https://issues.apache.org/jira/browse/KAFKA-7739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Satish Duggana updated KAFKA-7739:
--
Description:
KIP:
[https://cwiki.apache.org/confluence/display/KAFKA/KIP-405%3A+Kafka+Tiered+S
[
https://issues.apache.org/jira/browse/KAFKA-7739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Satish Duggana updated KAFKA-7739:
--
Labels: KIP-405 (was: needs-kip)
> Kafka Tiered Storage
>
>
>
[
https://issues.apache.org/jira/browse/KAFKA-15221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17765241#comment-17765241
]
Satish Duggana edited comment on KAFKA-15221 at 9/14/23 3:50 PM:
-
[
https://issues.apache.org/jira/browse/KAFKA-15221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17765241#comment-17765241
]
Satish Duggana commented on KAFKA-15221:
Moving to 3.7.0 as code freeze is over.
[
https://issues.apache.org/jira/browse/KAFKA-15221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Satish Duggana updated KAFKA-15221:
---
Fix Version/s: 3.7.0
(was: 3.6.0)
> Potential race condition between
[
https://issues.apache.org/jira/browse/KAFKA-15465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17765240#comment-17765240
]
Satish Duggana commented on KAFKA-15465:
Moving it to 3.7.0 as 3.6.0 code freeze
[
https://issues.apache.org/jira/browse/KAFKA-15465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Satish Duggana updated KAFKA-15465:
---
Fix Version/s: 3.7.0
(was: 3.6.0)
> MM2 not working when its internal
dajac commented on code in PR #14364:
URL: https://github.com/apache/kafka/pull/14364#discussion_r1326105802
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestManager.java:
##
@@ -0,0 +1,260 @@
+/*
+ * Licensed to the Apache Software Foundation
lianetm commented on code in PR #14364:
URL: https://github.com/apache/kafka/pull/14364#discussion_r1326089090
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestManager.java:
##
@@ -0,0 +1,260 @@
+/*
+ * Licensed to the Apache Software Foundati
zhaohaidao commented on PR #14271:
URL: https://github.com/apache/kafka/pull/14271#issuecomment-1719591231
> @zhaohaidao Thanks for the update and your patience. I just replied to
your comments and left a few nits. The PR looks pretty good. We are almost
there :).
Hey @dajac The late
lianetm commented on code in PR #14364:
URL: https://github.com/apache/kafka/pull/14364#discussion_r1326031428
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestManager.java:
##
@@ -0,0 +1,260 @@
+/*
+ * Licensed to the Apache Software Foundati
lianetm commented on code in PR #14364:
URL: https://github.com/apache/kafka/pull/14364#discussion_r1325999433
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/DefaultBackgroundThread.java:
##
@@ -168,28 +171,41 @@ public DefaultBackgroundThread(final Time ti
[
https://issues.apache.org/jira/browse/KAFKA-7739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Satish Duggana resolved KAFKA-7739.
---
Resolution: Fixed
> Kafka Tiered Storage
>
>
> Key: KAFK
lianetm commented on code in PR #14364:
URL: https://github.com/apache/kafka/pull/14364#discussion_r1325999433
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/DefaultBackgroundThread.java:
##
@@ -168,28 +171,41 @@ public DefaultBackgroundThread(final Time ti
OmniaGM commented on PR #14388:
URL: https://github.com/apache/kafka/pull/14388#issuecomment-1719474292
> @OmniaGM , Thank you for being very reactive. It seems
`TopicAuthorizationException` is missing
Added it now.
--
This is an automated message from the Apache Git Service.
To r
ahibot commented on PR #14388:
URL: https://github.com/apache/kafka/pull/14388#issuecomment-1719436507
@OmniaGM , Thank you for being very reactive.
It seems `TopicAuthorizationException` is missing
--
This is an automated message from the Apache Git Service.
To respond to the message,
[
https://issues.apache.org/jira/browse/KAFKA-15465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Omnia Ibrahim updated KAFKA-15465:
--
Fix Version/s: 3.5.2
(was: 3.7.0)
> MM2 not working when its internal t
OmniaGM opened a new pull request, #14388:
URL: https://github.com/apache/kafka/pull/14388
https://issues.apache.org/jira/browse/KAFKA-15465?page=com.atlassian.jira.plugin.system.issuetabpanels%3Aall-tabpanel
MM2 should work without throwing errors if it's not authorised to create
in
[
https://issues.apache.org/jira/browse/KAFKA-15442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen resolved KAFKA-15442.
---
Resolution: Fixed
> add document to introduce tiered storage feature and the usage
> ---
showuon commented on PR #14382:
URL: https://github.com/apache/kafka/pull/14382#issuecomment-1719338018
Failed tests are unrelated:
```
Build / JDK 11 and Scala 2.13 /
org.apache.kafka.connect.integration.ConnectorRestartApiIntegrationTest.testMultiWorkerRestartOnlyConnector
showuon merged PR #14382:
URL: https://github.com/apache/kafka/pull/14382
--
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-15465 ]
Omnia Ibrahim deleted comment on KAFKA-15465:
---
was (Author: omnia_h_ibrahim):
One thing I noticed is the test for `{{{}MirrorUtils.createCompactedTopic{}}}`
[https://github.com/apache/kafk
[
https://issues.apache.org/jira/browse/KAFKA-15465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17765103#comment-17765103
]
Omnia Ibrahim edited comment on KAFKA-15465 at 9/14/23 10:59 AM:
-
[
https://issues.apache.org/jira/browse/KAFKA-15465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17765103#comment-17765103
]
Omnia Ibrahim commented on KAFKA-15465:
---
One thing I noticed is the test for `{{{}
[
https://issues.apache.org/jira/browse/KAFKA-15465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Omnia Ibrahim reassigned KAFKA-15465:
-
Assignee: Omnia Ibrahim
> MM2 not working when its internal topics are pre-created on a
[
https://issues.apache.org/jira/browse/KAFKA-15465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17765099#comment-17765099
]
Omnia Ibrahim commented on KAFKA-15465:
---
Hi [~ahibot] ,
I re-checked the code of
cadonna commented on PR #12875:
URL: https://github.com/apache/kafka/pull/12875#issuecomment-1719166276
@marcmesh Unfortunately, we did not manage to enable the state updater by
default in 3.6. You can enable it with the internal `__state.updater.enabled__`
set to true. However, be aware th
OmniaGM commented on PR #13204:
URL: https://github.com/apache/kafka/pull/13204#issuecomment-1719152037
The test is failing for different packages
https://ci-builds.apache.org/job/Kafka/job/kafka-pr/job/PR-13204/19/testReport/
and one of the tasks succeeded in building but failed with an er
marcmesh commented on PR #12875:
URL: https://github.com/apache/kafka/pull/12875#issuecomment-1719130457
> @andrashatvani Do you mean the state updater? I am currently working on
enabling the state updater by default on trunk. We plan to officially release
it in 3.6. However, you can alread
dajac commented on code in PR #14182:
URL: https://github.com/apache/kafka/pull/14182#discussion_r1325561675
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/AbstractUniformAssignmentBuilder.java:
##
@@ -0,0 +1,227 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/KAFKA-15463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17765066#comment-17765066
]
Bruno Cadonna commented on KAFKA-15463:
---
[~yevsh] Sorry to hear that you have issu
showuon commented on PR #14382:
URL: https://github.com/apache/kafka/pull/14382#issuecomment-1718998104
@tinaselenge , thanks for the comments. PR updated.
--
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
showuon commented on code in PR #14382:
URL: https://github.com/apache/kafka/pull/14382#discussion_r1325573311
##
docs/ops.html:
##
@@ -3859,6 +3859,98 @@ Finalizing the migration
# Other configs ...
+
+6.11 Tiered Storage
+
+Tiered Storage
Overview
+
+Kafka data is mostly
tinaselenge commented on PR #14382:
URL: https://github.com/apache/kafka/pull/14382#issuecomment-1718963224
Left very minor comments which I'm happy if you want to address in
subsequent PR. LGTM otherwise.
--
This is an automated message from the Apache Git Service.
To respond to the mes
tinaselenge commented on code in PR #14382:
URL: https://github.com/apache/kafka/pull/14382#discussion_r1325541475
##
docs/ops.html:
##
@@ -3859,6 +3859,98 @@ Finalizing the migration
# Other configs ...
+
+6.11 Tiered Storage
+
+Tiered Storage
Overview
+
+Kafka data is mo
tinaselenge commented on code in PR #14382:
URL: https://github.com/apache/kafka/pull/14382#discussion_r1325542037
##
docs/ops.html:
##
@@ -3859,6 +3859,98 @@ Finalizing the migration
# Other configs ...
+
+6.11 Tiered Storage
+
+Tiered Storage
Overview
+
+Kafka data is mo
tinaselenge commented on code in PR #14382:
URL: https://github.com/apache/kafka/pull/14382#discussion_r1325541025
##
docs/ops.html:
##
@@ -3859,6 +3859,98 @@ Finalizing the migration
# Other configs ...
+
+6.11 Tiered Storage
+
+Tiered Storage
Overview
+
+Kafka data is mo
[
https://issues.apache.org/jira/browse/KAFKA-15452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17765044#comment-17765044
]
Mickael Maison commented on KAFKA-15452:
Hi [~raghu98...@gmail.com], I granted y
[
https://issues.apache.org/jira/browse/KAFKA-15452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17765044#comment-17765044
]
Mickael Maison edited comment on KAFKA-15452 at 9/14/23 7:52 AM:
-
dajac commented on code in PR #14271:
URL: https://github.com/apache/kafka/pull/14271#discussion_r1325484973
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java:
##
@@ -8603,6 +8614,86 @@ public void
testHeartbeatDuringRebalanceCa
98 matches
Mail list logo
