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
[
https://issues.apache.org/jira/browse/KAFKA-16026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17798843#comment-17798843
]
Philip Nee commented on KAFKA-16026:
For the PR [15035|https://github.com/apache/kafka/pull/15035] -
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
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:
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
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
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
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
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:
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:
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()
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,
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
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
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
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
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() {
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
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,
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:
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.
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
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
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=17798772#comment-17798772
]
Philip Nee commented on KAFKA-16010:
I thought KAFKA-16026 (fixing the max poll) would fix this;
[
https://issues.apache.org/jira/browse/KAFKA-16025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17798761#comment-17798761
]
Sabit edited comment on KAFKA-16025 at 12/19/23 10:23 PM:
--
I think this bug can
[
https://issues.apache.org/jira/browse/KAFKA-16025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17798761#comment-17798761
]
Sabit edited comment on KAFKA-16025 at 12/19/23 10:23 PM:
--
I think this bug can
[
https://issues.apache.org/jira/browse/KAFKA-16025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17798761#comment-17798761
]
Sabit edited comment on KAFKA-16025 at 12/19/23 10:22 PM:
--
I think this bug can
[
https://issues.apache.org/jira/browse/KAFKA-16025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17798761#comment-17798761
]
Sabit edited comment on KAFKA-16025 at 12/19/23 10:22 PM:
--
I think this bug can
[
https://issues.apache.org/jira/browse/KAFKA-16025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17798761#comment-17798761
]
Sabit edited comment on KAFKA-16025 at 12/19/23 10:21 PM:
--
I think this bug can
[
https://issues.apache.org/jira/browse/KAFKA-16025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17798761#comment-17798761
]
Sabit commented on KAFKA-16025:
---
I think this bug can occur when rebalancing is triggered in the middle of
[
https://issues.apache.org/jira/browse/KAFKA-15341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17798760#comment-17798760
]
Phuc Hong Tran commented on KAFKA-15341:
Got it. Thanks, [~showuon]
> Enabling TS for a topic
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
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:
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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)
>
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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)
>
[
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
>
[
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-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-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
>
[
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
