[
https://issues.apache.org/jira/browse/KAFKA-15490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen resolved KAFKA-15490.
---
Fix Version/s: 3.6.2
Resolution: Fixed
> Invalid path provided to the log failure channel upo
showuon commented on PR #15490:
URL: https://github.com/apache/kafka/pull/15490#issuecomment-1999010980
Sorry that I missed the ping. Thanks Satish for helping review. :)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
ableegoldman merged PR #15508:
URL: https://github.com/apache/kafka/pull/15508
--
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.ap
ableegoldman commented on PR #15508:
URL: https://github.com/apache/kafka/pull/15508#issuecomment-1998996811
Well 1 of the 4 JDK builds was aborted for some unknown but the other 3
builds completed with only unrelated test failures.
Given this is literally only touching on javadocs an
chia7712 commented on PR #15507:
URL: https://github.com/apache/kafka/pull/15507#issuecomment-1998993124
@ChrisAHolland thank for double checking the failed tests. Will merge it
later!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
ChrisAHolland commented on PR #15507:
URL: https://github.com/apache/kafka/pull/15507#issuecomment-1998991332
@chia7712 I believe test failures are orthogonal, it seems all recently
merged PR's have been having test failures.
--
This is an automated message from the Apache Git Service.
To
sjhajharia commented on code in PR #15486:
URL: https://github.com/apache/kafka/pull/15486#discussion_r1525774714
##
core/src/main/scala/kafka/server/AddPartitionsToTxnManager.scala:
##
@@ -42,14 +42,26 @@ object AddPartitionsToTxnManager {
val VerificationTimeMsMetricName =
[
https://issues.apache.org/jira/browse/KAFKA-16370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
kaushik srinivas updated KAFKA-16370:
-
Issue Type: Bug (was: Improvement)
> offline rollback procedure from kraft mode to zook
satishd merged PR #15490:
URL: https://github.com/apache/kafka/pull/15490
--
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.
satishd commented on PR #15490:
URL: https://github.com/apache/kafka/pull/15490#issuecomment-1998903881
Failing tests are unrelated to this change, merging it to 3.6 branch.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
github-actions[bot] commented on PR #14957:
URL: https://github.com/apache/kafka/pull/14957#issuecomment-1998877709
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
hudeqi opened a new pull request, #15543:
URL: https://github.com/apache/kafka/pull/15543
The `resumeDeletions` method is called from multiple places and is the core
logic responsible for executing the deletion. Therefore, adding comments to
indicate where this method is being called can he
jolshan commented on code in PR #15486:
URL: https://github.com/apache/kafka/pull/15486#discussion_r1525699817
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/runtime/CoordinatorRuntime.java:
##
@@ -1456,7 +1456,7 @@ public CompletableFuture scheduleWriteO
jolshan commented on code in PR #15486:
URL: https://github.com/apache/kafka/pull/15486#discussion_r1525699580
##
core/src/main/scala/kafka/server/AddPartitionsToTxnManager.scala:
##
@@ -44,7 +44,7 @@ object AddPartitionsToTxnManager {
/**
* This is an enum which handles th
[
https://issues.apache.org/jira/browse/KAFKA-15206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen updated KAFKA-15206:
--
Fix Version/s: 3.7.1
> Flaky test RemoteIndexCacheTest.testClose()
> -
showuon merged PR #15523:
URL: https://github.com/apache/kafka/pull/15523
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.
showuon commented on PR #15523:
URL: https://github.com/apache/kafka/pull/15523#issuecomment-1998835444
Failed tests are unrelated.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific co
showuon commented on PR #15474:
URL: https://github.com/apache/kafka/pull/15474#issuecomment-1998834117
Thanks all for the review!
I've backported to v3.7. For v3.6, there are more codes diff, I'd like to
run CI first before push the change. PR:
https://github.com/apache/kafka/pull/1
showuon opened a new pull request, #15542:
URL: https://github.com/apache/kafka/pull/15542
Backported https://github.com/apache/kafka/pull/15474 to v3.6 branch. Since
there is more code diff, I'd like to make sure the backport doesn't break any
tests.
Fix getOffsetByMaxTimestamp for
[
https://issues.apache.org/jira/browse/KAFKA-16378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jianbin Chen updated KAFKA-16378:
-
Component/s: Tiered-Storage
> Under tiered storage, deleting local logs does not free disk space
[
https://issues.apache.org/jira/browse/KAFKA-16378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jianbin Chen updated KAFKA-16378:
-
Issue Type: Bug (was: Wish)
> Under tiered storage, deleting local logs does not free disk spac
Jianbin Chen created KAFKA-16378:
Summary: Under tiered storage, deleting local logs does not free
disk space
Key: KAFKA-16378
URL: https://issues.apache.org/jira/browse/KAFKA-16378
Project: Kafka
chia7712 commented on code in PR #14471:
URL: https://github.com/apache/kafka/pull/14471#discussion_r1525644188
##
tools/src/main/java/org/apache/kafka/tools/consumer/group/CsvUtils.java:
##
@@ -0,0 +1,119 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or
ChrisAHolland commented on code in PR #15507:
URL: https://github.com/apache/kafka/pull/15507#discussion_r1525616031
##
server-common/src/main/java/org/apache/kafka/server/mutable/BoundedList.java:
##
@@ -40,18 +40,22 @@ public static BoundedList newArrayBacked(int
maxLength)
jolshan commented on code in PR #15541:
URL: https://github.com/apache/kafka/pull/15541#discussion_r1525612166
##
clients/src/main/java/org/apache/kafka/clients/producer/internals/Sender.java:
##
@@ -270,14 +270,7 @@ public void run() {
while (!forceClose && transaction
[
https://issues.apache.org/jira/browse/KAFKA-16377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-16377:
Component/s: streams
unit tests
> Fix flaky
> HighAvailabilityTaskAssign
CalvinConfluent opened a new pull request, #15541:
URL: https://github.com/apache/kafka/pull/15541
This is a mitigation fix for the
https://issues.apache.org/jira/browse/KAFKA-16217. Exceptions should not block
closing the producers.
This PR reverts a part of the change
https://github.c
chia7712 commented on code in PR #15507:
URL: https://github.com/apache/kafka/pull/15507#discussion_r1525585193
##
server-common/src/main/java/org/apache/kafka/server/mutable/BoundedList.java:
##
@@ -40,18 +40,22 @@ public static BoundedList newArrayBacked(int
maxLength) {
wcarlson5 commented on code in PR #15414:
URL: https://github.com/apache/kafka/pull/15414#discussion_r1525585101
##
streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryKeyValueStore.java:
##
@@ -76,6 +76,8 @@ public void init(final ProcessorContext context,
[
https://issues.apache.org/jira/browse/KAFKA-16274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-16274:
-
Assignee: (was: Philip Nee)
> Update replica_scale_test.py to support KIP-848’s group proto
[
https://issues.apache.org/jira/browse/KAFKA-16275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-16275:
-
Assignee: (was: Philip Nee)
> Update kraft_upgrade_test.py to support KIP-848’s group proto
[
https://issues.apache.org/jira/browse/KAFKA-16271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-16271:
-
Assignee: (was: Philip Nee)
> Update consumer_rolling_upgrade_test.py to support KIP-848’s
[
https://issues.apache.org/jira/browse/KAFKA-16276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-16276:
-
Assignee: (was: Philip Nee)
> Update transactions_test.py to support KIP-848’s group protoc
[
https://issues.apache.org/jira/browse/KAFKA-16272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-16272:
-
Assignee: (was: Philip Nee)
> Update connect_distributed_test.py to support KIP-848’s group
soarez commented on PR #14903:
URL: https://github.com/apache/kafka/pull/14903#issuecomment-1998592089
Rebased this due to merge conflict.
@gaurav-narula I also made what I believe are some improvement to
`BrokerLifecycleManagerTest.testKraftJBODMetadataVersionUpdateEvent`, can you
jolshan commented on code in PR #15524:
URL: https://github.com/apache/kafka/pull/15524#discussion_r1525559114
##
core/src/test/scala/unit/kafka/coordinator/transaction/TransactionMarkerChannelManagerTest.scala:
##
@@ -177,6 +178,86 @@ class TransactionMarkerChannelManagerTest {
chia7712 commented on PR #15474:
URL: https://github.com/apache/kafka/pull/15474#issuecomment-1998576991
Thanks for all reviews and @showuon. This is not only a important fix to
kafka but also a great experience to me :)
@showuon Could you please backport this fix? thanks!
--
This
chia7712 commented on PR #15476:
URL: https://github.com/apache/kafka/pull/15476#issuecomment-1998570706
@johnnychhsu Could you please rebase code and address following comments.
1. update KIP-734 according to
https://github.com/apache/kafka/pull/15476#discussion_r1523677272
2.
[
https://issues.apache.org/jira/browse/KAFKA-14971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai resolved KAFKA-14971.
Resolution: Duplicate
KAFKA-15945 has filed PR so close this ticket
> Flaky Test
> org.a
chia7712 merged PR #15474:
URL: https://github.com/apache/kafka/pull/15474
--
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-15523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai resolved KAFKA-15523.
Resolution: Duplicate
KAFKA-15945 has filed PR so close this ticket
> Flaky test
> org.
chia7712 commented on PR #15474:
URL: https://github.com/apache/kafka/pull/15474#issuecomment-1998564199
the failed tests pass on my local.
```sh
./gradlew cleanTest core:test --tests LogDirFailureTest --tests
ReplicaManagerTest connect:mirror:test --tests
MirrorConnectorsIntegrationT
Chia-Ping Tsai created KAFKA-16377:
--
Summary: Fix flaky
HighAvailabilityTaskAssignorIntegrationTest.shouldScaleOutWithWarmupTasksAndPersistentStores
Key: KAFKA-16377
URL: https://issues.apache.org/jira/browse/KAF
Chia-Ping Tsai created KAFKA-16376:
--
Summary: Fix flaky
ReplicaManagerTest.testRemoteFetchExpiresPerSecMetric
Key: KAFKA-16376
URL: https://issues.apache.org/jira/browse/KAFKA-16376
Project: Kafka
ChrisAHolland commented on code in PR #15507:
URL: https://github.com/apache/kafka/pull/15507#discussion_r1525523190
##
server-common/src/test/java/org/apache/kafka/server/mutable/BoundedListTest.java:
##
@@ -165,18 +199,24 @@ public void testIterator() {
@Test
publi
kirktrue opened a new pull request, #15540:
URL: https://github.com/apache/kafka/pull/15540
Added a new optional `group_protocol` parameter to the test methods, then
passed that down to the `setup_consumer` method.
Unfortunately, because the new consumer can only be used with the new
kirktrue opened a new pull request, #15539:
URL: https://github.com/apache/kafka/pull/15539
Added a new optional `group_protocol` parameter to the test methods, then
passed that down to the `setup_consumer` method.
Unfortunately, because the new consumer can only be used with the new
kirktrue opened a new pull request, #15538:
URL: https://github.com/apache/kafka/pull/15538
Added a new optional `group_protocol` parameter to the test methods, then
passed that down to the `setup_consumer` method.
Unfortunately, because the new consumer can only be used with the new
kirktrue opened a new pull request, #15537:
URL: https://github.com/apache/kafka/pull/15537
Added a new optional `group_protocol` parameter to the test methods, then
passed that down to the `setup_consumer` method.
Unfortunately, because the new consumer can only be used with the new
[
https://issues.apache.org/jira/browse/KAFKA-16276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-16276:
-
Assignee: Philip Nee (was: Kirk True)
> Update transactions_test.py to support KIP-848’s group
[
https://issues.apache.org/jira/browse/KAFKA-16273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-16273:
-
Assignee: Philip Nee (was: Kirk True)
> Update consume_bench_test.py to support KIP-848’s grou
[
https://issues.apache.org/jira/browse/KAFKA-16271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-16271:
-
Assignee: Philip Nee (was: Kirk True)
> Update consumer_rolling_upgrade_test.py to support KIP
[
https://issues.apache.org/jira/browse/KAFKA-16272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-16272:
-
Assignee: Philip Nee (was: Kirk True)
> Update connect_distributed_test.py to support KIP-848’
[
https://issues.apache.org/jira/browse/KAFKA-16275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-16275:
-
Assignee: Philip Nee (was: Kirk True)
> Update kraft_upgrade_test.py to support KIP-848’s grou
[
https://issues.apache.org/jira/browse/KAFKA-16274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-16274:
-
Assignee: Philip Nee (was: Kirk True)
> Update replica_scale_test.py to support KIP-848’s grou
chia7712 commented on code in PR #15507:
URL: https://github.com/apache/kafka/pull/15507#discussion_r1525490485
##
server-common/src/test/java/org/apache/kafka/server/mutable/BoundedListTest.java:
##
@@ -165,18 +199,24 @@ public void testIterator() {
@Test
public voi
[
https://issues.apache.org/jira/browse/KAFKA-15691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15691:
--
Summary: Update system tests to use AsyncKafkaConsumer (was: Update system
tests to use new consumer)
[
https://issues.apache.org/jira/browse/KAFKA-15691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15691:
--
Priority: Blocker (was: Major)
> Add new system tests to use new consumer
> -
[
https://issues.apache.org/jira/browse/KAFKA-15691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reopened KAFKA-15691:
---
> Add new system tests to use new consumer
>
>
>
[
https://issues.apache.org/jira/browse/KAFKA-15691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15691:
--
Summary: Update system tests to use new consumer (was: Add new system
tests to use new consumer)
> U
[
https://issues.apache.org/jira/browse/KAFKA-16269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16269:
--
Description:
This task is to update the test method(s) in {{reassign_partitions_test.py}} to
support
[
https://issues.apache.org/jira/browse/KAFKA-16270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16270:
--
Description:
This task is to update the test method(s) in {{snapshot_test.py}} to support
the {{group
[
https://issues.apache.org/jira/browse/KAFKA-16275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16275:
--
Description:
This task is to update the test method(s) in {{kraft_upgrade_test.py}} to
support the {{
[
https://issues.apache.org/jira/browse/KAFKA-16273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16273:
--
Description:
This task is to update the test method(s) in {{consume_bench_test.py}} to
support the {{
[
https://issues.apache.org/jira/browse/KAFKA-16267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16267:
--
Description:
This task is to update the test method(s) in {{consumer_group_command_test.py}}
to suppo
[
https://issues.apache.org/jira/browse/KAFKA-16269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16269:
--
Description:
This task is to update the test method(s) in {{reassign_partitions_test.py}} to
support
[
https://issues.apache.org/jira/browse/KAFKA-16268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16268:
--
Description:
This task is to update the test method(s) in {{fetch_from_follower_test.py}} to
support
[
https://issues.apache.org/jira/browse/KAFKA-16272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16272:
--
Description:
This task is to update the test method(s) in {{connect_distributed_test.py}} to
support
[
https://issues.apache.org/jira/browse/KAFKA-16274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16274:
--
Description:
This task is to update the test method(s) in {{replica_scale_test.py}} to
support the {{
[
https://issues.apache.org/jira/browse/KAFKA-16271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16271:
--
Description:
This task is to update the test method(s) in
{{consumer_rolling_upgrade_test.py}} to sup
[
https://issues.apache.org/jira/browse/KAFKA-16231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16231:
--
Description:
This task is to update {{consumer_test.py}} to support the {{group.protocol}}
configurat
[
https://issues.apache.org/jira/browse/KAFKA-16276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16276:
--
Description:
This task is to update the test method(s) in {{transactions_test.py}} to
support the {{g
lianetm commented on PR #15511:
URL: https://github.com/apache/kafka/pull/15511#issuecomment-1998471082
Thanks for the updates @lucasbru, left some minor comments.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
UR
[
https://issues.apache.org/jira/browse/KAFKA-16375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans updated KAFKA-16375:
---
Description: The current implementation of the new consumer discards the
result of a reconci
lianetm commented on code in PR #15511:
URL: https://github.com/apache/kafka/pull/15511#discussion_r1525452774
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/MembershipManagerImpl.java:
##
@@ -976,6 +974,10 @@ void maybeReconcile() {
}
ChrisAHolland commented on PR #15507:
URL: https://github.com/apache/kafka/pull/15507#issuecomment-1998410642
@chia7712 Thank you, 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 to go to the spec
lianetm commented on code in PR #15511:
URL: https://github.com/apache/kafka/pull/15511#discussion_r1525446624
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/MembershipManagerImplTest.java:
##
@@ -1028,9 +1028,9 @@ public void
testNewEmptyAssignmentReplace
chia7712 commented on code in PR #15507:
URL: https://github.com/apache/kafka/pull/15507#discussion_r1525419354
##
server-common/src/main/java/org/apache/kafka/server/mutable/BoundedList.java:
##
@@ -40,18 +40,17 @@ public static BoundedList newArrayBacked(int
maxLength) {
lianetm commented on code in PR #15511:
URL: https://github.com/apache/kafka/pull/15511#discussion_r1525418611
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/MembershipManagerImplTest.java:
##
@@ -2279,22 +2277,23 @@ private MembershipManagerImpl
mockJoinA
chia7712 merged PR #15506:
URL: https://github.com/apache/kafka/pull/15506
--
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 code in PR #15511:
URL: https://github.com/apache/kafka/pull/15511#discussion_r1525386165
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/MembershipManagerImpl.java:
##
@@ -911,9 +911,13 @@ void maybeReconcile() {
SortedSet assi
[
https://issues.apache.org/jira/browse/KAFKA-16375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans updated KAFKA-16375:
---
Priority: Critical (was: Major)
> Fix logic for discarding reconciliation if member rejoine
lianetm commented on code in PR #15511:
URL: https://github.com/apache/kafka/pull/15511#discussion_r1525360383
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/MembershipManagerImpl.java:
##
@@ -988,7 +989,8 @@ long getExpirationTimeForTimeout(final long time
Lianet Magrans created KAFKA-16375:
--
Summary: Fix logic for discarding reconciliation if member rejoined
Key: KAFKA-16375
URL: https://issues.apache.org/jira/browse/KAFKA-16375
Project: Kafka
jolshan commented on PR #15454:
URL: https://github.com/apache/kafka/pull/15454#issuecomment-1998091660
Hmm. I was rerunning just to confirm.
--
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
mimaison merged PR #15454:
URL: https://github.com/apache/kafka/pull/15454
--
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
kphelps opened a new pull request, #15536:
URL: https://github.com/apache/kafka/pull/15536
When there is a commit for multiple topic partitions and some, but not all,
exceed the offset metadata limit, the pending commit is not properly cleaned up
leading to `UNSTABLE_OFFSET_COMMIT` errors w
mimaison commented on PR #15454:
URL: https://github.com/apache/kafka/pull/15454#issuecomment-1998016477
Test failures don't seem related (all passed locally), merging to trunk.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
lianetm opened a new pull request, #15535:
URL: https://github.com/apache/kafka/pull/15535
*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 testing
cadonna closed pull request #15531: MINOR: Change link to deprecated class to
substitute class
URL: https://github.com/apache/kafka/pull/15531
--
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 spe
cadonna commented on PR #15531:
URL: https://github.com/apache/kafka/pull/15531#issuecomment-1997917052
Closing because it does not make sense to only change a link when the rest
of the content is out-of-date.
--
This is an automated message from the Apache Git Service.
To respond to the
[
https://issues.apache.org/jira/browse/KAFKA-16373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17827162#comment-17827162
]
Kenneth Eversole commented on KAFKA-16373:
--
This already seems to have been don
VictorvandenHoven commented on code in PR #15510:
URL: https://github.com/apache/kafka/pull/15510#discussion_r1525144034
##
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamJoin.java:
##
@@ -223,9 +223,9 @@ private void emitNonJoinedOuterRecords(
VictorvandenHoven commented on code in PR #15510:
URL: https://github.com/apache/kafka/pull/15510#discussion_r1525144034
##
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamJoin.java:
##
@@ -223,9 +223,9 @@ private void emitNonJoinedOuterRecords(
[
https://issues.apache.org/jira/browse/KAFKA-16361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17827134#comment-17827134
]
BDeus edited comment on KAFKA-16361 at 3/14/24 3:47 PM:
Is it a
[
https://issues.apache.org/jira/browse/KAFKA-16361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17827134#comment-17827134
]
BDeus edited comment on KAFKA-16361 at 3/14/24 3:46 PM:
Is it a
[
https://issues.apache.org/jira/browse/KAFKA-16361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17827134#comment-17827134
]
BDeus commented on KAFKA-16361:
---
Is it a regression related to this ticket
https://issues
msn-tldr commented on PR #15498:
URL: https://github.com/apache/kafka/pull/15498#issuecomment-1997688081
@ijuma 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 specific comment.
To u
msn-tldr commented on PR #15493:
URL: https://github.com/apache/kafka/pull/15493#issuecomment-199768
@ijuma 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 specific comment.
To u
lucasbru commented on code in PR #15511:
URL: https://github.com/apache/kafka/pull/15511#discussion_r1524575611
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/MembershipManagerImpl.java:
##
@@ -1497,4 +1502,93 @@ public PollResult poll(final long currentTim
1 - 100 of 374 matches
Mail list logo