[
https://issues.apache.org/jira/browse/KAFKA-17619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai reassigned KAFKA-17619:
--
Assignee: PoAn Yang (was: Chia-Ping Tsai)
> Remove zk type and instance from Cluster
frankvicky closed pull request #16649: KAFKA-17116: New consumer may not send
effective leave group if member ID received after close
URL: https://github.com/apache/kafka/pull/16649
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
smjn commented on code in PR #17149:
URL: https://github.com/apache/kafka/pull/17149#discussion_r1776430833
##
share-coordinator/src/main/java/org/apache/kafka/coordinator/share/StateBatchUtil.java:
##
@@ -0,0 +1,360 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) un
smjn commented on code in PR #17149:
URL: https://github.com/apache/kafka/pull/17149#discussion_r1776567400
##
share-coordinator/src/main/java/org/apache/kafka/coordinator/share/StateBatchUtil.java:
##
@@ -0,0 +1,360 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) un
[
https://issues.apache.org/jira/browse/KAFKA-17547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17884911#comment-17884911
]
George Yang commented on KAFKA-17547:
-
Could someone who has a deep understanding of
smjn commented on code in PR #17149:
URL: https://github.com/apache/kafka/pull/17149#discussion_r1776624490
##
share-coordinator/src/main/java/org/apache/kafka/coordinator/share/StateBatchUtil.java:
##
@@ -0,0 +1,360 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) un
smjn commented on code in PR #17149:
URL: https://github.com/apache/kafka/pull/17149#discussion_r1776624490
##
share-coordinator/src/main/java/org/apache/kafka/coordinator/share/StateBatchUtil.java:
##
@@ -0,0 +1,360 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) un
mjd95 commented on PR #15241:
URL: https://github.com/apache/kafka/pull/15241#issuecomment-2376460752
We were the ones discussing with @jeqo - the "caching closed channels" issue
was happening regularly for us on 3.8 in production, the thread doing a remote
read was interrupted while iterat
[
https://issues.apache.org/jira/browse/KAFKA-17617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17884912#comment-17884912
]
Chia-Ping Tsai commented on KAFKA-17617:
Scala 2.12 will be dropped in 4.0 (KAFK
[
https://issues.apache.org/jira/browse/KAFKA-12895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17884917#comment-17884917
]
Chia-Ping Tsai commented on KAFKA-12895:
[~frankvicky] Please review the KIP
([
[
https://issues.apache.org/jira/browse/KAFKA-17606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17884919#comment-17884919
]
Chia-Ping Tsai commented on KAFKA-17606:
[~loganzhu] I have assigned this Jira t
[
https://issues.apache.org/jira/browse/KAFKA-17606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai reassigned KAFKA-17606:
--
Assignee: Logan Zhu
> Include Rat errors in GitHub workflow summary
> ---
smjn commented on code in PR #17149:
URL: https://github.com/apache/kafka/pull/17149#discussion_r1776452137
##
share-coordinator/src/main/java/org/apache/kafka/coordinator/share/StateBatchUtil.java:
##
@@ -0,0 +1,360 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) un
[
https://issues.apache.org/jira/browse/KAFKA-12895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17884913#comment-17884913
]
Chia-Ping Tsai commented on KAFKA-12895:
Our new CI has already dropped support
[
https://issues.apache.org/jira/browse/KAFKA-12895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai reassigned KAFKA-12895:
--
Assignee: TengYao Chi (was: Ismael Juma)
> KIP-751: Drop support for Scala 2.12 in K
[
https://issues.apache.org/jira/browse/KAFKA-17587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17884923#comment-17884923
]
Chia-Ping Tsai commented on KAFKA-17587:
[~davidarthur] I open the https://issue
Chia-Ping Tsai created KAFKA-17619:
--
Summary: Remove zk type and instance from ClusterTest
Key: KAFKA-17619
URL: https://issues.apache.org/jira/browse/KAFKA-17619
Project: Kafka
Issue Type:
AndrewJSchofield opened a new pull request, #17279:
URL: https://github.com/apache/kafka/pull/17279
This PR implements the metadata redirection feature of the ShareFetch and
ShareAcknowledge responses where an error code of NOT_LEADER_OR_FOLLOWER or
FENCED_LEADER_EPOCH along with current le
LoganZhuZzz opened a new pull request, #17280:
URL: https://github.com/apache/kafka/pull/17280
In the current GitHub workflow, it has become difficult to locate Rat errors
when running `check -x test`. To improve readability and make it easier to
identify Rat errors, we need to include them
LoganZhuZzz commented on PR #17280:
URL: https://github.com/apache/kafka/pull/17280#issuecomment-2376561401
@chia7712 please take a look,thanks!
--
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 th
lianetm commented on code in PR #16982:
URL: https://github.com/apache/kafka/pull/16982#discussion_r1776792978
##
clients/src/test/java/org/apache/kafka/clients/consumer/KafkaConsumerTest.java:
##
@@ -2486,68 +2492,96 @@ public void testCurrentLag(GroupProtocol groupProtocol)
{
lianetm commented on code in PR #16982:
URL: https://github.com/apache/kafka/pull/16982#discussion_r1776796286
##
clients/src/test/java/org/apache/kafka/clients/consumer/KafkaConsumerTest.java:
##
@@ -2486,68 +2492,96 @@ public void testCurrentLag(GroupProtocol groupProtocol)
{
Apoorv Mittal created KAFKA-17620:
-
Summary: Simplify share partition acquire API
Key: KAFKA-17620
URL: https://issues.apache.org/jira/browse/KAFKA-17620
Project: Kafka
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/KAFKA-13938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17884953#comment-17884953
]
João Pedro Fonseca commented on KAFKA-13938:
Hi, [~mumrah]! Since Jenkins wa
fonsdant commented on code in PR #17182:
URL: https://github.com/apache/kafka/pull/17182#discussion_r1776825720
##
streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamTaskTest.java:
##
@@ -3030,7 +3030,7 @@ private StreamTask createSingleSourceStateless(fina
lianetm commented on code in PR #17165:
URL: https://github.com/apache/kafka/pull/17165#discussion_r1776831516
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractMembershipManager.java:
##
@@ -458,14 +466,24 @@ String memberIdInfoForLog() {
}
lianetm commented on code in PR #17230:
URL: https://github.com/apache/kafka/pull/17230#discussion_r1776850858
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java:
##
@@ -842,8 +843,8 @@ public void seekToEnd(Collection
partitions) {
lianetm commented on code in PR #17230:
URL: https://github.com/apache/kafka/pull/17230#discussion_r1776850858
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java:
##
@@ -842,8 +843,8 @@ public void seekToEnd(Collection
partitions) {
[
https://issues.apache.org/jira/browse/KAFKA-17496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot resolved KAFKA-17496.
-
Fix Version/s: 4.0.0
Resolution: Fixed
> Add heterogeneous configuration to TargetAssignm
[
https://issues.apache.org/jira/browse/KAFKA-17616?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17884885#comment-17884885
]
Dmitry Werner commented on KAFKA-17616:
---
[~cmccabe] Hello, if you are not start wo
dajac commented on PR #17274:
URL: https://github.com/apache/kafka/pull/17274#issuecomment-2376097825
@mumrah @chia7712 Long story short, I did not find any correctness issue in
the new group coordinator. All the failed tests where due to pending members in
the classic group preventing the
dajac merged PR #17274:
URL: https://github.com/apache/kafka/pull/17274
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.or
[
https://issues.apache.org/jira/browse/KAFKA-17571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot resolved KAFKA-17571.
-
Fix Version/s: 4.0.0
Resolution: Fixed
> Revert #17219
> -
>
>
cadonna commented on PR #17209:
URL: https://github.com/apache/kafka/pull/17209#issuecomment-2376116982
@aliehsaeedii the following test fails consistently with a NPE with this PR:
`StreamThreadTest.shouldRecordCommitLatency()`.
See https://github.com/apache/kafka/actions/runs/110306753
[
https://issues.apache.org/jira/browse/KAFKA-17584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen resolved KAFKA-17584.
---
Fix Version/s: 3.9.0
3.8.1
Resolution: Fixed
> Fix incorrect synonym handl
smjn commented on code in PR #17149:
URL: https://github.com/apache/kafka/pull/17149#discussion_r1776535621
##
share-coordinator/src/test/java/org/apache/kafka/coordinator/share/StateBatchUtilTest.java:
##
@@ -0,0 +1,472 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF
smjn commented on code in PR #17149:
URL: https://github.com/apache/kafka/pull/17149#discussion_r1776452137
##
share-coordinator/src/main/java/org/apache/kafka/coordinator/share/StateBatchUtil.java:
##
@@ -0,0 +1,360 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) un
smjn commented on code in PR #17149:
URL: https://github.com/apache/kafka/pull/17149#discussion_r1776535621
##
share-coordinator/src/test/java/org/apache/kafka/coordinator/share/StateBatchUtilTest.java:
##
@@ -0,0 +1,472 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF
[
https://issues.apache.org/jira/browse/KAFKA-17618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
PoAn Yang updated KAFKA-17618:
--
Labels: kip-848 (was: )
> group consumer heartbeat interval should be less than session timeout
> ---
PoAn Yang created KAFKA-17618:
-
Summary: group consumer heartbeat interval should be less than
session timeout
Key: KAFKA-17618
URL: https://issues.apache.org/jira/browse/KAFKA-17618
Project: Kafka
mumrah commented on PR #17112:
URL: https://github.com/apache/kafka/pull/17112#issuecomment-2377323567
@satishd @showuon this PR broke some tests and has caused trunk builds to
fail.
The latest CI run for this PR was
https://github.com/apache/kafka/actions/runs/11027485627 which sho
[
https://issues.apache.org/jira/browse/KAFKA-17617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Arthur reassigned KAFKA-17617:
Assignee: David Arthur
> New GitHub Actions build builds Java 8 with 2.13 instead of 2.12
kamalcph commented on PR #17287:
URL: https://github.com/apache/kafka/pull/17287#issuecomment-2377344257
Thanks @FrankYang0529 for fixing this test!
--
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 t
kamalcph commented on PR #17112:
URL: https://github.com/apache/kafka/pull/17112#issuecomment-2377346567
The failed test are fixed in #17287
--
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 sp
dajac commented on code in PR #17288:
URL: https://github.com/apache/kafka/pull/17288#discussion_r1777317218
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java:
##
@@ -1984,8 +1986,10 @@ private CoordinatorResult
classicGroupJoinToCo
dajac commented on code in PR #17288:
URL: https://github.com/apache/kafka/pull/17288#discussion_r1777312193
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java:
##
@@ -1984,8 +1986,10 @@ private CoordinatorResult
classicGroupJoinToCo
mumrah merged PR #17287:
URL: https://github.com/apache/kafka/pull/17287
--
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.o
gharris1727 commented on PR #16522:
URL: https://github.com/apache/kafka/pull/16522#issuecomment-2377340024
Hey @danishnawab thanks for reminding us.
Since this may only be included in future releases (3.7.2, 3.8.1, 3.9.1,
4.0.0), existing releases you can use the workaround of settin
lianetm merged PR #16982:
URL: https://github.com/apache/kafka/pull/16982
--
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-17623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-17623:
--
Component/s: clients
> Flaky
> testSeekPositionAndPauseNewlyAssignedPartitionOnPartitionsAssignedCall
jolshan merged PR #16719:
URL: https://github.com/apache/kafka/pull/16719
--
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.
kirktrue commented on code in PR #17244:
URL: https://github.com/apache/kafka/pull/17244#discussion_r1777422783
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java:
##
@@ -1279,7 +1281,7 @@ private void releaseAssignmentAndLeaveGroup(fina
FrankYang0529 commented on code in PR #17165:
URL: https://github.com/apache/kafka/pull/17165#discussion_r1776908662
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractMembershipManager.java:
##
@@ -458,14 +466,24 @@ String memberIdInfoForLog() {
}
AndrewJSchofield opened a new pull request, #17282:
URL: https://github.com/apache/kafka/pull/17282
KIP-932 added a bunch of new record schemas to the consumer offsets topic
which need to be added to the OffsetsMessageParser in kafka-dump-log.sh.
### Committer Checklist (excluded from
[
https://issues.apache.org/jira/browse/KAFKA-16394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17885016#comment-17885016
]
Andras Hatvani commented on KAFKA-16394:
[~mjsax] Any update on the fix and rele
FrankYang0529 opened a new pull request, #17284:
URL: https://github.com/apache/kafka/pull/17284
*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 t
AndrewJSchofield commented on code in PR #17149:
URL: https://github.com/apache/kafka/pull/17149#discussion_r1777017514
##
share-coordinator/src/main/java/org/apache/kafka/coordinator/share/StateBatchUtil.java:
##
@@ -0,0 +1,360 @@
+/*
+ * Licensed to the Apache Software Foundat
squah-confluent opened a new pull request, #17285:
URL: https://github.com/apache/kafka/pull/17285
Looking up topics in a TopicsImage is relatively slow. Cache the results
in TopicIds to improve assignor performance. In benchmarks, we see a
noticeable improvement in performance in the h
Chia-Ping Tsai created KAFKA-17624:
--
Summary: Remove the E2E uses of accessing ACLs from zk
Key: KAFKA-17624
URL: https://issues.apache.org/jira/browse/KAFKA-17624
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-17624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17885050#comment-17885050
]
TengYao Chi commented on KAFKA-17624:
-
Hi [~chia7712]
If you are not start working
FrankYang0529 opened a new pull request, #17287:
URL: https://github.com/apache/kafka/pull/17287
*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 t
dongnuo123 commented on PR #17008:
URL: https://github.com/apache/kafka/pull/17008#issuecomment-2377169743
Reopened https://github.com/apache/kafka/pull/17286
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL abo
mumrah commented on code in PR #17204:
URL: https://github.com/apache/kafka/pull/17204#discussion_r1777223177
##
committer-tools/update-cache.sh:
##
@@ -0,0 +1,35 @@
+#!/bin/bash
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license agreeme
mumrah commented on PR #17204:
URL: https://github.com/apache/kafka/pull/17204#issuecomment-2377207907
> Maybe, we keep it more agnostic and print a message guiding the user to
fetch. WDYT?
Good point on different remote names. Let's still attempt to update the ref
in this script. If
[
https://issues.apache.org/jira/browse/KAFKA-17617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Arthur updated KAFKA-17617:
-
Fix Version/s: 3.9.1
> New GitHub Actions build builds Java 8 with 2.13 instead of 2.12
> --
[
https://issues.apache.org/jira/browse/KAFKA-17617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Arthur updated KAFKA-17617:
-
Priority: Minor (was: Critical)
> New GitHub Actions build builds Java 8 with 2.13 instead of 2
[
https://issues.apache.org/jira/browse/KAFKA-17617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Arthur updated KAFKA-17617:
-
Fix Version/s: 3.7.2
3.8.1
> New GitHub Actions build builds Java 8 with 2.13
lianetm commented on code in PR #17244:
URL: https://github.com/apache/kafka/pull/17244#discussion_r1777270499
##
core/src/test/scala/integration/kafka/api/PlaintextConsumerSubscriptionTest.scala:
##
@@ -244,6 +245,9 @@ class PlaintextConsumerSubscriptionTest extends
AbstractCo
mumrah commented on PR #17287:
URL: https://github.com/apache/kafka/pull/17287#issuecomment-2377227125
Looks like the tests were failing on the PR, so this should not have been
merged.
https://github.com/apache/kafka/actions/runs/11027485627
--
This is an automated message from the
mumrah commented on PR #17287:
URL: https://github.com/apache/kafka/pull/17287#issuecomment-2377232171
@chia7712 I agree we should eventually have some "acceptance" tests which do
some high level sanity checks. In this case, a change to MetadataVersion
(located in server-common) will cause
wrwksexahatvani commented on PR #15607:
URL: https://github.com/apache/kafka/pull/15607#issuecomment-2376945505
@mjsax @wcarlson5 @gongxuanzhang This is a major blocker as it leads to data
loss as happened in dozens of my projects. When will the fix for this be
integrated?
--
This is an
lianetm commented on code in PR #17150:
URL: https://github.com/apache/kafka/pull/17150#discussion_r1777058782
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/ApplicationEventProcessor.java:
##
@@ -162,23 +163,44 @@ private void process(final PollEven
fonsdant commented on PR #17182:
URL: https://github.com/apache/kafka/pull/17182#issuecomment-2376967494
Accidentally, I must have reverted the removal of the
`builtInMetricsVersion` passing argument to `StreamsMetricsImpl` in
`TopologyTestDriver`, which has caused the build to fail. The la
[
https://issues.apache.org/jira/browse/KAFKA-17622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alieh Saeedi updated KAFKA-17622:
-
Summary: Kafka Streams Timeout During Partition Rebalance (was: Kafka
Streams Timeout During P
[
https://issues.apache.org/jira/browse/KAFKA-17582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17885032#comment-17885032
]
Kyle Kingsbury commented on KAFKA-17582:
I've done some more digging here, and w
lianetm commented on PR #17244:
URL: https://github.com/apache/kafka/pull/17244#issuecomment-2377319827
Regarding:
> I haven't had a chance to dig into the root cause as I'm curious what can
be done at that layer so that the consumer doesn't have to be aware of it.
My thoughts in c
FrankYang0529 commented on code in PR #16982:
URL: https://github.com/apache/kafka/pull/16982#discussion_r1776899718
##
clients/src/test/java/org/apache/kafka/clients/consumer/KafkaConsumerTest.java:
##
@@ -2486,68 +2492,96 @@ public void testCurrentLag(GroupProtocol groupProtoc
FrankYang0529 commented on code in PR #16982:
URL: https://github.com/apache/kafka/pull/16982#discussion_r1776899718
##
clients/src/test/java/org/apache/kafka/clients/consumer/KafkaConsumerTest.java:
##
@@ -2486,68 +2492,96 @@ public void testCurrentLag(GroupProtocol groupProtoc
lianetm commented on code in PR #17230:
URL: https://github.com/apache/kafka/pull/17230#discussion_r1776850858
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java:
##
@@ -842,8 +843,8 @@ public void seekToEnd(Collection
partitions) {
[
https://issues.apache.org/jira/browse/KAFKA-15266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kamal Chandraprakash resolved KAFKA-15266.
--
Resolution: Duplicate
> Static configs set for non primary synonyms are ignore
mumrah merged PR #17269:
URL: https://github.com/apache/kafka/pull/17269
--
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.o
FrankYang0529 opened a new pull request, #17281:
URL: https://github.com/apache/kafka/pull/17281
[KIP-848](https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=217387038#KIP848:TheNextGenerationoftheConsumerRebalanceProtocol-Heartbeat&Session)
mentions:
> The member is expect
mumrah commented on code in PR #17149:
URL: https://github.com/apache/kafka/pull/17149#discussion_r1776991897
##
share-coordinator/src/main/java/org/apache/kafka/coordinator/share/StateBatchUtil.java:
##
@@ -0,0 +1,360 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
chia7712 merged PR #17276:
URL: https://github.com/apache/kafka/pull/17276
--
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
David Jacot created KAFKA-17621:
---
Summary: Reduce logging verbosity on ConsumerGroupHeartbeat path
Key: KAFKA-17621
URL: https://issues.apache.org/jira/browse/KAFKA-17621
Project: Kafka
Issue T
[
https://issues.apache.org/jira/browse/KAFKA-17618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-17618:
--
Component/s: clients
consumer
> group consumer heartbeat interval should be less than
wrwksexahatvani commented on PR #15564:
URL: https://github.com/apache/kafka/pull/15564#issuecomment-2376930948
@wcarlson5 @mjsax In which release will these tests and of course the fix in
KAFKA-16394 be integrated?
--
This is an automated message from the Apache Git Service.
To respond
[
https://issues.apache.org/jira/browse/KAFKA-17618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-17618:
--
Component/s: (was: clients)
(was: consumer)
> group consumer heartbeat interv
lianetm commented on PR #17165:
URL: https://github.com/apache/kafka/pull/17165#issuecomment-2377143597
FYI, I filed https://issues.apache.org/jira/browse/KAFKA-17623 for a flaky
consumer integration test that I noticed here, has been flaky for a while.
--
This is an automated message fro
Lianet Magrans created KAFKA-17623:
--
Summary: Flaky
testSeekPositionAndPauseNewlyAssignedPartitionOnPartitionsAssignedCallback
Key: KAFKA-17623
URL: https://issues.apache.org/jira/browse/KAFKA-17623
FrankYang0529 commented on PR #17165:
URL: https://github.com/apache/kafka/pull/17165#issuecomment-2377164009
> FYI, I filed https://issues.apache.org/jira/browse/KAFKA-17623 for a flaky
consumer integration test that I noticed here, has been flaky for a while.
Okay. I will take a loo
[
https://issues.apache.org/jira/browse/KAFKA-17623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17885047#comment-17885047
]
PoAn Yang commented on KAFKA-17623:
---
Hi [~lianetm], may I take this? Thank you.
> Fla
dajac closed pull request #16527: (WIP) MINOR: Cache topic resolution in
TopicIds set
URL: https://github.com/apache/kafka/pull/16527
--
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 com
dongnuo123 closed pull request #17008: KAFKA-17317: Validate and maybe trigger
downgrade after static member replacement
URL: https://github.com/apache/kafka/pull/17008
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
[
https://issues.apache.org/jira/browse/KAFKA-17623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17885049#comment-17885049
]
Lianet Magrans commented on KAFKA-17623:
Sure, thanks!
> Flaky
> testSeekPosit
dongnuo123 opened a new pull request, #17286:
URL: https://github.com/apache/kafka/pull/17286
https://issues.apache.org/jira/browse/KAFKA-17317
This patch makes the online downgrade trigger asynchronous by scheduling a
timer to downgrade the group in the appendFuture of the coordinato
dajac commented on PR #16527:
URL: https://github.com/apache/kafka/pull/16527#issuecomment-2377167228
Replaced by https://github.com/apache/kafka/pull/17285.
--
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-17623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans reassigned KAFKA-17623:
--
Assignee: PoAn Yang
> Flaky
> testSeekPositionAndPauseNewlyAssignedPartitionOnPartit
mumrah commented on code in PR #17149:
URL: https://github.com/apache/kafka/pull/17149#discussion_r1776956765
##
share-coordinator/src/test/java/org/apache/kafka/coordinator/share/StateBatchUtilTest.java:
##
@@ -60,36 +60,60 @@ static class BatchTestHolder {
this.sh
jeffkbkim commented on code in PR #17221:
URL: https://github.com/apache/kafka/pull/17221#discussion_r1776938178
##
coordinator-common/src/test/java/org/apache/kafka/coordinator/common/runtime/HdrHistogramTest.java:
##
@@ -172,4 +178,39 @@ public void testHistogramDataReset() {
1 - 100 of 284 matches
Mail list logo
