showuon commented on code in PR #14482:
URL: https://github.com/apache/kafka/pull/14482#discussion_r1346883006
##
core/src/test/scala/unit/kafka/log/remote/RemoteIndexCacheTest.scala:
##
@@ -541,6 +542,131 @@ class RemoteIndexCacheTest {
verifyFetchIndexInvocation(count = 1
showuon commented on code in PR #14482:
URL: https://github.com/apache/kafka/pull/14482#discussion_r1346881421
##
core/src/test/scala/unit/kafka/log/remote/RemoteIndexCacheTest.scala:
##
@@ -541,6 +542,131 @@ class RemoteIndexCacheTest {
verifyFetchIndexInvocation(count = 1
tledkov commented on code in PR #13247:
URL: https://github.com/apache/kafka/pull/13247#discussion_r1346869932
##
tools/src/main/java/org/apache/kafka/tools/reassign/ReassignPartitionsCommand.java:
##
@@ -0,0 +1,1523 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) un
mjsax commented on PR #13860:
URL: https://github.com/apache/kafka/pull/13860#issuecomment-1748162304
Another issue just introduced in `trunk` ->
https://github.com/apache/kafka/pull/14490
--
This is an automated message from the Apache Git Service.
To respond to the message, please log o
mjsax commented on code in PR #14490:
URL: https://github.com/apache/kafka/pull/14490#discussion_r1346844509
##
tests/kafkatest/version.py:
##
@@ -120,7 +120,7 @@ def get_version(node=None):
return DEV_BRANCH
DEV_BRANCH = KafkaVersion("dev")
-DEV_VERSION = KafkaVersi
mjsax commented on code in PR #14490:
URL: https://github.com/apache/kafka/pull/14490#discussion_r1346842409
##
tests/kafkatest/version.py:
##
@@ -120,7 +120,7 @@ def get_version(node=None):
return DEV_BRANCH
DEV_BRANCH = KafkaVersion("dev")
-DEV_VERSION = KafkaVersi
mjsax commented on code in PR #14490:
URL: https://github.com/apache/kafka/pull/14490#discussion_r1346843365
##
tests/kafkatest/version.py:
##
@@ -257,6 +257,4 @@ def get_version(node=None):
V_3_6_0 = KafkaVersion("3.6.0")
LATEST_3_6 = V_3_6_0
-# 3.7.x versions
-V_3_7_0 = Ka
mjsax opened a new pull request, #14490:
URL: https://github.com/apache/kafka/pull/14490
The last PR
(https://github.com/apache/kafka/commit/9e3b1f9b9bf48603acde7f71c704af812a6dab4b)
bumping versions introduces a bug for system test setup. This PR fixes it.
Call for review @satishd
[
https://issues.apache.org/jira/browse/KAFKA-15546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17772089#comment-17772089
]
Giovanni Marigi commented on KAFKA-15546:
-
[~jolshan] I would not live the field
[
https://issues.apache.org/jira/browse/KAFKA-15546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17772088#comment-17772088
]
Giovanni Marigi edited comment on KAFKA-15546 at 10/5/23 6:13 AM:
[
https://issues.apache.org/jira/browse/KAFKA-15546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17772088#comment-17772088
]
Giovanni Marigi commented on KAFKA-15546:
-
Tested with version 3.5 and usage of
mjsax commented on PR #13860:
URL: https://github.com/apache/kafka/pull/13860#issuecomment-1748136807
I identified one fundamental problem in 3.3 release -- a bug was introduced
that fundamentally breaks KS systems tests using that version. This PR
(https://github.com/apache/kafka/commit/fa
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 = 1
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 = 1
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 MirrorMakerConfigTest#testClientCon
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: jira-unsubscr...@kafka.apach
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 t
[
https://issues.apache.org/jira/browse/KAFKA-15541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17772072#comment-17772072
]
Matthias J. Sax commented on KAFKA-15541:
-
Did not read the KIP yet, but sound v
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
* Re
[
https://issues.apache.org/jira/browse/KAFKA-14941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17772048#comment-17772048
]
Luke Chen commented on KAFKA-14941:
---
Great! I'm working on the list, will let you know
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 Founda
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 Consumer
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 Soft
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 Apache
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
transactional
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 Fo
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). Th
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 Soft
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 intended
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 refreshCommittedOffsetsIfNe
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) {
return
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 failur
[
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: c
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 Fo
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
- [ ] V
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: jira-unsubscr...@kafka.apache.
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 G
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 UU
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 C
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
U
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 (final
[
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 MirrorMakerConfigTest#testClientConfigProperti
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 Fo
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 ReplicaEpoch
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 Fo
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 Fo
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&focusedCommentId=17771948#comment-17771948
]
ASF GitHub Bot commented on KAFKA-15530:
jolshan opened a new pull request, #555
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 Fo
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 (final
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: Ka
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 mar
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, pleas
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 Consumer
[
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 interna
[
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 bei
[
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 listTopic
[
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 change
[
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 ConsumerGroupProtocolVersion
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()
th
[
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 int
[
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 offsetsForTimes
[
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 locall
[
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 integ
[
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 bounde
[
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 FetchRequ
[
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 OffsetFetc
[
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 Fe
[
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 pat
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://kafka.apa
[
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 for
[
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: jira-unsubscr...@kafka.apach
[
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 and
[
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 Protot
[
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 Reques
[
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 A
1 - 100 of 263 matches
Mail list logo
