[
https://issues.apache.org/jira/browse/KAFKA-16799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16799:
--
Priority: Major (was: Blocker)
> NetworkClientDelegate is not backing off if the node is not found
>
[
https://issues.apache.org/jira/browse/KAFKA-16315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16315:
--
Fix Version/s: (was: 4.0.0)
> Investigate propagating metadata updates via queues
> --
[
https://issues.apache.org/jira/browse/KAFKA-15321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15321:
--
Fix Version/s: (was: 4.0.0)
> Document consumer group member state machine
> -
[
https://issues.apache.org/jira/browse/KAFKA-15652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15652:
--
Fix Version/s: (was: 4.0.0)
> Add tests to verify OffsetFetcherUtils.getOffsetResetTimestamp()
> -
[
https://issues.apache.org/jira/browse/KAFKA-16966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16966:
--
Fix Version/s: (was: 4.0.0)
> Allow offset commit fetch to reuse previous request if partitions ar
[
https://issues.apache.org/jira/browse/KAFKA-15173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15173:
--
Fix Version/s: (was: 4.0.0)
> Consumer event queues should be bounded
> --
[
https://issues.apache.org/jira/browse/KAFKA-16109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16109:
--
Fix Version/s: (was: 4.0.0)
> Write system tests cover the "simple consumer + commit" use case
> -
[
https://issues.apache.org/jira/browse/KAFKA-16111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16111:
--
Fix Version/s: (was: 4.0.0)
> Implement tests for tricky rebalance callback scenarios
> --
[
https://issues.apache.org/jira/browse/KAFKA-15551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15551:
--
Fix Version/s: (was: 4.0.0)
> Evaluate conditions for short circuiting consumer API calls
> --
[
https://issues.apache.org/jira/browse/KAFKA-15617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15617:
--
Fix Version/s: (was: 4.0.0)
> Investigate FetcherTest's/FetchRequestManager's testFetchingPendingP
[
https://issues.apache.org/jira/browse/KAFKA-16799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16799:
--
Fix Version/s: (was: 4.0.0)
> NetworkClientDelegate is not backing off if the node is not found
>
[
https://issues.apache.org/jira/browse/KAFKA-16110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16110:
--
Fix Version/s: (was: 4.0.0)
> Document and publicize performance test results for AsyncKafkaConsum
[
https://issues.apache.org/jira/browse/KAFKA-15637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15637:
--
Fix Version/s: (was: 4.0.0)
> Investigate FetcherTest's/FetchRequestManager's
> testFetchComplete
[
https://issues.apache.org/jira/browse/KAFKA-15639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15639:
--
Fix Version/s: (was: 4.0.0)
> Investigate ConsumerNetworkThreadTest's
> testResetPositionsProcess
[
https://issues.apache.org/jira/browse/KAFKA-15638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15638:
--
Fix Version/s: (was: 4.0.0)
> Investigate ConsumerNetworkThreadTest's testPollResultTimer
> --
[
https://issues.apache.org/jira/browse/KAFKA-15615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15615:
--
Fix Version/s: (was: 4.0.0)
> Improve handling of fetching during metadata updates
> -
[
https://issues.apache.org/jira/browse/KAFKA-15320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15320:
--
Fix Version/s: (was: 4.0.0)
> Document event queueing patterns
>
[
https://issues.apache.org/jira/browse/KAFKA-15635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15635:
--
Fix Version/s: (was: 4.0.0)
> Investigate FetcherTest's/FetchRequestManager's testFetcherLeadMetri
[
https://issues.apache.org/jira/browse/KAFKA-15634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15634:
--
Fix Version/s: (was: 4.0.0)
> Investigate FetcherTest's/FetchRequestManager's testQuotaMetrics
> -
[
https://issues.apache.org/jira/browse/KAFKA-15557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15557:
--
Fix Version/s: (was: 4.0.0)
> Investigate FetcherTest's/FetchRequestManager's duplicate metadata u
[
https://issues.apache.org/jira/browse/KAFKA-16444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16444:
--
Fix Version/s: (was: 4.0.0)
> Run KIP-848 unit tests under code coverage
> ---
[
https://issues.apache.org/jira/browse/KAFKA-16642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16642:
--
Fix Version/s: (was: 4.0.0)
> Update KafkaConsumerTest to show parameters in test lists
>
[
https://issues.apache.org/jira/browse/KAFKA-15636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15636:
--
Fix Version/s: (was: 4.0.0)
> Investigate FetcherTest's/FetchRequestManager's testFetchResponseMet
[
https://issues.apache.org/jira/browse/KAFKA-15606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15606:
--
Fix Version/s: (was: 4.0.0)
> Investigate FetcherTest's/FetchRequestManager's testCompletedFetchRe
[
https://issues.apache.org/jira/browse/KAFKA-16272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True resolved KAFKA-16272.
---
Resolution: Fixed
> Update connect_distributed_test.py to support KIP-848’s group protocol config
>
[
https://issues.apache.org/jira/browse/KAFKA-15908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-15908:
-
Assignee: (was: Kirk True)
> Remove deprecated Consumer API poll(long timeout)
> --
[
https://issues.apache.org/jira/browse/KAFKA-15908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17886780#comment-17886780
]
Kirk True commented on KAFKA-15908:
---
I've unassigned myself, so whomever is willing an
[
https://issues.apache.org/jira/browse/KAFKA-17686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-17686:
--
Summary: AsyncKafkaConsumer.offsetsForTimes() fails with
NullPointerException (was: AsyncKafkaConsume
[
https://issues.apache.org/jira/browse/KAFKA-17686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-17686:
--
Summary: AsyncKafkaConsumer.offsetsForTimes fails with NullPointerException
(was: PlaintextAdminInteg
Kirk True created KAFKA-17686:
-
Summary: PlaintextAdminIntegrationTest’s
testOffsetsForTimesAfterDeleteRecords fails with NPE with new consumer
Key: KAFKA-17686
URL: https://issues.apache.org/jira/browse/KAFKA-17686
[
https://issues.apache.org/jira/browse/KAFKA-16109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17885936#comment-17885936
]
Kirk True commented on KAFKA-16109:
---
I think we can push it to post-4.0 and/or lower t
[
https://issues.apache.org/jira/browse/KAFKA-17647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-17647:
--
Component/s: clients
consumer
> Check
> PlaintextConsumerSubscriptionTest#testSubscr
[
https://issues.apache.org/jira/browse/KAFKA-17648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-17648:
--
Component/s: clients
consumer
> AsyncKafkaConsumer#unsubscribe swallow TopicAuthoriza
[
https://issues.apache.org/jira/browse/KAFKA-17623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-17623:
--
Component/s: clients
> Flaky
> testSeekPositionAndPauseNewlyAssignedPartitionOnPartitionsAssignedCall
[
https://issues.apache.org/jira/browse/KAFKA-17618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-17618:
--
Component/s: (was: clients)
(was: consumer)
> group consumer heartbeat interv
[
https://issues.apache.org/jira/browse/KAFKA-17618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-17618:
--
Component/s: clients
consumer
> group consumer heartbeat interval should be less than
[
https://issues.apache.org/jira/browse/KAFKA-17518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17884834#comment-17884834
]
Kirk True commented on KAFKA-17518:
---
Thanks! :)
> AsyncKafkaConsumer cannot reliably
[
https://issues.apache.org/jira/browse/KAFKA-17518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17884832#comment-17884832
]
Kirk True commented on KAFKA-17518:
---
[~frankvicky]—as [~lianetm] mentioned, this Jira
[
https://issues.apache.org/jira/browse/KAFKA-16778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16778:
--
Labels: kip-848-client-support (was: )
> AsyncKafkaConsumer fetcher might occasionally try to fetch t
[
https://issues.apache.org/jira/browse/KAFKA-16778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16778:
--
Component/s: clients
consumer
> AsyncKafkaConsumer fetcher might occasionally try to
[
https://issues.apache.org/jira/browse/KAFKA-16966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17884828#comment-17884828
]
Kirk True commented on KAFKA-16966:
---
[~taijuwu]—feel free to take it :)
> Allow offse
[
https://issues.apache.org/jira/browse/KAFKA-15588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17884827#comment-17884827
]
Kirk True commented on KAFKA-15588:
---
[~frankvicky]—I can't say with any certainty, but
[
https://issues.apache.org/jira/browse/KAFKA-17581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-17581:
--
Labels: consumer-threading-refactor kip-848-client-support (was: )
> AsyncKafkaConsumer can't unsubsc
[
https://issues.apache.org/jira/browse/KAFKA-17582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-17582:
--
Component/s: consumer
> Unpredictable consumer position after transaction abort
>
[
https://issues.apache.org/jira/browse/KAFKA-17439?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-17439:
--
Labels: consumer-threading-refactor kip-848-client-support (was:
consumer-threading-refactor)
> Make
[
https://issues.apache.org/jira/browse/KAFKA-16460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-16460:
-
Assignee: Kirk True (was: Arpit Goyal)
> New consumer times out consuming records in multiple
[
https://issues.apache.org/jira/browse/KAFKA-16460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17884399#comment-17884399
]
Kirk True commented on KAFKA-16460:
---
There's a good chance this is a result of a diffe
[
https://issues.apache.org/jira/browse/KAFKA-17581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-17581:
--
Component/s: clients
consumer
> AsyncKafkaConsumer can't unsubscribe invalid topics
>
[
https://issues.apache.org/jira/browse/KAFKA-17581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883613#comment-17883613
]
Kirk True commented on KAFKA-17581:
---
[~yangpoan]—this is a good catch! Where in the ne
[
https://issues.apache.org/jira/browse/KAFKA-17554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-17554:
--
Component/s: clients
> Flaky testFutureCompletionOutsidePoll in ConsumerNetworkClientTest
> --
[
https://issues.apache.org/jira/browse/KAFKA-17519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17881422#comment-17881422
]
Kirk True commented on KAFKA-17519:
---
[~yangpoan]—it's yours if you want it. Thanks!
>
[
https://issues.apache.org/jira/browse/KAFKA-17535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-17535:
--
Component/s: clients
> Flaky testCloseNoWait in KafkaConsumerTest for Classic Consumer
>
[
https://issues.apache.org/jira/browse/KAFKA-17518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17881421#comment-17881421
]
Kirk True commented on KAFKA-17518:
---
[~frankvicky]—yes, you're free to take it. Thanks
Kirk True created KAFKA-17536:
-
Summary: Ensure clear error message when "new" consumer used with
incompatible cluster
Key: KAFKA-17536
URL: https://issues.apache.org/jira/browse/KAFKA-17536
Project: Kafk
[
https://issues.apache.org/jira/browse/KAFKA-17536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-17536:
--
Priority: Critical (was: Major)
> Ensure clear error message when "new" consumer used with incompatib
[
https://issues.apache.org/jira/browse/KAFKA-17519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-17519:
--
Summary: Define behavior of Consumer.close() and its timeout when thread is
interrupted (was: Review
[
https://issues.apache.org/jira/browse/KAFKA-17518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17880817#comment-17880817
]
Kirk True edited comment on KAFKA-17518 at 9/11/24 12:32 AM:
-
Kirk True created KAFKA-17518:
-
Summary: AsyncKafkaConsumer cannot reliably leave group when
closed with small timeout
Key: KAFKA-17518
URL: https://issues.apache.org/jira/browse/KAFKA-17518
Project: Kafk
[
https://issues.apache.org/jira/browse/KAFKA-16138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16138:
--
Fix Version/s: 4.0.0
> QuotaTest system test fails consistently in 3.7
> -
[
https://issues.apache.org/jira/browse/KAFKA-16138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-16138:
-
Assignee: Kirk True (was: Philip Nee)
> QuotaTest system test fails consistently in 3.7
>
[
https://issues.apache.org/jira/browse/KAFKA-17448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17879653#comment-17879653
]
Kirk True commented on KAFKA-17448:
---
[~yangpoan]—sorry for the nag, but can you mark t
[
https://issues.apache.org/jira/browse/KAFKA-16138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16138:
--
Component/s: system tests
> QuotaTest system test fails consistently in 3.7
>
[
https://issues.apache.org/jira/browse/KAFKA-16138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-16138:
-
Assignee: Philip Nee
> QuotaTest system test fails consistently in 3.7
> --
[
https://issues.apache.org/jira/browse/KAFKA-16138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16138:
--
Component/s: clients
consumer
> QuotaTest system test fails consistently in 3.7
> ---
[
https://issues.apache.org/jira/browse/KAFKA-17466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-17466:
--
Component/s: clients
consumer
> Revisit failAndRemoveExpiredCommitRequests method
> -
[
https://issues.apache.org/jira/browse/KAFKA-17456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-17456:
--
Component/s: clients
consumer
> Make sure FindCoordinatorResponse get created before
[
https://issues.apache.org/jira/browse/KAFKA-17338?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17879020#comment-17879020
]
Kirk True commented on KAFKA-17338:
---
[~m1a2st]—I assigned this to you and updated the
[
https://issues.apache.org/jira/browse/KAFKA-17338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-17338:
--
Fix Version/s: 4.0.0
> ConsumerConfig should prevent using partition assignors with CONSUMER group
>
[
https://issues.apache.org/jira/browse/KAFKA-17338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-17338:
-
Assignee: 黃竣陽 (was: Kirk True)
> ConsumerConfig should prevent using partition assignors with
[
https://issues.apache.org/jira/browse/KAFKA-17116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-17116:
--
Labels: kip-848-client-support needs-kip (was: kip-848-client-support)
> New consumer may not send ef
[
https://issues.apache.org/jira/browse/KAFKA-17338?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17878956#comment-17878956
]
Kirk True commented on KAFKA-17338:
---
[~m1a2st] do you want to assign this to yourself,
[
https://issues.apache.org/jira/browse/KAFKA-17453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-17453:
--
Component/s: clients
consumer
> Fix flaky
> PlaintextConsumerFetchTest#testFetchOutO
[
https://issues.apache.org/jira/browse/KAFKA-17453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-17453:
--
Labels: integration-test (was: )
> Fix flaky
> PlaintextConsumerFetchTest#testFetchOutOfRangeOffsetR
[
https://issues.apache.org/jira/browse/KAFKA-17451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-17451:
--
Component/s: clients
consumer
> Remove deprecated Consumer#committed
> --
[
https://issues.apache.org/jira/browse/KAFKA-17335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17877943#comment-17877943
]
Kirk True commented on KAFKA-17335:
---
Thanks [~chia7712]!!!
> Lack of default for URL
[
https://issues.apache.org/jira/browse/KAFKA-16623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16623:
--
Fix Version/s: 4.0.0
(was: 3.9.0)
> KafkaAsyncConsumer system tests warn about
[
https://issues.apache.org/jira/browse/KAFKA-16623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17877879#comment-17877879
]
Kirk True commented on KAFKA-16623:
---
[~cmccabe]—this is not a blocker for 3.9.0, no. I
[
https://issues.apache.org/jira/browse/KAFKA-17335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-17335:
--
Fix Version/s: (was: 3.9.0)
> Lack of default for URL encoding configuration for OAuth causes NPE
[
https://issues.apache.org/jira/browse/KAFKA-17439?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-17439:
--
Fix Version/s: 4.0.0
> Make polling for new records an explicit action/event in the new consumer
> ---
[
https://issues.apache.org/jira/browse/KAFKA-17439?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-17439:
--
Affects Version/s: 3.7.0
> Make polling for new records an explicit action/event in the new consumer
>
Kirk True created KAFKA-17439:
-
Summary: Make polling for new records an explicit action/event in
the new consumer
Key: KAFKA-17439
URL: https://issues.apache.org/jira/browse/KAFKA-17439
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-14830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17877221#comment-17877221
]
Kirk True commented on KAFKA-14830:
---
cc [~mjsax]
> Illegal state error in transactio
[
https://issues.apache.org/jira/browse/KAFKA-14830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17877220#comment-17877220
]
Kirk True commented on KAFKA-14830:
---
[~jolshan] [~alivshits] [~calvinliu]—I have looke
[
https://issues.apache.org/jira/browse/KAFKA-16792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17877042#comment-17877042
]
Kirk True commented on KAFKA-16792:
---
{{AsyncKafkaConsumer.poll()}} should indirectly c
[
https://issues.apache.org/jira/browse/KAFKA-17397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17877037#comment-17877037
]
Kirk True commented on KAFKA-17397:
---
[~goyarpit]—yes, feel free to work on it :)
> En
[
https://issues.apache.org/jira/browse/KAFKA-17421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-17421:
--
Component/s: clients
consumer
> Add IT for ConsumerRecord#leaderEpoch
> -
[
https://issues.apache.org/jira/browse/KAFKA-17421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-17421:
--
Labels: integration-test (was: )
> Add IT for ConsumerRecord#leaderEpoch
> --
[
https://issues.apache.org/jira/browse/KAFKA-17182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-17182:
--
Summary: Consumer fetch sessions are evicted too quickly (was: Consumer’s
fetch sessions are evicted
[
https://issues.apache.org/jira/browse/KAFKA-17335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17876399#comment-17876399
]
Kirk True commented on KAFKA-17335:
---
No worries, [~bachmanity1]!
Regarding 3.9.0, I t
[
https://issues.apache.org/jira/browse/KAFKA-17335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-17335:
--
Summary: Lack of default for URL encoding configuration for OAuth causes
NPE (was: Lack of default fo
[
https://issues.apache.org/jira/browse/KAFKA-17182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-17182:
--
Summary: Consumer’s fetch sessions are evicted too quickly (was:
Consumer's fetch sessions are evicte
[
https://issues.apache.org/jira/browse/KAFKA-17377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17875692#comment-17875692
]
Kirk True commented on KAFKA-17377:
---
[~yangpoan]—your suggestion makes a lot of sense.
[
https://issues.apache.org/jira/browse/KAFKA-17377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-17377:
--
Labels: refactor (was: )
> Consider using defaultApiTimeoutMs in AsyncKafkaConsumer#unsubscribe
> ---
[
https://issues.apache.org/jira/browse/KAFKA-17377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-17377:
--
Labels: consumer-threading-refactor (was: refactor)
> Consider using defaultApiTimeoutMs in AsyncKafk
[
https://issues.apache.org/jira/browse/KAFKA-17377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-17377:
--
Component/s: clients
consumer
> Consider using defaultApiTimeoutMs in AsyncKafkaConsu
[
https://issues.apache.org/jira/browse/KAFKA-17395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-17395:
--
Labels: consumer-threading-refactor flaky-test (was:
consumer-threading-refactor)
> Flaky test testM
Kirk True created KAFKA-17397:
-
Summary: Ensure ClassicKafkaConsumer sends leave request on close
even if interrupted
Key: KAFKA-17397
URL: https://issues.apache.org/jira/browse/KAFKA-17397
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-16985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16985:
--
Fix Version/s: 4.0.0
(was: 3.9.0)
> Ensure consumer sends leave request on clos
[
https://issues.apache.org/jira/browse/KAFKA-16443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True resolved KAFKA-16443.
---
Resolution: Won't Fix
This Jira was created prior to getting input from the Kafka Streams developers
[
https://issues.apache.org/jira/browse/KAFKA-16441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True resolved KAFKA-16441.
---
Resolution: Won't Fix
This Jira was created prior to getting input from the Kafka Streams developers
201 - 300 of 1250 matches
Mail list logo
