jeqo commented on code in PR #15324:
URL: https://github.com/apache/kafka/pull/15324#discussion_r1482430278
##
storage/src/main/java/org/apache/kafka/storage/internals/log/ProducerStateManager.java:
##
@@ -177,7 +177,7 @@ private void addProducerId(long producerId,
philipnee opened a new pull request, #15339:
URL: https://github.com/apache/kafka/pull/15339
Adding the following rebalance metrics to the consumer:
rebalance-latency-avg
rebalance-latency-max
rebalance-latency-total
rebalance-rate-per-hour
rebalance-total
github-actions[bot] commented on PR #14720:
URL: https://github.com/apache/kafka/pull/14720#issuecomment-1933309607
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
github-actions[bot] commented on PR #14721:
URL: https://github.com/apache/kafka/pull/14721#issuecomment-1933309585
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
highluck commented on code in PR #9786:
URL: https://github.com/apache/kafka/pull/9786#discussion_r1482300227
##
streams/src/main/java/org/apache/kafka/streams/kstream/internals/InternalStreamsBuilder.java:
##
@@ -437,7 +438,10 @@ private void rewriteSingleStoreSelfJoin(
highluck commented on PR #15295:
URL: https://github.com/apache/kafka/pull/15295#issuecomment-1933212514
Oh thank you! I'll fix it right away
--
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
highluck commented on PR #15301:
URL: https://github.com/apache/kafka/pull/15301#issuecomment-1933211994
@mimaison
thank you! Can I please merge it?
--
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
mberndt123 opened a new pull request, #15338:
URL: https://github.com/apache/kafka/pull/15338
A port of Kafka-Streams-Scala.
The code itself was almost entirely compatible, most of the work revolves
around the build system.
Because core doesn't yet support Scala 3, it's
rreddy-22 commented on PR #15150:
URL: https://github.com/apache/kafka/pull/15150#issuecomment-1933178128
Ran all the tests locally with changes from this patch
https://github.com/apache/kafka/pull/15311 and everything passes. Tests in
ListConsumerGroupTest that use the new "consumer"
rreddy-22 commented on code in PR #15150:
URL: https://github.com/apache/kafka/pull/15150#discussion_r1482258074
##
clients/src/test/java/org/apache/kafka/clients/admin/KafkaAdminClientTest.java:
##
@@ -2804,8 +2804,8 @@ public void testListConsumerGroupsWithStates() throws
rreddy-22 commented on code in PR #15150:
URL: https://github.com/apache/kafka/pull/15150#discussion_r1482258074
##
clients/src/test/java/org/apache/kafka/clients/admin/KafkaAdminClientTest.java:
##
@@ -2804,8 +2804,8 @@ public void testListConsumerGroupsWithStates() throws
rreddy-22 commented on code in PR #15150:
URL: https://github.com/apache/kafka/pull/15150#discussion_r1482157827
##
core/src/test/scala/unit/kafka/admin/ListConsumerGroupTest.scala:
##
@@ -18,44 +18,47 @@ package kafka.admin
import joptsimple.OptionException
import
rreddy-22 commented on code in PR #15150:
URL: https://github.com/apache/kafka/pull/15150#discussion_r1482168707
##
core/src/main/scala/kafka/admin/ConsumerGroupCommand.scala:
##
@@ -187,16 +197,69 @@ object ConsumerGroupCommand extends Logging {
}
def listGroups():
rreddy-22 commented on code in PR #15150:
URL: https://github.com/apache/kafka/pull/15150#discussion_r1482167679
##
core/src/main/scala/kafka/admin/ConsumerGroupCommand.scala:
##
@@ -189,16 +199,68 @@ object ConsumerGroupCommand extends Logging {
}
def listGroups():
rreddy-22 commented on code in PR #15150:
URL: https://github.com/apache/kafka/pull/15150#discussion_r1482157827
##
core/src/test/scala/unit/kafka/admin/ListConsumerGroupTest.scala:
##
@@ -18,44 +18,47 @@ package kafka.admin
import joptsimple.OptionException
import
jolshan commented on code in PR #15324:
URL: https://github.com/apache/kafka/pull/15324#discussion_r1482140038
##
storage/src/main/java/org/apache/kafka/storage/internals/log/ProducerStateManager.java:
##
@@ -177,7 +177,7 @@ private void addProducerId(long producerId,
jolshan commented on PR #15324:
URL: https://github.com/apache/kafka/pull/15324#issuecomment-1932990160
Also @jeqo -- just curious which java version were you running?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
rreddy-22 commented on code in PR #15150:
URL: https://github.com/apache/kafka/pull/15150#discussion_r1482112413
##
clients/src/main/java/org/apache/kafka/clients/admin/ConsumerGroupListing.java:
##
@@ -21,14 +21,16 @@
import java.util.Optional;
import
mumrah commented on PR #15306:
URL: https://github.com/apache/kafka/pull/15306#issuecomment-1932944727
@OmniaGM, the metrics changes were split out from my original PR into this
one. The commit from my closed PR just has the batch size change
[
https://issues.apache.org/jira/browse/KAFKA-16055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman reassigned KAFKA-16055:
--
Assignee: Kohei Nozaki (was: Kohei Nozaki)
> Thread unsafe use of
[
https://issues.apache.org/jira/browse/KAFKA-16055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman reassigned KAFKA-16055:
--
Assignee: Kohei Nozaki
> Thread unsafe use of HashMap stored in
[
https://issues.apache.org/jira/browse/KAFKA-16055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman updated KAFKA-16055:
---
Fix Version/s: 3.8.0
> Thread unsafe use of HashMap stored in
ableegoldman commented on PR #15121:
URL: https://github.com/apache/kafka/pull/15121#issuecomment-1932890035
Merged to trunk. Thanks for the fix!
--
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
ableegoldman merged PR #15121:
URL: https://github.com/apache/kafka/pull/15121
--
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:
cmccabe merged PR #15327:
URL: https://github.com/apache/kafka/pull/15327
--
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:
wcarlson5 opened a new pull request, #15337:
URL: https://github.com/apache/kafka/pull/15337
*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
[
https://issues.apache.org/jira/browse/KAFKA-16001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-16001:
-
Assignee: (was: Kirk True)
> Migrate ConsumerNetworkThreadTest away from
[
https://issues.apache.org/jira/browse/KAFKA-15638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15638:
--
Labels: consumer-threading-refactor timeout unit-tests (was:
consumer-threading-refactor unit-tests)
[
https://issues.apache.org/jira/browse/KAFKA-15615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-15615:
-
Assignee: (was: Kirk True)
> Improve handling of fetching during metadata updates
>
[
https://issues.apache.org/jira/browse/KAFKA-15639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-15639:
-
Assignee: (was: Kirk True)
> Investigate ConsumerNetworkThreadTest's
>
[
https://issues.apache.org/jira/browse/KAFKA-14747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17815424#comment-17815424
]
Ayoub Omari commented on KAFKA-14747:
-
I see that the ticket is open for a while. May I take it over
[
https://issues.apache.org/jira/browse/KAFKA-16156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-16156:
-
Assignee: Philip Nee
> System test failing for new consumer on endOffsets with negative
[
https://issues.apache.org/jira/browse/KAFKA-16178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-16178:
-
Assignee: Lianet Magrans (was: Philip Nee)
> AsyncKafkaConsumer doesn't retry joining the
[
https://issues.apache.org/jira/browse/KAFKA-15539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stanislav Kozlovski updated KAFKA-15539:
Fix Version/s: (was: 3.7.0)
> Client should stop fetching while partitions
[
https://issues.apache.org/jira/browse/KAFKA-15631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stanislav Kozlovski updated KAFKA-15631:
Fix Version/s: (was: 3.7.0)
> Do not send new heartbeat request while another
[
https://issues.apache.org/jira/browse/KAFKA-15540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stanislav Kozlovski updated KAFKA-15540:
Fix Version/s: (was: 3.7.0)
> Handle heartbeat and revocation when consumer
[
https://issues.apache.org/jira/browse/KAFKA-15543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stanislav Kozlovski updated KAFKA-15543:
Fix Version/s: (was: 3.7.0)
> Send HB request right after reconciliation
[
https://issues.apache.org/jira/browse/KAFKA-15573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stanislav Kozlovski updated KAFKA-15573:
Fix Version/s: (was: 3.7.0)
> Implement auto-commit on partition assignment
[
https://issues.apache.org/jira/browse/KAFKA-15592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stanislav Kozlovski updated KAFKA-15592:
Fix Version/s: (was: 3.7.0)
> Member does not need to always try to join a
[
https://issues.apache.org/jira/browse/KAFKA-15515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stanislav Kozlovski updated KAFKA-15515:
Fix Version/s: (was: 3.7.0)
> Remove duplicated integration tests for new
[
https://issues.apache.org/jira/browse/KAFKA-15651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stanislav Kozlovski updated KAFKA-15651:
Fix Version/s: (was: 3.7.0)
> Investigate auto commit guarantees during
[
https://issues.apache.org/jira/browse/KAFKA-15694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stanislav Kozlovski updated KAFKA-15694:
Fix Version/s: (was: 3.7.0)
> New integration tests to have full coverage for
[
https://issues.apache.org/jira/browse/KAFKA-15840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stanislav Kozlovski updated KAFKA-15840:
Fix Version/s: (was: 3.7.0)
> Correct initialization of
[
https://issues.apache.org/jira/browse/KAFKA-15694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stanislav Kozlovski updated KAFKA-15694:
Description:
These are to fix bugs discovered during PR reviews but not tests.
[
https://issues.apache.org/jira/browse/KAFKA-16121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stanislav Kozlovski updated KAFKA-16121:
Fix Version/s: (was: 3.7.0)
> Partition reassignments in ZK migration dual
[
https://issues.apache.org/jira/browse/KAFKA-16121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stanislav Kozlovski closed KAFKA-16121.
---
> Partition reassignments in ZK migration dual write mode stalled until leader
> epoch
[
https://issues.apache.org/jira/browse/KAFKA-15539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stanislav Kozlovski closed KAFKA-15539.
---
> Client should stop fetching while partitions being revoked
>
[
https://issues.apache.org/jira/browse/KAFKA-15515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stanislav Kozlovski closed KAFKA-15515.
---
> Remove duplicated integration tests for new consumer
>
[
https://issues.apache.org/jira/browse/KAFKA-15543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stanislav Kozlovski closed KAFKA-15543.
---
> Send HB request right after reconciliation completes
>
[
https://issues.apache.org/jira/browse/KAFKA-15631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stanislav Kozlovski closed KAFKA-15631.
---
> Do not send new heartbeat request while another one in-flight
>
[
https://issues.apache.org/jira/browse/KAFKA-15573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stanislav Kozlovski closed KAFKA-15573.
---
> Implement auto-commit on partition assignment revocation
>
[
https://issues.apache.org/jira/browse/KAFKA-15592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stanislav Kozlovski closed KAFKA-15592.
---
> Member does not need to always try to join a group when a groupId is
> configured
>
[
https://issues.apache.org/jira/browse/KAFKA-16121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17815421#comment-17815421
]
Stanislav Kozlovski commented on KAFKA-16121:
-
Marked as closed in order to be able to build
[
https://issues.apache.org/jira/browse/KAFKA-15840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stanislav Kozlovski closed KAFKA-15840.
---
> Correct initialization of ConsumerGroupHeartbeat by client
>
[
https://issues.apache.org/jira/browse/KAFKA-16121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stanislav Kozlovski closed KAFKA-16121.
---
> Partition reassignments in ZK migration dual write mode stalled until leader
> epoch
rreddy-22 commented on code in PR #15150:
URL: https://github.com/apache/kafka/pull/15150#discussion_r1482012622
##
clients/src/main/java/org/apache/kafka/clients/admin/ConsumerGroupListing.java:
##
@@ -68,48 +97,44 @@ public boolean isSimpleConsumerGroup() {
}
/**
rreddy-22 commented on code in PR #15150:
URL: https://github.com/apache/kafka/pull/15150#discussion_r1481994449
##
core/src/test/scala/unit/kafka/admin/ListConsumerGroupTest.scala:
##
@@ -64,28 +64,89 @@ class ListConsumerGroupTest extends
ConsumerGroupCommandTest {
val
gharris1727 commented on code in PR #15313:
URL: https://github.com/apache/kafka/pull/15313#discussion_r1481920004
##
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerSinkTaskMockitoTest.java:
##
@@ -343,6 +354,103 @@ public void testShutdown() throws
cmccabe commented on PR #15327:
URL: https://github.com/apache/kafka/pull/15327#issuecomment-193270
Thanks, @mumrah . It looks good. One comment: it seems like any error log
being issued should fail any junit test, unless it’s expected, right?
--
This is an automated message from the
[
https://issues.apache.org/jira/browse/KAFKA-16235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17815407#comment-17815407
]
Ryan Leslie commented on KAFKA-16235:
-
Linked related JIRAs.
> auto commit still causes delays due
Ryan Leslie created KAFKA-16235:
---
Summary: auto commit still causes delays due to retriable
UNKNOWN_TOPIC_OR_PARTITION
Key: KAFKA-16235
URL: https://issues.apache.org/jira/browse/KAFKA-16235
Project:
[
https://issues.apache.org/jira/browse/KAFKA-16233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16233:
--
Labels: consumer-threading-refactor (was: )
> Review auto-commit continuously committing when no
[
https://issues.apache.org/jira/browse/KAFKA-14920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Justine Olshan updated KAFKA-14920:
---
Description:
KAFKA-14844 showed the destructive nature of a timeout on the first produce
[
https://issues.apache.org/jira/browse/KAFKA-13292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17815404#comment-17815404
]
Matthias J. Sax commented on KAFKA-13292:
-
Sounds like a question about Spring... For a plain
[
https://issues.apache.org/jira/browse/KAFKA-16234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17815403#comment-17815403
]
Gaurav Narula commented on KAFKA-16234:
---
Perhaps a way to solve this would be to determine if a
hachikuji commented on code in PR #15323:
URL: https://github.com/apache/kafka/pull/15323#discussion_r1481936087
##
clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordAccumulator.java:
##
@@ -647,27 +647,27 @@ private long batchReady(boolean exhausted,
[
https://issues.apache.org/jira/browse/KAFKA-16217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17815402#comment-17815402
]
Calvin Liu commented on KAFKA-16217:
[~kirktrue] I have a UT which simulate the close issue
CalvinConfluent opened a new pull request, #15336:
URL: https://github.com/apache/kafka/pull/15336
A UT to repro the bug in https://issues.apache.org/jira/browse/KAFKA-16217
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
[
https://issues.apache.org/jira/browse/KAFKA-16234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17815397#comment-17815397
]
Gaurav Narula commented on KAFKA-16234:
---
This gets trickier because {{LogManager::loadLog}} reads
gharris1727 commented on code in PR #14995:
URL: https://github.com/apache/kafka/pull/14995#discussion_r1481872234
##
clients/src/test/java/org/apache/kafka/common/config/provider/MockFileConfigProvider.java:
##
@@ -42,10 +43,12 @@ public void configure(Map configs) {
OmniaGM opened a new pull request, #15335:
URL: https://github.com/apache/kafka/pull/15335
This pr fixes the bug created by #15263 which caused topic partition to be
recreated whenever the original log dir is offline.
I believe the bug #15263 was trying to fix is more rare to happened
[
https://issues.apache.org/jira/browse/KAFKA-15467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17815385#comment-17815385
]
Steve Jacobs commented on KAFKA-15467:
--
The way to reproduce this is an unclean shutdown of the
hachikuji commented on code in PR #15323:
URL: https://github.com/apache/kafka/pull/15323#discussion_r1481854476
##
clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordAccumulator.java:
##
@@ -647,27 +647,27 @@ private long batchReady(boolean exhausted,
mberndt123 commented on PR #15239:
URL: https://github.com/apache/kafka/pull/15239#issuecomment-1932541985
> Do we want to remove it from streams only or also for core?
I've tried that and thought it worked because of a silly mistake that I
made. But `core` actually needs it, so it
mimaison commented on code in PR #14631:
URL: https://github.com/apache/kafka/pull/14631#discussion_r1481826420
##
docs/ops.html:
##
@@ -3819,6 +3819,12 @@ Provisioning the KRaft controller quorum
# ZooKeeper client configuration
zookeeper.connect=localhost:2181
+# The
mimaison commented on PR #10983:
URL: https://github.com/apache/kafka/pull/10983#issuecomment-1932493933
@showuon I pushed a commit to tweak this section. Can you take another look?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
satishd commented on code in PR #15213:
URL: https://github.com/apache/kafka/pull/15213#discussion_r1481778242
##
core/src/main/scala/kafka/log/UnifiedLog.scala:
##
@@ -1300,18 +1301,29 @@ class UnifiedLog(@volatile var logStartOffset: Long,
} else if (targetTimestamp ==
jeqo commented on PR #15324:
URL: https://github.com/apache/kafka/pull/15324#issuecomment-1932429115
@jolshan sure! I just added it
--
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
msn-tldr commented on PR #15323:
URL: https://github.com/apache/kafka/pull/15323#issuecomment-1932366816
@hachikuji
There are unrelated test failures on Jenkins run. Further looking at history
of failed tests, they have been failing from before.
[
https://issues.apache.org/jira/browse/KAFKA-16234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gaurav Narula updated KAFKA-16234:
--
Description:
With [KAFKA-16157|https://github.com/apache/kafka/pull/15263] we made changes
[
https://issues.apache.org/jira/browse/KAFKA-16234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gaurav Narula reassigned KAFKA-16234:
-
Assignee: Omnia Ibrahim
> Log directory failure re-creates partitions in another
[
https://issues.apache.org/jira/browse/KAFKA-16234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gaurav Narula updated KAFKA-16234:
--
Description:
With [KAFKA-16157|https://github.com/apache/kafka/pull/15263] we made changes
Gaurav Narula created KAFKA-16234:
-
Summary: Log directory failure re-creates partitions in another
logdir automatically
Key: KAFKA-16234
URL: https://issues.apache.org/jira/browse/KAFKA-16234
ijuma commented on code in PR #10826:
URL: https://github.com/apache/kafka/pull/10826#discussion_r850506417
##
clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java:
##
@@ -188,6 +190,12 @@ public class ProducerConfig extends AbstractConfig {
clolov commented on PR #15261:
URL: https://github.com/apache/kafka/pull/15261#issuecomment-1932183121
Heya @cadonna, apologies for the delay. I am not certain I fully understand
the comments, so I wanted to confirm before making changes. The purpose of this
pull request is to just migrate
clolov commented on code in PR #15261:
URL: https://github.com/apache/kafka/pull/15261#discussion_r1481566534
##
streams/src/test/java/org/apache/kafka/streams/processor/internals/TaskManagerTest.java:
##
@@ -2016,13 +2015,14 @@ public void
clolov commented on code in PR #15261:
URL: https://github.com/apache/kafka/pull/15261#discussion_r1481561763
##
streams/src/test/java/org/apache/kafka/streams/processor/internals/TaskManagerTest.java:
##
@@ -2399,7 +2393,8 @@ public void
clolov commented on code in PR #15261:
URL: https://github.com/apache/kafka/pull/15261#discussion_r1481561392
##
streams/src/test/java/org/apache/kafka/streams/processor/internals/TaskManagerTest.java:
##
@@ -2332,19 +2335,12 @@ public void
clolov commented on code in PR #15261:
URL: https://github.com/apache/kafka/pull/15261#discussion_r1481560896
##
streams/src/test/java/org/apache/kafka/streams/processor/internals/TaskManagerTest.java:
##
@@ -2210,6 +2210,9 @@ public void shouldComputeOffsetSumForStandbyTask()
clolov commented on code in PR #15261:
URL: https://github.com/apache/kafka/pull/15261#discussion_r1481557433
##
streams/src/test/java/org/apache/kafka/streams/processor/internals/TaskManagerTest.java:
##
@@ -2369,12 +2366,9 @@ public void closeClean() {
}
clolov commented on code in PR #15261:
URL: https://github.com/apache/kafka/pull/15261#discussion_r1481556951
##
streams/src/test/java/org/apache/kafka/streams/processor/internals/TaskManagerTest.java:
##
@@ -2332,19 +2335,12 @@ public void
clolov commented on code in PR #15261:
URL: https://github.com/apache/kafka/pull/15261#discussion_r1481555805
##
streams/src/test/java/org/apache/kafka/streams/processor/internals/TaskManagerTest.java:
##
@@ -4821,8 +4911,10 @@ private Map
handleAssignment(final Map assignment
[
https://issues.apache.org/jira/browse/KAFKA-16224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans updated KAFKA-16224:
---
Description:
Current logic for auto-committing offsets when partitions are revoked will
clolov commented on PR #15213:
URL: https://github.com/apache/kafka/pull/15213#issuecomment-1932149971
Heya @showuon @kamalcph @satishd, I hope I have addressed the latest
comments!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
Lianet Magrans created KAFKA-16233:
--
Summary: Review auto-commit continuously committing when no
progress
Key: KAFKA-16233
URL: https://issues.apache.org/jira/browse/KAFKA-16233
Project: Kafka
clolov commented on code in PR #15213:
URL: https://github.com/apache/kafka/pull/15213#discussion_r1481540437
##
core/src/main/scala/kafka/log/UnifiedLog.scala:
##
@@ -1300,18 +1301,29 @@ class UnifiedLog(@volatile var logStartOffset: Long,
} else if (targetTimestamp ==
msn-tldr commented on code in PR #15323:
URL: https://github.com/apache/kafka/pull/15323#discussion_r1481455003
##
clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordAccumulator.java:
##
@@ -647,27 +647,27 @@ private long batchReady(boolean exhausted,
[
https://issues.apache.org/jira/browse/KAFKA-16226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mayank Shekhar Narula updated KAFKA-16226:
--
Description:
h1. Background
[
https://issues.apache.org/jira/browse/KAFKA-15824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mayank Shekhar Narula updated KAFKA-15824:
--
Description:
As can be
[
https://issues.apache.org/jira/browse/KAFKA-15824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mayank Shekhar Narula updated KAFKA-15824:
--
Description:
As can be
1 - 100 of 122 matches
Mail list logo
