Philip Nee created KAFKA-16034:
--
Summary: AsyncKafkaConsumer will get Invalid Request error when
trying to rejoin on fenced/unknown member Id
Key: KAFKA-16034
URL: https://issues.apache.org/jira/browse/KAFKA-16034
[
https://issues.apache.org/jira/browse/KAFKA-16034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Philip Nee updated KAFKA-16034:
---
Parent: KAFKA-14246
Issue Type: Sub-task (was: Bug)
> AsyncKafkaConsumer will get Invalid R
[
https://issues.apache.org/jira/browse/KAFKA-16026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798843#comment-17798843
]
Philip Nee commented on KAFKA-16026:
For the PR [15035|https://github.com/apache/kaf
dajac commented on PR #14848:
URL: https://github.com/apache/kafka/pull/14848#issuecomment-1863996596
Merged to trunk and 3.7.
--
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
dajac merged PR #14848:
URL: https://github.com/apache/kafka/pull/14848
--
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.or
philipnee commented on PR #15035:
URL: https://github.com/apache/kafka/pull/15035#issuecomment-1863986474
hi @cadonna - Thanks for putting time into the review. I've addressed your
comments.
--
This is an automated message from the Apache Git Service.
To respond to the message, please lo
dajac commented on code in PR #14985:
URL: https://github.com/apache/kafka/pull/14985#discussion_r1432348819
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupCoordinatorShardTest.java:
##
@@ -968,4 +971,34 @@ public void testCleanupGroupMetadata() {
dajac commented on code in PR #14985:
URL: https://github.com/apache/kafka/pull/14985#discussion_r1432346828
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/OffsetMetadataManagerTest.java:
##
@@ -2414,6 +2424,67 @@ public void testReplayWithTombstone() {
dajac commented on code in PR #14985:
URL: https://github.com/apache/kafka/pull/14985#discussion_r1432340012
##
core/src/test/scala/unit/kafka/coordinator/group/CoordinatorLoaderImplTest.scala:
##
@@ -511,4 +544,35 @@ class CoordinatorLoaderImplTest {
new FetchDataInfo(ne
dajac commented on code in PR #14985:
URL: https://github.com/apache/kafka/pull/14985#discussion_r1432339221
##
core/src/test/scala/unit/kafka/coordinator/group/CoordinatorLoaderImplTest.scala:
##
@@ -511,4 +544,35 @@ class CoordinatorLoaderImplTest {
new FetchDataInfo(ne
cadonna commented on code in PR #15035:
URL: https://github.com/apache/kafka/pull/15035#discussion_r1432322309
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestManager.java:
##
@@ -234,7 +235,8 @@ public long maximumTimeToWait(long currentTime
showuon commented on code in PR #15050:
URL: https://github.com/apache/kafka/pull/15050#discussion_r1432303423
##
core/src/main/scala/kafka/log/UnifiedLog.scala:
##
@@ -1585,6 +1585,12 @@ class UnifiedLog(@volatile var logStartOffset: Long,
def onlyLocalLogSegmentsSize: Long
kamalcph commented on code in PR #15026:
URL: https://github.com/apache/kafka/pull/15026#discussion_r1432264764
##
core/src/main/scala/kafka/server/KafkaRequestHandler.scala:
##
@@ -289,14 +289,14 @@ class BrokerTopicMetrics(name: Option[String], configOpt:
java.util.Optional[K
kamalcph commented on code in PR #15050:
URL: https://github.com/apache/kafka/pull/15050#discussion_r1432252882
##
core/src/main/scala/kafka/log/UnifiedLog.scala:
##
@@ -1585,6 +1585,12 @@ class UnifiedLog(@volatile var logStartOffset: Long,
def onlyLocalLogSegmentsSize: Long
kamalcph commented on PR #15005:
URL: https://github.com/apache/kafka/pull/15005#issuecomment-1863858511
https://github.com/apache/kafka/pull/15005#discussion_r1431092107
We can take this up in the next PR, otherwise the replica might report stale
metrics.
--
This is an automated
showuon commented on code in PR #15026:
URL: https://github.com/apache/kafka/pull/15026#discussion_r1432207715
##
core/src/test/java/kafka/log/remote/RemoteLogManagerTest.java:
##
@@ -701,16 +702,22 @@ void
testRemoteLogManagerTasksAvgIdlePercentAndMetadataCountMetrics() throws
showuon commented on code in PR #15026:
URL: https://github.com/apache/kafka/pull/15026#discussion_r1432205258
##
core/src/test/scala/kafka/server/KafkaRequestHandlerTest.scala:
##
@@ -321,4 +323,24 @@ class KafkaRequestHandlerTest {
assertEquals(0, brokerTopicMetrics.remot
philipnee commented on code in PR #15035:
URL: https://github.com/apache/kafka/pull/15035#discussion_r1432202539
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestManager.java:
##
@@ -234,7 +237,8 @@ public long maximumTimeToWait(long currentTi
philipnee commented on code in PR #15035:
URL: https://github.com/apache/kafka/pull/15035#discussion_r1432201481
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestManager.java:
##
@@ -195,6 +195,7 @@ public NetworkClientDelegate.PollResult poll
philipnee commented on code in PR #15035:
URL: https://github.com/apache/kafka/pull/15035#discussion_r1432201197
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/CommitRequestManager.java:
##
@@ -288,7 +288,7 @@ public CompletableFuture> addOffsetFetchR
philipnee commented on code in PR #15035:
URL: https://github.com/apache/kafka/pull/15035#discussion_r1432199885
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestManagerTest.java:
##
@@ -660,14 +672,14 @@ private HeartbeatRequestManager
creat
philipnee commented on code in PR #15035:
URL: https://github.com/apache/kafka/pull/15035#discussion_r1432199373
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumerTest.java:
##
@@ -385,6 +386,7 @@ public void testWakeupAfterEmptyFetch() {
philipnee commented on code in PR #15035:
URL: https://github.com/apache/kafka/pull/15035#discussion_r1432199230
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/ApplicationEventProcessor.java:
##
@@ -136,7 +135,7 @@ private void process(final PollAppl
philipnee commented on code in PR #15035:
URL: https://github.com/apache/kafka/pull/15035#discussion_r1432199044
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/MembershipManagerImpl.java:
##
@@ -728,7 +732,6 @@ public boolean shouldSkipHeartbeat() {
@O
philipnee commented on code in PR #15035:
URL: https://github.com/apache/kafka/pull/15035#discussion_r1432198577
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestManager.java:
##
@@ -184,7 +184,9 @@ public NetworkClientDelegate.PollResult poll
ijuma commented on code in PR #15032:
URL: https://github.com/apache/kafka/pull/15032#discussion_r1432179355
##
generator/src/main/java/org/apache/kafka/message/StructRegistry.java:
##
@@ -110,6 +110,7 @@ private void addStructSpecs(Versions parentVersions,
List fields) {
ijuma commented on code in PR #15032:
URL: https://github.com/apache/kafka/pull/15032#discussion_r1432178897
##
core/src/test/scala/unit/kafka/network/RequestConvertToJsonTest.scala:
##
@@ -118,6 +119,21 @@ class RequestConvertToJsonTest {
assertEquals(expectedNode, actualN
hachikuji commented on code in PR #15032:
URL: https://github.com/apache/kafka/pull/15032#discussion_r1432175567
##
generator/src/main/java/org/apache/kafka/message/StructRegistry.java:
##
@@ -110,6 +110,7 @@ private void addStructSpecs(Versions parentVersions,
List fields) {
rondagostino merged PR #14977:
URL: https://github.com/apache/kafka/pull/14977
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscr...@kafka.ap
rondagostino commented on PR #14977:
URL: https://github.com/apache/kafka/pull/14977#issuecomment-1863734568
Test failures are unrelated/flakes. JDK 8 tests were clean. All tests in
this PR passed. Merging to trunk and 3.7.
--
This is an automated message from the Apache Git Service.
T
lianetm commented on PR #15033:
URL: https://github.com/apache/kafka/pull/15033#issuecomment-1863701453
Test failures seem unrelated. I checked around `testCoordinatorFailover`
that, even though it passes locally, it failed on the CI for the new consumer,
but it's been failing for other rec
philipnee closed pull request #15036: Test refactor consumer close
URL: https://github.com/apache/kafka/pull/15036
--
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 unsubscrib
philipnee closed pull request #14390: KAFKA-15592: Allow member to not sending
a heartbeat when a group ID is configured
URL: https://github.com/apache/kafka/pull/14390
--
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-16010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798772#comment-17798772
]
Philip Nee commented on KAFKA-16010:
I thought KAFKA-16026 (fixing the max poll) wou
[
https://issues.apache.org/jira/browse/KAFKA-16025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798761#comment-17798761
]
Sabit edited comment on KAFKA-16025 at 12/19/23 10:23 PM:
--
I th
[
https://issues.apache.org/jira/browse/KAFKA-16025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798761#comment-17798761
]
Sabit edited comment on KAFKA-16025 at 12/19/23 10:23 PM:
--
I th
[
https://issues.apache.org/jira/browse/KAFKA-16025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798761#comment-17798761
]
Sabit edited comment on KAFKA-16025 at 12/19/23 10:22 PM:
--
I th
[
https://issues.apache.org/jira/browse/KAFKA-16025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798761#comment-17798761
]
Sabit edited comment on KAFKA-16025 at 12/19/23 10:22 PM:
--
I th
[
https://issues.apache.org/jira/browse/KAFKA-16025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798761#comment-17798761
]
Sabit edited comment on KAFKA-16025 at 12/19/23 10:21 PM:
--
I th
[
https://issues.apache.org/jira/browse/KAFKA-16025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798761#comment-17798761
]
Sabit commented on KAFKA-16025:
---
I think this bug can occur when rebalancing is triggered
[
https://issues.apache.org/jira/browse/KAFKA-15341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798760#comment-17798760
]
Phuc Hong Tran commented on KAFKA-15341:
Got it. Thanks, [~showuon]
> Enabling
jeffkbkim commented on code in PR #14985:
URL: https://github.com/apache/kafka/pull/14985#discussion_r1431849588
##
core/src/test/scala/unit/kafka/coordinator/group/CoordinatorLoaderImplTest.scala:
##
@@ -511,4 +544,35 @@ class CoordinatorLoaderImplTest {
new FetchDataInf
ableegoldman merged PR #14853:
URL: https://github.com/apache/kafka/pull/14853
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscr...@kafka.ap
ableegoldman commented on PR #14853:
URL: https://github.com/apache/kafka/pull/14853#issuecomment-1863466888
I honestly don't know...maybe try doing a rebase from trunk and force
pushing? That can often clear up this sort of thing. Ideally we don't have to
abandon this PR for a fresh one (j
[
https://issues.apache.org/jira/browse/KAFKA-15250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15250:
--
Issue Type: Bug (was: Improvement)
> DefaultBackgroundThread is running tight loop
>
[
https://issues.apache.org/jira/browse/KAFKA-15946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15946:
--
Issue Type: Bug (was: Improvement)
> AsyncKafkaConsumer should retry commits on the application threa
[
https://issues.apache.org/jira/browse/KAFKA-15872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15872:
--
Issue Type: Task (was: Improvement)
> Investigate autocommit retry logic
> --
[
https://issues.apache.org/jira/browse/KAFKA-15991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15991:
--
Issue Type: Test (was: Task)
> Flaky new consumer test testGroupIdNotNullAndValid
> -
[
https://issues.apache.org/jira/browse/KAFKA-15775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15775:
--
Fix Version/s: 3.7.0
> Implement listTopics() and partitionFor() for the AsyncKafkaConsumer
>
[
https://issues.apache.org/jira/browse/KAFKA-15548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15548:
--
Fix Version/s: 3.7.0
> Send GroupConsumerHeartbeatRequest on Consumer.close()
> --
[
https://issues.apache.org/jira/browse/KAFKA-15696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15696:
--
Fix Version/s: 3.7.0
> Revoke partitions on Consumer.close()
> -
>
[
https://issues.apache.org/jira/browse/KAFKA-15475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15475:
--
Parent: (was: KAFKA-14246)
Issue Type: Bug (was: Sub-task)
> Timeout request might retry
[
https://issues.apache.org/jira/browse/KAFKA-15866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15866:
--
Parent: (was: KAFKA-14246)
Issue Type: Improvement (was: Sub-task)
> Refactor OffsetFetch
[
https://issues.apache.org/jira/browse/KAFKA-15652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15652:
--
Parent: (was: KAFKA-14246)
Issue Type: Test (was: Sub-task)
> Add tests to verify OffsetF
[
https://issues.apache.org/jira/browse/KAFKA-15639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15639:
--
Parent: (was: KAFKA-14246)
Issue Type: Test (was: Sub-task)
> Investigate ConsumerNetwork
[
https://issues.apache.org/jira/browse/KAFKA-15634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15634:
--
Parent: (was: KAFKA-14246)
Issue Type: Test (was: Sub-task)
> Investigate FetcherTest's/F
[
https://issues.apache.org/jira/browse/KAFKA-15284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15284:
--
Parent: (was: KAFKA-14246)
Issue Type: New Feature (was: Sub-task)
> Implement ConsumerGr
[
https://issues.apache.org/jira/browse/KAFKA-15615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15615:
--
Parent: (was: KAFKA-14246)
Issue Type: Improvement (was: Sub-task)
> Improve handling of
[
https://issues.apache.org/jira/browse/KAFKA-15558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15558:
--
Parent: (was: KAFKA-14246)
Issue Type: Task (was: Sub-task)
> Determine if Timer should b
[
https://issues.apache.org/jira/browse/KAFKA-15553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15553:
--
Parent: (was: KAFKA-14246)
Issue Type: Task (was: Sub-task)
> Review committed offset ref
[
https://issues.apache.org/jira/browse/KAFKA-15515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15515:
--
Component/s: unit tests
> Remove duplicated integration tests for new consumer
> -
[
https://issues.apache.org/jira/browse/KAFKA-15515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15515:
--
Parent: (was: KAFKA-14246)
Issue Type: Test (was: Sub-task)
> Remove duplicated integrati
[
https://issues.apache.org/jira/browse/KAFKA-15551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15551:
--
Parent: (was: KAFKA-14246)
Issue Type: Improvement (was: Sub-task)
> Evaluate conditions
[
https://issues.apache.org/jira/browse/KAFKA-15250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15250:
--
Parent: (was: KAFKA-14246)
Issue Type: Improvement (was: Sub-task)
> DefaultBackgroundThr
[
https://issues.apache.org/jira/browse/KAFKA-15305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15305:
--
Parent: (was: KAFKA-14246)
Issue Type: Improvement (was: Sub-task)
> The background threa
[
https://issues.apache.org/jira/browse/KAFKA-15556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15556:
--
Parent: (was: KAFKA-14246)
Issue Type: Improvement (was: Sub-task)
> Remove NetworkClient
[
https://issues.apache.org/jira/browse/KAFKA-15173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15173:
--
Parent: (was: KAFKA-14246)
Issue Type: Improvement (was: Sub-task)
> Consumer event queue
[
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-14246)
Issue Type: Task (was: Sub-task)
> Document event queueing pat
[
https://issues.apache.org/jira/browse/KAFKA-15867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15867:
--
Parent: (was: KAFKA-14246)
Issue Type: Task (was: Sub-task)
> Should ConsumerNetworkThrea
[
https://issues.apache.org/jira/browse/KAFKA-15942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15942:
--
Parent: (was: KAFKA-14246)
Issue Type: New Feature (was: Sub-task)
> Implement ConsumerIn
[
https://issues.apache.org/jira/browse/KAFKA-15636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15636:
--
Parent: (was: KAFKA-14246)
Issue Type: Test (was: Sub-task)
> Investigate FetcherTest's/F
[
https://issues.apache.org/jira/browse/KAFKA-15637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15637:
--
Parent: (was: KAFKA-14246)
Issue Type: Test (was: Sub-task)
> Investigate FetcherTest's/F
[
https://issues.apache.org/jira/browse/KAFKA-15635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15635:
--
Parent: (was: KAFKA-14246)
Issue Type: Test (was: Sub-task)
> Investigate FetcherTest's/F
[
https://issues.apache.org/jira/browse/KAFKA-15638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15638:
--
Parent: (was: KAFKA-14246)
Issue Type: Test (was: Sub-task)
> Investigate ConsumerNetwork
[
https://issues.apache.org/jira/browse/KAFKA-15557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15557:
--
Parent: (was: KAFKA-14246)
Issue Type: Test (was: Sub-task)
> Investigate FetcherTest's/F
[
https://issues.apache.org/jira/browse/KAFKA-15617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15617:
--
Parent: (was: KAFKA-14246)
Issue Type: Test (was: Sub-task)
> Investigate FetcherTest's/F
[
https://issues.apache.org/jira/browse/KAFKA-15606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15606:
--
Parent: (was: KAFKA-14246)
Issue Type: Test (was: Sub-task)
> Investigate FetcherTest's/F
[
https://issues.apache.org/jira/browse/KAFKA-15946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15946:
--
Parent: (was: KAFKA-14246)
Issue Type: Improvement (was: Sub-task)
> AsyncKafkaConsumer s
[
https://issues.apache.org/jira/browse/KAFKA-15993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15993:
--
Parent: (was: KAFKA-14246)
Issue Type: Test (was: Sub-task)
> Enable integration tests th
[
https://issues.apache.org/jira/browse/KAFKA-15948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15948:
--
Parent: (was: KAFKA-14246)
Issue Type: Improvement (was: Sub-task)
> Refactor AsyncKafkaC
[
https://issues.apache.org/jira/browse/KAFKA-16000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16000:
--
Parent: (was: KAFKA-14246)
Issue Type: Test (was: Sub-task)
> Migrate MembershipManagerIm
[
https://issues.apache.org/jira/browse/KAFKA-15872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15872:
--
Parent: (was: KAFKA-14246)
Issue Type: Improvement (was: Sub-task)
> Investigate autocomm
[
https://issues.apache.org/jira/browse/KAFKA-15999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15999:
--
Parent: (was: KAFKA-14246)
Issue Type: Test (was: Sub-task)
> Migrate HeartbeatRequestMan
[
https://issues.apache.org/jira/browse/KAFKA-16019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16019:
--
Parent: (was: KAFKA-14246)
Issue Type: Test (was: Sub-task)
> Some of the tests in Plaint
[
https://issues.apache.org/jira/browse/KAFKA-16022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16022:
--
Parent: (was: KAFKA-14246)
Issue Type: Bug (was: Sub-task)
> AsyncKafkaConsumer sometimes
[
https://issues.apache.org/jira/browse/KAFKA-16001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16001:
--
Parent: (was: KAFKA-14246)
Issue Type: Test (was: Sub-task)
> Migrate ConsumerNetworkThre
[
https://issues.apache.org/jira/browse/KAFKA-16023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16023:
--
Parent: (was: KAFKA-14246)
Issue Type: Test (was: Sub-task)
> PlaintextConsumerTest needs
[
https://issues.apache.org/jira/browse/KAFKA-16024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16024:
--
Parent: (was: KAFKA-14246)
Issue Type: Test (was: Sub-task)
> SaslPlaintextConsumerTest#t
[
https://issues.apache.org/jira/browse/KAFKA-15942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15942:
--
Fix Version/s: 3.8.0
> Implement ConsumerInterceptor
> -
>
>
[
https://issues.apache.org/jira/browse/KAFKA-16009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16009:
--
Fix Version/s: 3.8.0
> Fix PlaintextConsumerTest.testMaxPollIntervalMsDelayInRevocation
>
[
https://issues.apache.org/jira/browse/KAFKA-15282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15282:
--
Fix Version/s: 3.8.0
> Implement client support for KIP-848 client-side assignors
> --
[
https://issues.apache.org/jira/browse/KAFKA-15993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15993:
--
Fix Version/s: 3.8.0
> Enable integration tests that relies on rebalance listener
> --
[
https://issues.apache.org/jira/browse/KAFKA-15283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15283:
--
Fix Version/s: 3.8.0
> Add support for topic ID-related Consumer changes
> ---
[
https://issues.apache.org/jira/browse/KAFKA-15475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15475:
--
Fix Version/s: 3.8.0
> Timeout request might retry forever even if the user API times out in
> Protot
[
https://issues.apache.org/jira/browse/KAFKA-15279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15279:
--
Fix Version/s: 3.8.0
> Implement client support for KIP-848 client-side assigner RPCs
> --
[
https://issues.apache.org/jira/browse/KAFKA-15538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15538:
--
Fix Version/s: 3.8.0
> Client support for java regex based subscription
> ---
[
https://issues.apache.org/jira/browse/KAFKA-15692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15692:
--
Fix Version/s: 3.8.0
> New integration tests to ensure full coverage
> ---
[
https://issues.apache.org/jira/browse/KAFKA-16023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16023:
--
Fix Version/s: 3.8.0
> PlaintextConsumerTest needs to wait for reconciliation to complete before
> pr
[
https://issues.apache.org/jira/browse/KAFKA-15561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15561:
--
Fix Version/s: 3.8.0
> Client support for new SubscriptionPattern based subscription
> --
[
https://issues.apache.org/jira/browse/KAFKA-15542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15542:
--
Fix Version/s: 3.8.0
> Release member assignments on errors
>
>
>
1 - 100 of 260 matches
Mail list logo