Owen-CH-Leung opened a new pull request, #15429:
URL: https://github.com/apache/kafka/pull/15429
https://issues.apache.org/jira/browse/KAFKA-15715
As per [KAFKA-15715](https://issues.apache.org/jira/browse/KAFKA-15715),
this PR adds Kraft support to UpgradeFeaturesTest
###
github-actions[bot] commented on PR #14776:
URL: https://github.com/apache/kafka/pull/14776#issuecomment-1962236422
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 #14808:
URL: https://github.com/apache/kafka/pull/14808#issuecomment-1962236411
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 #14834:
URL: https://github.com/apache/kafka/pull/14834#issuecomment-1962236395
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
cmccabe opened a new pull request, #15428:
URL: https://github.com/apache/kafka/pull/15428
(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, e-ma
credpath-seek commented on PR #15416:
URL: https://github.com/apache/kafka/pull/15416#issuecomment-1962156726
I was going to try to fix the pipeline issue:
```
[Checks API] No suitable checks publisher found.
```
But then I saw it had been attempted and reverted 😭
https://git
junrao commented on code in PR #13451:
URL: https://github.com/apache/kafka/pull/13451#discussion_r1501252737
##
core/src/test/scala/unit/kafka/controller/ControllerIntegrationTest.scala:
##
@@ -572,6 +572,48 @@ class ControllerIntegrationTest extends QuorumTestHarness {
wcarlson5 commented on PR #15414:
URL: https://github.com/apache/kafka/pull/15414#issuecomment-1962002805
I might need to add a couple of unit tests, but I think it could use a
review when you got time @mjsax !
--
This is an automated message from the Apache Git Service.
To respond to the
wcarlson5 commented on code in PR #15414:
URL: https://github.com/apache/kafka/pull/15414#discussion_r1501173995
##
streams/src/test/java/org/apache/kafka/streams/integration/GlobalThreadShutDownOrderTest.java:
##
@@ -120,23 +119,11 @@ public void before(final TestInfo testInfo)
jsancio merged PR #15397:
URL: https://github.com/apache/kafka/pull/15397
--
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 opened a new pull request, #15427:
URL: https://github.com/apache/kafka/pull/15427
*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 testin
artemlivshits commented on code in PR #15265:
URL: https://github.com/apache/kafka/pull/15265#discussion_r1501002625
##
clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java:
##
@@ -2129,63 +2167,183 @@ private Map>
handleDescribeTopicsByNames(f
[
https://issues.apache.org/jira/browse/KAFKA-15853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17796383#comment-17796383
]
Federico Valeri edited comment on KAFKA-15853 at 2/23/24 5:06 PM:
hachikuji commented on code in PR #15385:
URL: https://github.com/apache/kafka/pull/15385#discussion_r1499908727
##
clients/src/test/java/org/apache/kafka/clients/MetadataTest.java:
##
@@ -1260,6 +1265,103 @@ else if (partition.equals(internalPart))
Mockito.reset(mockLi
lucasbru merged PR #15420:
URL: https://github.com/apache/kafka/pull/15420
--
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
lianetm commented on PR #15188:
URL: https://github.com/apache/kafka/pull/15188#issuecomment-1961610927
Regarding the validation of the regex, I lean towards having a new error,
like @dajac suggested. Just to clearly tell the user that it is using an
invalid regex, without overcomplicating
jolshan commented on code in PR #15413:
URL: https://github.com/apache/kafka/pull/15413#discussion_r1500883045
##
clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java:
##
@@ -231,7 +231,7 @@ public class ProducerConfig extends AbstractConfig {
Gaurav Narula created KAFKA-16304:
-
Summary: Disk I/O error does not offline log directory while
handling Fetch requests
Key: KAFKA-16304
URL: https://issues.apache.org/jira/browse/KAFKA-16304
Project
lucasbru merged PR #15419:
URL: https://github.com/apache/kafka/pull/15419
--
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
lianetm commented on PR #15415:
URL: https://github.com/apache/kafka/pull/15415#issuecomment-1961554165
Closing and re-opening PR to trigger build
--
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
lianetm closed pull request #15415: KAFKA-16258: callback to release assignment
when stale member leaves group
URL: https://github.com/apache/kafka/pull/15415
--
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
[
https://issues.apache.org/jira/browse/KAFKA-15302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17820083#comment-17820083
]
Jinyong Choi commented on KAFKA-15302:
--
[~cervinka] Hi.
It seems like the patch f
lianetm commented on PR #15415:
URL: https://github.com/apache/kafka/pull/15415#issuecomment-1961481081
Changes done @lucasbru, 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 the specifi
lianetm commented on code in PR #15415:
URL: https://github.com/apache/kafka/pull/15415#discussion_r1500782762
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/MemberState.java:
##
@@ -132,11 +132,20 @@ public enum MemberState {
PREPARE_LEAVING.previ
nicktelford commented on PR #15137:
URL: https://github.com/apache/kafka/pull/15137#issuecomment-1961419902
Closing this PR for now while I break changes out into separate PRs
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub an
nicktelford closed pull request #15137: KAFKA-14412: Transactional StateStores
URL: https://github.com/apache/kafka/pull/15137
--
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.
T
cadonna opened a new pull request, #15426:
URL: https://github.com/apache/kafka/pull/15426
Currently, in the async Kafka consumer updates to the group metadata that
are received by the heartbeat are propagated to the application thread in form
of an event. Group metadata is updated when a n
[
https://issues.apache.org/jira/browse/KAFKA-16169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lucas Brutschy reassigned KAFKA-16169:
--
Assignee: Lucas Brutschy (was: Lianet Magrans)
> FencedException in commitAsync not
cadonna commented on code in PR #15419:
URL: https://github.com/apache/kafka/pull/15419#discussion_r1500644733
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestManager.java:
##
@@ -546,8 +546,9 @@ public ConsumerGroupHeartbeatRequestData build
lucasbru commented on code in PR #15419:
URL: https://github.com/apache/kafka/pull/15419#discussion_r1500632283
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestManager.java:
##
@@ -546,8 +546,9 @@ public ConsumerGroupHeartbeatRequestData buil
lucasbru commented on PR #15415:
URL: https://github.com/apache/kafka/pull/15415#issuecomment-1961282993
Let me know if you are planning to change something. Otherwise, I think we
can merge it.
--
This is an automated message from the Apache Git Service.
To respond to the message, please
lucasbru commented on code in PR #15415:
URL: https://github.com/apache/kafka/pull/15415#discussion_r1500621907
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/MemberState.java:
##
@@ -132,11 +132,20 @@ public enum MemberState {
PREPARE_LEAVING.prev
songnon commented on PR #13451:
URL: https://github.com/apache/kafka/pull/13451#issuecomment-1961272891
@junrao Could you help to review this? 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
cadonna commented on code in PR #15419:
URL: https://github.com/apache/kafka/pull/15419#discussion_r1500548287
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestManager.java:
##
@@ -546,8 +546,9 @@ public ConsumerGroupHeartbeatRequestData build
credpath-seek commented on PR #15416:
URL: https://github.com/apache/kafka/pull/15416#issuecomment-1961101177
Thanks for the review @ableegoldman - I have incorporated your suggested
changes
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
credpath-seek commented on code in PR #15416:
URL: https://github.com/apache/kafka/pull/15416#discussion_r1500481139
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java:
##
@@ -663,6 +663,7 @@ private void assignOwnedPartitions() {
lucasbru commented on code in PR #15372:
URL: https://github.com/apache/kafka/pull/15372#discussion_r1500478736
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestManager.java:
##
@@ -232,13 +232,22 @@ public MembershipManager membershipManager(
divijvaidya commented on PR #15403:
URL: https://github.com/apache/kafka/pull/15403#issuecomment-1961076220
The build is failing because we need to modify a few other tests to use enum
instead of string. Please tag me here again for review once we have a green
build.
--
This is an automa
[
https://issues.apache.org/jira/browse/KAFKA-9803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17820006#comment-17820006
]
Lenin Joseph commented on KAFKA-9803:
-
Do we have any ETA on the availability of the
lucasbru merged PR #15392:
URL: https://github.com/apache/kafka/pull/15392
--
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-16111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17819997#comment-17819997
]
Lucas Brutschy commented on KAFKA-16111:
https://github.com/apache/kafka/pull/15
lucasbru commented on PR #15408:
URL: https://github.com/apache/kafka/pull/15408#issuecomment-1961025640
I'm keeping this around as an example, but I don't intend to merge this. I
think we can merge it together with
https://issues.apache.org/jira/browse/KAFKA-16111. Converting to a draft.
[
https://issues.apache.org/jira/browse/KAFKA-16301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Quoc Phong Dang reassigned KAFKA-16301:
---
Assignee: Quoc Phong Dang
> Review fenced member unsubscribe/subscribe callbacks in
[
https://issues.apache.org/jira/browse/KAFKA-16105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17819994#comment-17819994
]
Anatolii Popov commented on KAFKA-16105:
Hi [~ckamal] unfortunately it is really
lucasbru commented on code in PR #15419:
URL: https://github.com/apache/kafka/pull/15419#discussion_r1500408843
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestManager.java:
##
@@ -546,8 +546,9 @@ public ConsumerGroupHeartbeatRequestData buil
stanislavkozlovski commented on code in PR #15406:
URL: https://github.com/apache/kafka/pull/15406#discussion_r1500387364
##
docs/upgrade.html:
##
@@ -36,9 +36,9 @@ Notable changes in 3
-Upgrading to 3.6.0 from any
version 0.8.x through 3.5.x
+Upgrading to 3.6
[
https://issues.apache.org/jira/browse/KAFKA-15713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17818300#comment-17818300
]
Pavel Pozdeev edited comment on KAFKA-15713 at 2/23/24 8:55 AM:
--
pasharik commented on PR #15295:
URL: https://github.com/apache/kafka/pull/15295#issuecomment-1960924198
Hi, it looks like there is a typo in the ticket number in the title of this
pull request. It says KAFKA-15761, but the change is related to KAFKA-15716 -
the last two digits are switched
[
https://issues.apache.org/jira/browse/KAFKA-16296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin Leroy updated KAFKA-16296:
Description:
We have a rolling-restart problem we don't understand on a 3-node cluster.
When stop
adixitconfluent closed pull request #15425: AKCORE-32: Defined signature for
acknowledge functionality and added definition of Share Sessions
URL: https://github.com/apache/kafka/pull/15425
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on t
adixitconfluent opened a new pull request, #15425:
URL: https://github.com/apache/kafka/pull/15425
AKCORE-32: Defined signature for share acknowledge functionality and added
definition of Share Sessions
--
This is an automated message from the Apache Git Service.
To respond to
51 matches
Mail list logo