nizhikov commented on PR #15256:
URL: https://github.com/apache/kafka/pull/15256#issuecomment-1923260434
Hello @showuon
What do you think? `DynamicBrokerReconfigurationTest` failures related to
this PR? Or it can be merged as is?
--
This is an automated message from the Apache Git
[
https://issues.apache.org/jira/browse/KAFKA-16218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17813523#comment-17813523
]
Drawxy commented on KAFKA-16218:
Hi [~showuon], yes, as long as replica 2001 caught up,
[
https://issues.apache.org/jira/browse/KAFKA-16218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Drawxy updated KAFKA-16218:
---
Affects Version/s: 3.1.2
> Partition reassignment can't complete if any target replica is out-of-sync
>
[
https://issues.apache.org/jira/browse/KAFKA-16218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17813516#comment-17813516
]
Luke Chen commented on KAFKA-16218:
---
As long as replica 2001 caught up, everything sho
Drawxy created KAFKA-16218:
--
Summary: Partition reassignment can't complete if any target
replica is out-of-sync
Key: KAFKA-16218
URL: https://issues.apache.org/jira/browse/KAFKA-16218
Project: Kafka
github-actions[bot] commented on PR #14203:
URL: https://github.com/apache/kafka/pull/14203#issuecomment-1922745265
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 #14681:
URL: https://github.com/apache/kafka/pull/14681#issuecomment-1922745104
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
satishd commented on PR #15213:
URL: https://github.com/apache/kafka/pull/15213#issuecomment-1922694144
I will take a look at this PR by Monday(5th).
--
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
showuon commented on PR #15287:
URL: https://github.com/apache/kafka/pull/15287#issuecomment-1922643301
And given the above observation, I think it'd be better we also document it
about the error logs during rollback, to not surprise other users. @ppatierno
@cmccabe , WDYT?
--
This is an
showuon commented on PR #15287:
URL: https://github.com/apache/kafka/pull/15287#issuecomment-1922641648
@cmccabe , thanks for the comments. Please see my reply below:
> running zookeeper-shell.sh does not need to be done "quickly together with
rolling at least one broker". You must ha
[
https://issues.apache.org/jira/browse/KAFKA-16217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17813432#comment-17813432
]
Justine Olshan edited comment on KAFKA-16217 at 2/2/24 1:36 AM:
--
arunmathew88 commented on PR #11438:
URL: https://github.com/apache/kafka/pull/11438#issuecomment-1922610191
@showuon @divijvaidya Please take a look into this, as it is long pending.
Thanks.
--
This is an automated message from the Apache Git Service.
To respond to the message, please
[
https://issues.apache.org/jira/browse/KAFKA-16216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin McCabe resolved KAFKA-16216.
--
Fix Version/s: 3.7.0
Reviewer: Colin McCabe
Assignee: David Arthur (was: Col
cmccabe commented on PR #15287:
URL: https://github.com/apache/kafka/pull/15287#issuecomment-1922552107
I'm sorry but I had to revert this. It's just not correct.
* Brokers don't need to be in "pure ZK mode" to become ZK controllers. A
broker with `zookeeper.metadata.migration.enable
[
https://issues.apache.org/jira/browse/KAFKA-16216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin McCabe reassigned KAFKA-16216:
Assignee: Colin McCabe (was: David Arthur)
> Reduce batch size for initial metadata load
[
https://issues.apache.org/jira/browse/KAFKA-16217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16217:
--
Fix Version/s: 3.6.2
3.7.1
> Transactional producer stuck in IllegalStateException
[
https://issues.apache.org/jira/browse/KAFKA-16217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16217:
--
Labels: transactions (was: )
> Transactional producer stuck in IllegalStateException during close
> -
[
https://issues.apache.org/jira/browse/KAFKA-16217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-16217:
-
Assignee: Kirk True
> Transactional producer stuck in IllegalStateException during close
>
[
https://issues.apache.org/jira/browse/KAFKA-16217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-16217:
Component/s: producer
> Transactional producer stuck in IllegalStateException during clos
cmccabe commented on PR #15299:
URL: https://github.com/apache/kafka/pull/15299#issuecomment-1922507934
I moved the discussion about KIP-866 metrics to here
https://github.com/apache/kafka/pull/15306
--
This is an automated message from the Apache Git Service.
To respond to the message, p
cmccabe opened a new pull request, #15306:
URL: https://github.com/apache/kafka/pull/15306
This patch addresses a few minor observability and operational concerns for
ZK to KRaft migrations.
The "MetadataType" metric is added to both the brokers and controllers, as
defined in KIP-866
cmccabe commented on PR #15299:
URL: https://github.com/apache/kafka/pull/15299#issuecomment-1922503205
lgtm, committed.
--
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
cmccabe closed pull request #15299: KAFKA-16216: Reduce batch size for initial
metadata load during ZK migration
URL: https://github.com/apache/kafka/pull/15299
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL abov
[
https://issues.apache.org/jira/browse/KAFKA-16217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Justine Olshan updated KAFKA-16217:
---
Affects Version/s: 3.6.1
3.7.0
> Transactional producer stuck in Ille
[
https://issues.apache.org/jira/browse/KAFKA-16217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17813432#comment-17813432
]
Justine Olshan commented on KAFKA-16217:
Thanks [~calvinliu] for filing this bug
[
https://issues.apache.org/jira/browse/KAFKA-16217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Calvin Liu updated KAFKA-16217:
---
Description:
The producer is stuck during the close. It keeps retrying to abort the
transaction but
Calvin Liu created KAFKA-16217:
--
Summary: Transactional producer stuck in IllegalStateException
during close
Key: KAFKA-16217
URL: https://issues.apache.org/jira/browse/KAFKA-16217
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-15561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15561:
--
Priority: Critical (was: Major)
> Client support for new SubscriptionPattern based subscription
> ---
[
https://issues.apache.org/jira/browse/KAFKA-15538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15538:
--
Priority: Critical (was: Major)
> Client support for java regex based subscription
>
Colin McCabe created KAFKA-16216:
Summary: Reduce batch size for initial metadata load during ZK
migration
Key: KAFKA-16216
URL: https://issues.apache.org/jira/browse/KAFKA-16216
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-15284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15284:
--
Priority: Major (was: Blocker)
> Implement ConsumerGroupProtocolVersionResolver to determine consumer
cmccabe commented on code in PR #15293:
URL: https://github.com/apache/kafka/pull/15293#discussion_r1475200369
##
core/src/main/scala/kafka/server/metadata/ZkMetadataCache.scala:
##
@@ -65,48 +65,84 @@ case class MetadataSnapshot(partitionStates:
mutable.AnyRefMap[String, mutab
cmccabe commented on code in PR #15293:
URL: https://github.com/apache/kafka/pull/15293#discussion_r1475198190
##
core/src/main/scala/kafka/server/metadata/ZkMetadataCache.scala:
##
@@ -65,48 +65,84 @@ case class MetadataSnapshot(partitionStates:
mutable.AnyRefMap[String, mutab
cmccabe commented on code in PR #15293:
URL: https://github.com/apache/kafka/pull/15293#discussion_r1475196894
##
core/src/main/scala/kafka/server/metadata/ZkMetadataCache.scala:
##
@@ -65,48 +65,84 @@ case class MetadataSnapshot(partitionStates:
mutable.AnyRefMap[String, mutab
mumrah commented on code in PR #15293:
URL: https://github.com/apache/kafka/pull/15293#discussion_r1474508267
##
core/src/main/scala/kafka/server/metadata/ZkMetadataCache.scala:
##
@@ -65,48 +65,84 @@ case class MetadataSnapshot(partitionStates:
mutable.AnyRefMap[String, mutabl
[
https://issues.apache.org/jira/browse/KAFKA-15691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True resolved KAFKA-15691.
---
Resolution: Duplicate
> Add new system tests to use new consumer
> -
[
https://issues.apache.org/jira/browse/KAFKA-16169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16169:
--
Labels: kip-848-client-support (was: )
> FencedException in commitAsync not propagated without callba
[
https://issues.apache.org/jira/browse/KAFKA-16024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16024:
--
Labels: flaky-test integration-tests (was: flaky-test)
> SaslPlaintextConsumerTest#testCoordinatorFai
[
https://issues.apache.org/jira/browse/KAFKA-16024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16024:
--
Component/s: (was: unit tests)
> SaslPlaintextConsumerTest#testCoordinatorFailover is flaky
>
[
https://issues.apache.org/jira/browse/KAFKA-15993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15993:
--
Labels: consumer-threading-refactor integration-tests timeout (was:
consumer-threading-refactor integ
[
https://issues.apache.org/jira/browse/KAFKA-16112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16112:
--
Issue Type: Task (was: Improvement)
> Review JMX metrics in Async Consumer and determine the missing
[
https://issues.apache.org/jira/browse/KAFKA-16142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16142:
--
Issue Type: Improvement (was: Task)
Priority: Critical (was: Major)
> Update metrics documenta
[
https://issues.apache.org/jira/browse/KAFKA-16112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16112:
--
Issue Type: Improvement (was: Task)
Priority: Critical (was: Major)
> Review JMX metrics in As
[
https://issues.apache.org/jira/browse/KAFKA-16113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16113:
--
Priority: Critical (was: Major)
> AsyncKafkaConsumer: Add missing offset commit metrics
> ---
[
https://issues.apache.org/jira/browse/KAFKA-16116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16116:
--
Priority: Critical (was: Major)
> AsyncKafkaConsumer: Add missing rebalance metrics
> ---
[
https://issues.apache.org/jira/browse/KAFKA-16115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16115:
--
Priority: Critical (was: Major)
> AsyncKafkaConsumer: Add missing heartbeat metrics
> ---
[
https://issues.apache.org/jira/browse/KAFKA-16143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16143:
--
Fix Version/s: 4.0.0
(was: 3.8.0)
> New metrics for KIP-848 protocol
>
[
https://issues.apache.org/jira/browse/KAFKA-16143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16143:
--
Labels: kip-848-client-support metrics needs-kip (was:
kip-848-client-support metrics)
> New metrics
[
https://issues.apache.org/jira/browse/KAFKA-16143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16143:
--
Issue Type: Improvement (was: Task)
> New metrics for KIP-848 protocol
>
[
https://issues.apache.org/jira/browse/KAFKA-16143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16143:
--
Description: This task is to consider what _new_ metrics we need from the
KIP-848 protocol that aren't
Cerchie commented on code in PR #14360:
URL: https://github.com/apache/kafka/pull/14360#discussion_r1475018035
##
docs/streams/developer-guide/config-streams.html:
##
@@ -1010,6 +1016,18 @@ topology.optimization
+ windowed.inner.class.serde
+
+
+
+
[
https://issues.apache.org/jira/browse/KAFKA-16215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans updated KAFKA-16215:
---
Affects Version/s: 3.7.0
> Consumer does not rejoin after fenced on delayed revocation
> ---
[
https://issues.apache.org/jira/browse/KAFKA-16215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17813389#comment-17813389
]
Lianet Magrans commented on KAFKA-16215:
Definitely, added the Fix version.
>
[
https://issues.apache.org/jira/browse/KAFKA-16215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans updated KAFKA-16215:
---
Fix Version/s: 3.8.0
> Consumer does not rejoin after fenced on delayed revocation
> ---
[
https://issues.apache.org/jira/browse/KAFKA-16202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16202:
--
Component/s: clients
producer
> Extra dot in error message in producer
> ---
[
https://issues.apache.org/jira/browse/KAFKA-16215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17813382#comment-17813382
]
Kirk True commented on KAFKA-16215:
---
[~lianetm] do we want this in 3.8.0?
> Consumer
philipnee commented on code in PR #15216:
URL: https://github.com/apache/kafka/pull/15216#discussion_r1474925331
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/metrics/HeartbeatMetricsManager.java:
##
@@ -0,0 +1,77 @@
+/*
+ * Licensed to the Apache Software
philipnee commented on code in PR #15216:
URL: https://github.com/apache/kafka/pull/15216#discussion_r1474925331
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/metrics/HeartbeatMetricsManager.java:
##
@@ -0,0 +1,77 @@
+/*
+ * Licensed to the Apache Software
OmniaGM commented on code in PR #15304:
URL: https://github.com/apache/kafka/pull/15304#discussion_r1474743330
##
core/src/main/scala/kafka/admin/ConfigCommand.scala:
##
@@ -405,7 +420,7 @@ object ConfigCommand extends Logging {
val alterOptions = new
AlterConfigsOptio
cmccabe commented on code in PR #15293:
URL: https://github.com/apache/kafka/pull/15293#discussion_r1474870992
##
core/src/main/scala/kafka/server/metadata/ZkMetadataCache.scala:
##
@@ -65,48 +65,84 @@ case class MetadataSnapshot(partitionStates:
mutable.AnyRefMap[String, mutab
cmccabe commented on code in PR #15293:
URL: https://github.com/apache/kafka/pull/15293#discussion_r1474870992
##
core/src/main/scala/kafka/server/metadata/ZkMetadataCache.scala:
##
@@ -65,48 +65,84 @@ case class MetadataSnapshot(partitionStates:
mutable.AnyRefMap[String, mutab
nizhikov commented on PR #15256:
URL: https://github.com/apache/kafka/pull/15256#issuecomment-1921875382
@showuon Please, wright me, If those failures should be further
investigated.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
nizhikov commented on PR #15256:
URL: https://github.com/apache/kafka/pull/15256#issuecomment-1921873375
Other trunk test run contains `DynamicBrokerReconfigurationTest ` fails,
also (but only for 1 environment).
https://ci-builds.apache.org/blue/organizations/jenkins/Kafka%2Fkafka/d
lucasbru commented on code in PR #15216:
URL: https://github.com/apache/kafka/pull/15216#discussion_r1474777535
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/metrics/HeartbeatMetricsManager.java:
##
@@ -0,0 +1,77 @@
+/*
+ * Licensed to the Apache Software
philipnee commented on PR #15216:
URL: https://github.com/apache/kafka/pull/15216#issuecomment-1921750518
@lucasbru - Thank you for spending time reviewing the PR. I responded to
your comment about resource closing. It is indeed a bit strange why we need to
do this.
A weird thing I
philipnee commented on code in PR #15216:
URL: https://github.com/apache/kafka/pull/15216#discussion_r1474763839
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/metrics/HeartbeatMetricsManager.java:
##
@@ -0,0 +1,77 @@
+/*
+ * Licensed to the Apache Software
Vaibhav-Nazare commented on code in PR #13817:
URL: https://github.com/apache/kafka/pull/13817#discussion_r1474755853
##
Jenkinsfile:
##
@@ -174,6 +183,28 @@ pipeline {
echo 'Skipping Kafka Streams archetype test for Java 21'
}
}
+
+stage
[
https://issues.apache.org/jira/browse/KAFKA-15575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton resolved KAFKA-15575.
---
Fix Version/s: 3.8.0
Resolution: Fixed
> Prevent Connectors from exceeding tasks.max
C0urante merged PR #15180:
URL: https://github.com/apache/kafka/pull/15180
--
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
Vaibhav-Nazare commented on code in PR #13817:
URL: https://github.com/apache/kafka/pull/13817#discussion_r1474754259
##
Jenkinsfile:
##
@@ -1,3 +1,7 @@
+
+
+
+
Review Comment:
done
--
This is an automated message from the Apache Git Service.
To respond to the message, p
Vaibhav-Nazare commented on code in PR #13817:
URL: https://github.com/apache/kafka/pull/13817#discussion_r1474755853
##
Jenkinsfile:
##
@@ -174,6 +183,28 @@ pipeline {
echo 'Skipping Kafka Streams archetype test for Java 21'
}
}
+
+stage
C0urante commented on PR #15302:
URL: https://github.com/apache/kafka/pull/15302#issuecomment-1921719937
@yashmayya @gharris1727 If either of you have a moment, here's another flaky
test fix. Would appreciate a look!
--
This is an automated message from the Apache Git Service.
To respond
mimaison commented on code in PR #15274:
URL: https://github.com/apache/kafka/pull/15274#discussion_r1474737738
##
tools/src/main/java/org/apache/kafka/tools/consumer/ConsoleConsumer.java:
##
@@ -0,0 +1,233 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or
mimaison commented on code in PR #15274:
URL: https://github.com/apache/kafka/pull/15274#discussion_r1474734641
##
tools/src/main/java/org/apache/kafka/tools/consumer/ConsoleConsumer.java:
##
@@ -0,0 +1,233 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or
dajac merged PR #15285:
URL: https://github.com/apache/kafka/pull/15285
--
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
mimaison commented on code in PR #15274:
URL: https://github.com/apache/kafka/pull/15274#discussion_r1474695808
##
tools/src/main/java/org/apache/kafka/tools/consumer/ConsoleConsumerOptions.java:
##
@@ -0,0 +1,414 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under
mimaison commented on code in PR #13817:
URL: https://github.com/apache/kafka/pull/13817#discussion_r1474685305
##
Jenkinsfile:
##
@@ -174,6 +183,28 @@ pipeline {
echo 'Skipping Kafka Streams archetype test for Java 21'
}
}
+
+stage('Powe
lianetm commented on PR #15285:
URL: https://github.com/apache/kafka/pull/15285#issuecomment-1921599500
Hey @dajac seems like we got a good
[build](https://ci-builds.apache.org/blue/organizations/jenkins/Kafka%2Fkafka-pr/detail/PR-15285/7/pipeline)
now, and test failures are unrelated.
-
lucasbru commented on PR #15216:
URL: https://github.com/apache/kafka/pull/15216#issuecomment-1921566239
I have one last comment, otherwise the PR looks good to me.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
U
lucasbru commented on code in PR #15216:
URL: https://github.com/apache/kafka/pull/15216#discussion_r1474644032
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/metrics/AbstractConsumerMetricsManager.java:
##
@@ -0,0 +1,94 @@
+/*
+ * Licensed to the Apache So
lucasbru commented on code in PR #15216:
URL: https://github.com/apache/kafka/pull/15216#discussion_r1474642551
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/metrics/HeartbeatMetricsManager.java:
##
@@ -0,0 +1,77 @@
+/*
+ * Licensed to the Apache Software
vamossagar12 commented on PR #13801:
URL: https://github.com/apache/kafka/pull/13801#issuecomment-1921517994
Thanks @C0urante for this! Let me review this and get back to you.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub an
vamossagar12 commented on PR #14158:
URL: https://github.com/apache/kafka/pull/14158#issuecomment-1921511483
@yashmayya , would you like to re-review this one when you have some time?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to G
vamossagar12 commented on code in PR #15305:
URL: https://github.com/apache/kafka/pull/15305#discussion_r1474605205
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/WorkerCoordinator.java:
##
@@ -267,6 +267,18 @@ public String memberId() {
r
vamossagar12 commented on code in PR #15305:
URL: https://github.com/apache/kafka/pull/15305#discussion_r1474598172
##
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/distributed/WorkerCoordinatorTest.java:
##
@@ -533,6 +536,47 @@ public void testSkippingAssignmen
vamossagar12 commented on code in PR #15305:
URL: https://github.com/apache/kafka/pull/15305#discussion_r1474595936
##
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/distributed/WorkerCoordinatorTest.java:
##
@@ -93,9 +96,9 @@ public class WorkerCoordinatorTest {
vamossagar12 opened a new pull request, #15305:
URL: https://github.com/apache/kafka/pull/15305
Please refer to the description in
[KAFKA-16197](https://issues.apache.org/jira/browse/KAFKA-16197).
--
This is an automated message from the Apache Git Service.
To respond to the message, ple
nizhikov commented on PR #15256:
URL: https://github.com/apache/kafka/pull/15256#issuecomment-1921473385
@showuon CI results are ready.
AFAICS other tests of `DynamicBrokerReconfigurationTest` failed in the
latest trunk:
https://ci-builds.apache.org/blue/organizations/jenkins/Kaf
C0urante commented on code in PR #15249:
URL: https://github.com/apache/kafka/pull/15249#discussion_r1474555935
##
connect/runtime/src/test/java/org/apache/kafka/connect/util/clusters/EmbeddedConnect.java:
##
@@ -963,11 +962,19 @@ public Set activeWorkers() {
return wor
C0urante merged PR #15249:
URL: https://github.com/apache/kafka/pull/15249
--
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
C0urante commented on PR #15249:
URL: https://github.com/apache/kafka/pull/15249#issuecomment-1921447477
The last change was trivial and the build passes locally. Merging...
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
C0urante commented on PR #15249:
URL: https://github.com/apache/kafka/pull/15249#issuecomment-1921446548
Thanks Yash! Regarding adding status code checking in
`EmbeddedConnect::restartConnectorAndTasks`, unfortunately this causes the
[testFailedConnectorRestartOnlyConnector
case](https://g
Lianet Magrans created KAFKA-16215:
--
Summary: Consumer does not rejoin after fenced on delayed
revocation
Key: KAFKA-16215
URL: https://issues.apache.org/jira/browse/KAFKA-16215
Project: Kafka
lucasbru commented on PR #15275:
URL: https://github.com/apache/kafka/pull/15275#issuecomment-1921371376
@lianetm Could you please have a look?
--
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
lucasbru commented on code in PR #15275:
URL: https://github.com/apache/kafka/pull/15275#discussion_r1474503361
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/MembershipManagerImpl.java:
##
@@ -1392,4 +1402,16 @@ public void registerStateListener(MemberStat
mumrah commented on code in PR #15293:
URL: https://github.com/apache/kafka/pull/15293#discussion_r1473671017
##
core/src/main/scala/kafka/server/metadata/ZkMetadataCache.scala:
##
@@ -65,48 +65,84 @@ case class MetadataSnapshot(partitionStates:
mutable.AnyRefMap[String, mutabl
dengziming opened a new pull request, #15304:
URL: https://github.com/apache/kafka/pull/15304
*More detailed description of your change*
This PR implement KIP-1011, use incrementalAlterConfigs by default to alter
broker configurations instead of the deprecated alterConfigs API, and fall b
showuon commented on PR #14953:
URL: https://github.com/apache/kafka/pull/14953#issuecomment-1921207947
@cmccabe @jsancio , please take a look when available. Thanks.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
showuon commented on PR #14631:
URL: https://github.com/apache/kafka/pull/14631#issuecomment-1921207331
@mumrah @cmccabe @mimaison , I think this doc improvement for ZK migrating
to KRaft is good to be included in v3.7.0. Please take a look. Thanks.
--
This is an automated message from th
showuon commented on PR #15280:
URL: https://github.com/apache/kafka/pull/15280#issuecomment-1921205131
@ijuma @mimaison , please take a look when available. Thanks.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
1 - 100 of 122 matches
Mail list logo
