iit2009060 commented on code in PR #14482:
URL: https://github.com/apache/kafka/pull/14482#discussion_r1346817006
##
core/src/test/scala/unit/kafka/log/remote/RemoteIndexCacheTest.scala:
##
@@ -541,6 +542,131 @@ class RemoteIndexCacheTest {
verifyFetchIndexInvocation(count
showuon commented on code in PR #14482:
URL: https://github.com/apache/kafka/pull/14482#discussion_r1346739560
##
core/src/test/scala/unit/kafka/log/remote/RemoteIndexCacheTest.scala:
##
@@ -541,6 +542,131 @@ class RemoteIndexCacheTest {
verifyFetchIndexInvocation(count =
showuon commented on code in PR #14482:
URL: https://github.com/apache/kafka/pull/14482#discussion_r1346739560
##
core/src/test/scala/unit/kafka/log/remote/RemoteIndexCacheTest.scala:
##
@@ -541,6 +542,131 @@ class RemoteIndexCacheTest {
verifyFetchIndexInvocation(count =
showuon commented on PR #14488:
URL: https://github.com/apache/kafka/pull/14488#issuecomment-1748033933
@satishd , we need to wait until someone in Confluent help upload the
artifacts , then merge it. So, you should go ahead with the release process and
do this afterwards.
--
This is an
[
https://issues.apache.org/jira/browse/KAFKA-15547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yash Mayya updated KAFKA-15547:
---
Issue Type: Test (was: Bug)
> Thread leak in MirrorMakerConfigTest#testClientConfigProperties
>
[
https://issues.apache.org/jira/browse/KAFKA-15547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yash Mayya resolved KAFKA-15547.
Fix Version/s: 3.7.0
Resolution: Fixed
> Thread leak in
yashmayya merged PR #14487:
URL: https://github.com/apache/kafka/pull/14487
--
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:
yashmayya commented on PR #14487:
URL: https://github.com/apache/kafka/pull/14487#issuecomment-1748025828
Test failures are unrelated, merging to `trunk`.
--
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-15541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17772072#comment-17772072
]
Matthias J. Sax commented on KAFKA-15541:
-
Did not read the KIP yet, but sound very similar to
soarez commented on PR #14291:
URL: https://github.com/apache/kafka/pull/14291#issuecomment-1747977220
Thank you for the reviews @rondagostino and @pprovenzano.
I've addressed the suggestions, and also made the changes discussed earlier:
* Introduce a third reserved UUID
*
[
https://issues.apache.org/jira/browse/KAFKA-14941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17772048#comment-17772048
]
Luke Chen commented on KAFKA-14941:
---
Great! I'm working on the list, will let you know when completed.
kirktrue commented on code in PR #14406:
URL: https://github.com/apache/kafka/pull/14406#discussion_r1346616646
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/PrototypeAsyncConsumer.java:
##
@@ -621,56 +825,174 @@ public void assign(Collection
partitions)
kirktrue commented on code in PR #14406:
URL: https://github.com/apache/kafka/pull/14406#discussion_r1346616102
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/FetchRequestManagerTest.java:
##
@@ -0,0 +1,3565 @@
+/*
+ * Licensed to the Apache Software
kirktrue commented on code in PR #14406:
URL: https://github.com/apache/kafka/pull/14406#discussion_r1346615044
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractFetch.java:
##
@@ -92,6 +88,23 @@ public AbstractFetch(final LogContext logContext,
kirktrue commented on code in PR #14406:
URL: https://github.com/apache/kafka/pull/14406#discussion_r1346613925
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/PrototypeAsyncConsumer.java:
##
@@ -622,12 +837,18 @@ public void assign(Collection partitions)
kirktrue commented on code in PR #14406:
URL: https://github.com/apache/kafka/pull/14406#discussion_r1346612374
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/PrototypeAsyncConsumer.java:
##
@@ -192,71 +321,38 @@ public PrototypeAsyncConsumer(final
jeffkbkim commented on code in PR #14417:
URL: https://github.com/apache/kafka/pull/14417#discussion_r1346610016
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/metrics/CoordinatorRuntimeMetrics.java:
##
@@ -0,0 +1,100 @@
+/*
+ * Licensed to the Apache
jeffkbkim commented on code in PR #14417:
URL: https://github.com/apache/kafka/pull/14417#discussion_r1346608656
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/runtime/CoordinatorRuntime.java:
##
@@ -156,15 +165,16 @@ public CoordinatorRuntime build() {
jeffkbkim commented on code in PR #14417:
URL: https://github.com/apache/kafka/pull/14417#discussion_r1346607275
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/metrics/GroupCoordinatorRuntimeMetrics.java:
##
@@ -0,0 +1,353 @@
+/*
+ * Licensed to the
kirktrue commented on code in PR #14406:
URL: https://github.com/apache/kafka/pull/14406#discussion_r1346607807
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/FetchRequestManager.java:
##
@@ -0,0 +1,136 @@
+/*
+ * Licensed to the Apache Software Foundation
kirktrue commented on code in PR #14406:
URL: https://github.com/apache/kafka/pull/14406#discussion_r1346606932
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/Fetcher.java:
##
@@ -106,7 +127,62 @@ public void onFailure(RuntimeException e) {
return
kirktrue commented on code in PR #14406:
URL: https://github.com/apache/kafka/pull/14406#discussion_r1346606768
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/ApplicationEventHandler.java:
##
@@ -0,0 +1,122 @@
+/*
+ * Licensed to the Apache Software
jolshan commented on code in PR #14489:
URL: https://github.com/apache/kafka/pull/14489#discussion_r1346606122
##
core/src/main/scala/kafka/coordinator/transaction/TransactionMetadata.scala:
##
@@ -375,7 +375,7 @@ private[transaction] class TransactionMetadata(val
kirktrue commented on code in PR #14406:
URL: https://github.com/apache/kafka/pull/14406#discussion_r1346604856
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/BackgroundEventHandler.java:
##
@@ -0,0 +1,52 @@
+/*
+ * Licensed to the Apache Software
jolshan opened a new pull request, #14489:
URL: https://github.com/apache/kafka/pull/14489
This PR has two parts:
1. Redefining the TopicDelta fields to better distinguish when a leader is
elected (leader epoch bump) vs when a leader has isr/replica changes (partition
epoch bump).
jeffkbkim commented on code in PR #14417:
URL: https://github.com/apache/kafka/pull/14417#discussion_r1346600021
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/metrics/CoordinatorRuntimeMetrics.java:
##
@@ -0,0 +1,100 @@
+/*
+ * Licensed to the Apache
jeffkbkim commented on code in PR #14417:
URL: https://github.com/apache/kafka/pull/14417#discussion_r1346596121
##
core/src/test/scala/unit/kafka/coordinator/group/CoordinatorLoaderImplTest.scala:
##
@@ -283,7 +292,63 @@ class CoordinatorLoaderImplTest {
minOneMessage
kpatelatwork commented on PR #14487:
URL: https://github.com/apache/kafka/pull/14487#issuecomment-1747775381
below test failures are only in the Scala 2.13 build and unrelated to this
change
```
QuorumControllerTest > testBrokerHeartbeatDuringMigration(MetadataVersion) >
[1] 3.4-IV0
kirktrue commented on code in PR #14406:
URL: https://github.com/apache/kafka/pull/14406#discussion_r1346546088
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/PrototypeAsyncConsumer.java:
##
@@ -621,56 +825,174 @@ public void assign(Collection
partitions)
kirktrue commented on code in PR #14406:
URL: https://github.com/apache/kafka/pull/14406#discussion_r1346545044
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/FetchBuffer.java:
##
@@ -37,7 +36,7 @@
*
* Note: this class is not thread-safe and is
kirktrue commented on code in PR #14406:
URL: https://github.com/apache/kafka/pull/14406#discussion_r1346517075
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/PrototypeAsyncConsumer.java:
##
@@ -621,56 +825,174 @@ public void assign(Collection
partitions)
kirktrue commented on code in PR #14406:
URL: https://github.com/apache/kafka/pull/14406#discussion_r1346508562
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/PrototypeAsyncConsumer.java:
##
@@ -693,15 +1015,14 @@ private boolean
kirktrue commented on code in PR #14406:
URL: https://github.com/apache/kafka/pull/14406#discussion_r1346504058
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/FetchRequestManager.java:
##
@@ -0,0 +1,186 @@
+/*
+ * Licensed to the Apache Software Foundation
philipnee commented on code in PR #14406:
URL: https://github.com/apache/kafka/pull/14406#discussion_r1346493970
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/Fetcher.java:
##
@@ -106,7 +127,62 @@ public void onFailure(RuntimeException e) {
philipnee commented on PR #14364:
URL: https://github.com/apache/kafka/pull/14364#issuecomment-1747674288
Thanks @dajac - I refactored some tests based on your comments. Thanks a lot
for putting time into it. Here I've got a list of Jira for the follow-ups:
- Propagate time during
[
https://issues.apache.org/jira/browse/KAFKA-15548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Philip Nee updated KAFKA-15548:
---
Parent: KAFKA-14246
Issue Type: Sub-task (was: Bug)
> Handling close() properly
>
Philip Nee created KAFKA-15548:
--
Summary: Handling close() properly
Key: KAFKA-15548
URL: https://issues.apache.org/jira/browse/KAFKA-15548
Project: Kafka
Issue Type: Bug
Components:
philipnee commented on code in PR #14364:
URL: https://github.com/apache/kafka/pull/14364#discussion_r1346463825
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestManagerTest.java:
##
@@ -0,0 +1,346 @@
+/*
+ * Licensed to the Apache Software
satishd opened a new pull request, #14488:
URL: https://github.com/apache/kafka/pull/14488
Added version 3.6.0 to system tests.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ]
jolshan merged PR #14480:
URL: https://github.com/apache/kafka/pull/14480
--
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:
jolshan commented on PR #14480:
URL: https://github.com/apache/kafka/pull/14480#issuecomment-1747589664
Tests are unrelated It is a bit worrying we see this large number of
failures in Java 11 from time to time.
I may follow up later.
--
This is an automated message from the Apache
rondagostino commented on code in PR #14291:
URL: https://github.com/apache/kafka/pull/14291#discussion_r1346212521
##
clients/src/main/java/org/apache/kafka/common/Uuid.java:
##
@@ -27,16 +30,33 @@
*/
public class Uuid implements Comparable {
+/**
+ * A reserved
kpatelatwork opened a new pull request, #14487:
URL: https://github.com/apache/kafka/pull/14487
The test MirrorMakerConfigTest#testClientConfigProperties` creates a
`ForwardingAdmin` but needs to use `try-with-resources` statement to ensure the
Admin client is closed
### Committer
kpatelatwork commented on PR #14487:
URL: https://github.com/apache/kafka/pull/14487#issuecomment-1747424669
Hey @yashmayya would you be able to review this change?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
kirktrue commented on code in PR #14406:
URL: https://github.com/apache/kafka/pull/14406#discussion_r1346278813
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/BackgroundEventProcessor.java:
##
@@ -0,0 +1,77 @@
+/*
+ * Licensed to the Apache Software
kirktrue commented on code in PR #14406:
URL: https://github.com/apache/kafka/pull/14406#discussion_r1346270372
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/DefaultBackgroundThread.java:
##
@@ -222,58 +99,158 @@ public void run() {
} catch
[
https://issues.apache.org/jira/browse/KAFKA-15547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kalpesh Patel reassigned KAFKA-15547:
-
Assignee: Kalpesh Patel
> Thread leak in
Kalpesh Patel created KAFKA-15547:
-
Summary: Thread leak in
MirrorMakerConfigTest#testClientConfigProperties
Key: KAFKA-15547
URL: https://issues.apache.org/jira/browse/KAFKA-15547
Project: Kafka
philipnee commented on code in PR #14364:
URL: https://github.com/apache/kafka/pull/14364#discussion_r1346258637
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestManagerTest.java:
##
@@ -0,0 +1,346 @@
+/*
+ * Licensed to the Apache Software
msn-tldr commented on code in PR #1:
URL: https://github.com/apache/kafka/pull/1#discussion_r1346257999
##
clients/src/main/resources/common/message/FetchRequest.json:
##
@@ -53,7 +53,9 @@
//
// Version 15 adds the ReplicaState which includes new field
philipnee commented on code in PR #14364:
URL: https://github.com/apache/kafka/pull/14364#discussion_r1346245842
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestManagerTest.java:
##
@@ -0,0 +1,346 @@
+/*
+ * Licensed to the Apache Software
philipnee commented on code in PR #14364:
URL: https://github.com/apache/kafka/pull/14364#discussion_r1346244285
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestManagerTest.java:
##
@@ -0,0 +1,346 @@
+/*
+ * Licensed to the Apache Software
chb2ab commented on code in PR #1:
URL: https://github.com/apache/kafka/pull/1#discussion_r1346244195
##
clients/src/main/java/org/apache/kafka/common/requests/FetchResponse.java:
##
@@ -276,11 +289,16 @@ private static FetchResponseData toMessage(Errors error,
[
https://issues.apache.org/jira/browse/KAFKA-15530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17771948#comment-17771948
]
ASF GitHub Bot commented on KAFKA-15530:
jolshan opened a new pull request, #555:
URL:
philipnee commented on code in PR #14364:
URL: https://github.com/apache/kafka/pull/14364#discussion_r1346233433
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestManagerTest.java:
##
@@ -0,0 +1,346 @@
+/*
+ * Licensed to the Apache Software
kirktrue commented on code in PR #14406:
URL: https://github.com/apache/kafka/pull/14406#discussion_r1346234546
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/DefaultBackgroundThread.java:
##
@@ -222,58 +99,158 @@ public void run() {
} catch
Justine Olshan created KAFKA-15546:
--
Summary: Transactions tool duration field confusing for completed
transactions
Key: KAFKA-15546
URL: https://issues.apache.org/jira/browse/KAFKA-15546
Project:
mjsax commented on PR #13983:
URL: https://github.com/apache/kafka/pull/13983#issuecomment-1747335866
Just discovered this PR -- Seems it part of KIP-906, but the KIP does not
cover the renaming of the method -- it's technically a breaking change...
Given that `StreamsResetter` is
sangyongchoi commented on PR #14423:
URL: https://github.com/apache/kafka/pull/14423#issuecomment-1747310104
@vamossagar12
1. If I find it while looking at the sauce, I will add it.
2. I do
--
This is an automated message from the Apache Git Service.
To respond to the message,
dongnuo123 commented on code in PR #14462:
URL: https://github.com/apache/kafka/pull/14462#discussion_r1346196993
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java:
##
@@ -8686,6 +8695,88 @@ public void testListGroups() {
dongnuo123 commented on code in PR #14462:
URL: https://github.com/apache/kafka/pull/14462#discussion_r1346196163
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java:
##
@@ -521,6 +575,31 @@ GenericGroup getOrMaybeCreateGenericGroup(
[
https://issues.apache.org/jira/browse/KAFKA-14761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14761:
--
Parent: KAFKA-14246
Issue Type: Sub-task (was: Task)
> Integration Tests for the New
[
https://issues.apache.org/jira/browse/KAFKA-14875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14875:
--
Parent: KAFKA-14246
Issue Type: Sub-task (was: Task)
> Implement Wakeup()
>
[
https://issues.apache.org/jira/browse/KAFKA-15277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15277:
--
Parent: KAFKA-14246
Issue Type: Sub-task (was: Task)
> Design & implement support for
[
https://issues.apache.org/jira/browse/KAFKA-15304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15304:
--
Parent: KAFKA-14246
Issue Type: Sub-task (was: Bug)
> CompletableApplicationEvents aren't
[
https://issues.apache.org/jira/browse/KAFKA-14960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14960:
--
Parent: KAFKA-14246
Issue Type: Sub-task (was: Task)
> Metadata Request Manager and
[
https://issues.apache.org/jira/browse/KAFKA-15180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15180:
--
Parent: KAFKA-14246
Issue Type: Sub-task (was: Test)
> Generalize integration tests to
[
https://issues.apache.org/jira/browse/KAFKA-15284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15284:
--
Parent: KAFKA-14246
Issue Type: Sub-task (was: Task)
> Implement
msn-tldr commented on code in PR #14384:
URL: https://github.com/apache/kafka/pull/14384#discussion_r1346188807
##
clients/src/test/java/org/apache/kafka/clients/producer/internals/SenderTest.java:
##
@@ -3146,6 +3149,97 @@ public void testInvalidTxnStateIsAnAbortableError()
[
https://issues.apache.org/jira/browse/KAFKA-14965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14965:
--
Parent: KAFKA-14246
Issue Type: Sub-task (was: Task)
> Introduce OffsetsRequestManager to
[
https://issues.apache.org/jira/browse/KAFKA-15081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15081:
--
Parent: KAFKA-14246
Issue Type: Sub-task (was: Task)
> Implement new consumer
[
https://issues.apache.org/jira/browse/KAFKA-14848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14848:
--
Parent: KAFKA-14246
Issue Type: Sub-task (was: Bug)
> KafkaConsumer incorrectly passes
[
https://issues.apache.org/jira/browse/KAFKA-14274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14274:
--
Parent: KAFKA-14246
Issue Type: Sub-task (was: Task)
> Introduce FetchRequestManager to
[
https://issues.apache.org/jira/browse/KAFKA-15173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15173:
--
Parent: KAFKA-14246
Issue Type: Sub-task (was: Task)
> Consumer event queues should be
[
https://issues.apache.org/jira/browse/KAFKA-14724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14724:
--
Parent: KAFKA-14246
Issue Type: Sub-task (was: Task)
> Port tests in FetcherTest to
[
https://issues.apache.org/jira/browse/KAFKA-14937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14937:
--
Parent: KAFKA-14246
Issue Type: Sub-task (was: Improvement)
> Refactoring for client code to
[
https://issues.apache.org/jira/browse/KAFKA-14966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14966:
--
Parent: KAFKA-14246
Issue Type: Sub-task (was: Task)
> Extract reusable logic from
[
https://issues.apache.org/jira/browse/KAFKA-15320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15320:
--
Parent: KAFKA-14246
Issue Type: Sub-task (was: Task)
> Document event queueing patterns
>
[
https://issues.apache.org/jira/browse/KAFKA-14675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14675:
--
Parent: KAFKA-14246
Issue Type: Sub-task (was: Task)
> Extract metadata-related tasks from
[
https://issues.apache.org/jira/browse/KAFKA-15320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15320:
--
Parent: (was: KAFKA-15173)
Issue Type: Task (was: Sub-task)
> Document event queueing
yashmayya commented on PR #14486:
URL: https://github.com/apache/kafka/pull/14486#issuecomment-1747287584
Mentioning the newly added collaborators here as an FYI - @kamalcph @hudeqi
@lihaosky @jeffkbkim @tinaselenge
You can check out the `Collaborators` section on
[
https://issues.apache.org/jira/browse/KAFKA-14758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14758:
--
Parent: KAFKA-14246
Issue Type: Sub-task (was: Task)
> Extract inner classes from Fetcher
[
https://issues.apache.org/jira/browse/KAFKA-14365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14365:
--
Parent: KAFKA-14246
Issue Type: Sub-task (was: Task)
> Extract common logic from Fetcher
>
yashmayya merged PR #14486:
URL: https://github.com/apache/kafka/pull/14486
--
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-15184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15184:
--
Parent: KAFKA-14246
Issue Type: Sub-task (was: Task)
> New consumer internals refactoring
[
https://issues.apache.org/jira/browse/KAFKA-15188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15188:
--
Parent: KAFKA-14246
Issue Type: Sub-task (was: Task)
> Implement more of the remaining
[
https://issues.apache.org/jira/browse/KAFKA-15316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15316:
--
Parent: KAFKA-14246
Issue Type: Sub-task (was: Bug)
> CommitRequestManager not calling
[
https://issues.apache.org/jira/browse/KAFKA-15281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15281:
--
Parent: KAFKA-14246
Issue Type: Sub-task (was: Task)
> Implement the groupMetadata Consumer
[
https://issues.apache.org/jira/browse/KAFKA-15317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15317:
--
Parent: KAFKA-14246
Issue Type: Sub-task (was: Task)
> Fix for async consumer access to
[
https://issues.apache.org/jira/browse/KAFKA-15515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15515:
--
Parent: KAFKA-14246
Issue Type: Sub-task (was: Task)
> Remove duplicated integration tests
[
https://issues.apache.org/jira/browse/KAFKA-15438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15438:
--
Parent: KAFKA-14246
Issue Type: Sub-task (was: Task)
> Review exception caching logic used
[
https://issues.apache.org/jira/browse/KAFKA-15475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15475:
--
Labels: consumer-threading-refactor (was: )
> Timeout request might retry forever even if the user
junrao commented on code in PR #14406:
URL: https://github.com/apache/kafka/pull/14406#discussion_r1346179200
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/FetchBuffer.java:
##
@@ -37,7 +36,7 @@
*
* Note: this class is not thread-safe and is intended
[
https://issues.apache.org/jira/browse/KAFKA-15475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15475:
--
Parent: KAFKA-14246
Issue Type: Sub-task (was: Bug)
> Timeout request might retry forever
[
https://issues.apache.org/jira/browse/KAFKA-15534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15534:
--
Labels: consumer-threading-refactor (was: )
> Propagate client response time when timeout to the
[
https://issues.apache.org/jira/browse/KAFKA-15475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15475:
--
Summary: Timeout request might retry forever even if the user API times out
in PrototypeAsyncConsumer
[
https://issues.apache.org/jira/browse/KAFKA-15534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15534:
--
Parent: KAFKA-14246
Issue Type: Sub-task (was: Bug)
> Propagate client response time when
[
https://issues.apache.org/jira/browse/KAFKA-15539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15539:
--
Parent: KAFKA-14048
Issue Type: Sub-task (was: Task)
> Client should stop fetching while
[
https://issues.apache.org/jira/browse/KAFKA-15539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-15539:
-
Assignee: Kirk True
> Client should stop fetching while partitions being revoked
>
[
https://issues.apache.org/jira/browse/KAFKA-15539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15539:
--
Parent: (was: KAFKA-14048)
Issue Type: Task (was: Sub-task)
> Client should stop
1 - 100 of 252 matches
Mail list logo
