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
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.
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
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:
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
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
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
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
[
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:
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
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:
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
[
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
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 &&
[
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
>
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
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
[
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
[
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
[
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
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
[
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
>
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:
[
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
>
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
Chia-Ping Tsai created KAFKA-16377:
--
Summary: Fix flaky
HighAvailabilityTaskAssignorIntegrationTest.shouldScaleOutWithWarmupTasksAndPersistentStores
Key: KAFKA-16377
URL:
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
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
[
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
[
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
[
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
[
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
[
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
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
[
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
[
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)
>
[
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
[
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
[
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
[
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}}
[
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
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
[
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
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
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
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
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:
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
[
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
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
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:
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
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
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
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=17827162#comment-17827162
]
Kenneth Eversole commented on KAFKA-16373:
--
This already seems to have been done in a previous
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=17827134#comment-17827134
]
BDeus edited comment on KAFKA-16361 at 3/14/24 3:47 PM:
Is it a regression
[
https://issues.apache.org/jira/browse/KAFKA-16361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17827134#comment-17827134
]
BDeus edited comment on KAFKA-16361 at 3/14/24 3:46 PM:
Is it a regression
[
https://issues.apache.org/jira/browse/KAFKA-16361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17827134#comment-17827134
]
BDeus commented on KAFKA-16361:
---
Is it a regression related to this ticket
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
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
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
[
https://issues.apache.org/jira/browse/KAFKA-16180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Arthur resolved KAFKA-16180.
--
Resolution: Fixed
> Full metadata request sometimes fails during zk migration
>
[
https://issues.apache.org/jira/browse/KAFKA-16180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Arthur updated KAFKA-16180:
-
Fix Version/s: 3.6.2
3.7.0
> Full metadata request sometimes fails during zk
[
https://issues.apache.org/jira/browse/KAFKA-16372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haruki Okada updated KAFKA-16372:
-
Description:
As of Kafka 3.7.0, the javadoc of
[
https://issues.apache.org/jira/browse/KAFKA-16369?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17827107#comment-17827107
]
Edoardo Comar commented on KAFKA-16369:
---
PR is ready for review - can anyone take a look please ?
1 - 100 of 371 matches
Mail list logo
