Re: [PR] KAFKA-15632: Drop the invalid remote log metadata events [kafka]

2023-10-19 Thread via GitHub
kamalcph commented on code in PR #14576: URL: https://github.com/apache/kafka/pull/14576#discussion_r1364317572 ## storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/RemoteLogMetadataCache.java: ## @@ -302,22 +307,26 @@ public void

[jira] [Commented] (KAFKA-15657) Unexpected errors when producing transactionally in 3.6

2023-10-19 Thread Ismael Juma (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1567#comment-1567 ] Ismael Juma commented on KAFKA-15657: - I was wondering the same. We should fix KAFKA-15653 and see

[jira] [Commented] (KAFKA-15657) Unexpected errors when producing transactionally in 3.6

2023-10-19 Thread Travis Bischel (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1565#comment-1565 ] Travis Bischel commented on KAFKA-15657: I'm beginning to suspect that KAFKA-15653 may

[jira] [Updated] (KAFKA-15629) proposal to introduce IQv2 Query Types: TimestampedKeyQuery and TimestampedRangeQuery

2023-10-19 Thread Hanyu Zheng (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hanyu Zheng updated KAFKA-15629: Fix Version/s: 3.7.0 > proposal to introduce IQv2 Query Types: TimestampedKeyQuery and >

[jira] [Updated] (KAFKA-15527) Add reverseRange and reverseAll query over kv-store in IQv2

2023-10-19 Thread Hanyu Zheng (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hanyu Zheng updated KAFKA-15527: Fix Version/s: 3.7.0 > Add reverseRange and reverseAll query over kv-store in IQv2 >

Re: [PR] KAFKA-14808: fix leaderless partition issue when controller removes u… [kafka]

2023-10-19 Thread via GitHub
github-actions[bot] commented on PR #13451: URL: https://github.com/apache/kafka/pull/13451#issuecomment-1772023180 This PR is being marked as stale since it has not had any activity in 90 days. If you would like to keep this PR alive, please ask a committer for review. If the PR has

[jira] [Commented] (KAFKA-7699) Improve wall-clock time punctuations

2023-10-19 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1550#comment-1550 ] Matthias J. Sax commented on KAFKA-7699: Happy to support you. The KIP wiki page describes how it

[jira] [Commented] (KAFKA-15653) NPE in ChunkedByteStream

2023-10-19 Thread Ismael Juma (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1549#comment-1549 ] Ismael Juma commented on KAFKA-15653: - cc [~divijvaidya]  > NPE in ChunkedByteStream >

[jira] [Comment Edited] (KAFKA-15653) NPE in ChunkedByteStream

2023-10-19 Thread Travis Bischel (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1542#comment-1542 ] Travis Bischel edited comment on KAFKA-15653 at 10/20/23 2:55 AM: --

Re: [PR] KAFKA-15607:Possible NPE is thrown in MirrorCheckpointTask [kafka]

2023-10-19 Thread via GitHub
hudeqi commented on code in PR #14587: URL: https://github.com/apache/kafka/pull/14587#discussion_r1366378637 ## connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorCheckpointTaskTest.java: ## @@ -169,6 +169,33 @@ public void testSyncOffset() {

Re: [PR] KAFKA-15607:Possible NPE is thrown in MirrorCheckpointTask [kafka]

2023-10-19 Thread via GitHub
hudeqi commented on PR #14587: URL: https://github.com/apache/kafka/pull/14587#issuecomment-1771985878 > Thanks @hudeqi, I think this is reasonable. Do you know why Sarama sets offsets to -1? If it's for normal operations and not indicative of something wrong, we may not even need to log a

[jira] [Comment Edited] (KAFKA-15657) Unexpected errors when producing transactionally in 3.6

2023-10-19 Thread Travis Bischel (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1537#comment-1537 ] Travis Bischel edited comment on KAFKA-15657 at 10/20/23 2:35 AM: -- re:

[jira] [Commented] (KAFKA-15653) NPE in ChunkedByteStream

2023-10-19 Thread Travis Bischel (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1542#comment-1542 ] Travis Bischel commented on KAFKA-15653: Not just : {noformat} [2023-10-20 02:31:00,204] ERROR

[jira] [Updated] (KAFKA-15653) NPE in ChunkedByteStream

2023-10-19 Thread Travis Bischel (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Travis Bischel updated KAFKA-15653: --- Summary: NPE in ChunkedByteStream (was: NPE in ChunkedByteStream.) > NPE in

[PR] KAFKA-15346: add support for single-Key_single-timestamp IQs with versioned state stores (KIP-960) [kafka]

2023-10-19 Thread via GitHub
aliehsaeedii opened a new pull request, #14596: URL: https://github.com/apache/kafka/pull/14596 This PR implements KIP-960. -- 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

[jira] [Commented] (KAFKA-15657) Unexpected errors when producing transactionally in 3.6

2023-10-19 Thread Travis Bischel (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1537#comment-1537 ] Travis Bischel commented on KAFKA-15657: re: first comment – the client doesn't advance to

[PR] MINOR: Enable kraft test in kafka.api and kafka.network [kafka]

2023-10-19 Thread via GitHub
dengziming opened a new pull request, #14595: URL: https://github.com/apache/kafka/pull/14595 *More detailed description of your change, if necessary. The PR title and PR message become the squashed commit message, so use a separate comment to ping reviewers.* *Summary of

Re: [PR] KAFKA-15481: Fix concurrency bug in RemoteIndexCache [kafka]

2023-10-19 Thread via GitHub
iit2009060 commented on PR #14483: URL: https://github.com/apache/kafka/pull/14483#issuecomment-1771965660 > @iit2009060 , do you have any comments to this PR? @showuon No , I am good . Thanks @jeel2420 for addressing the review comments. -- This is an automated message from the

Re: [PR] MINOR:Remove unused method parameter in ConsumerGroupCommand [kafka]

2023-10-19 Thread via GitHub
showuon merged PR #14585: URL: https://github.com/apache/kafka/pull/14585 -- 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:

Re: [PR] MINOR:Remove unused method parameter in ConsumerGroupCommand [kafka]

2023-10-19 Thread via GitHub
showuon commented on PR #14585: URL: https://github.com/apache/kafka/pull/14585#issuecomment-1771961258 Failed tests are unrelated: ``` Build / JDK 17 and Scala 2.13 /

Re: [PR] KAFKA-15481: Fix concurrency bug in RemoteIndexCache [kafka]

2023-10-19 Thread via GitHub
showuon commented on PR #14483: URL: https://github.com/apache/kafka/pull/14483#issuecomment-1771958677 @iit2009060 , do you have any comments to this PR? -- 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

Re: [PR] KAFKA-15566: Fix flaky tests in FetchRequestTest.scala in KRaft mode [kafka]

2023-10-19 Thread via GitHub
showuon merged PR #14573: URL: https://github.com/apache/kafka/pull/14573 -- 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:

Re: [PR] KAFKA-15566: Fix flaky tests in FetchRequestTest.scala in KRaft mode [kafka]

2023-10-19 Thread via GitHub
showuon commented on PR #14573: URL: https://github.com/apache/kafka/pull/14573#issuecomment-1771954831 Ran 3 times of CI build and no fetchRequestTest failures. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[jira] [Commented] (KAFKA-15657) Unexpected errors when producing transactionally in 3.6

2023-10-19 Thread Justine Olshan (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1526#comment-1526 ] Justine Olshan commented on KAFKA-15657: [~twmb] Can you confirm if the AddPartitionsToTxn calls

[jira] [Commented] (KAFKA-15657) Unexpected errors when producing transactionally in 3.6

2023-10-19 Thread Justine Olshan (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1524#comment-1524 ] Justine Olshan commented on KAFKA-15657: Hey Travis. INVALID_TXN_STATE likely indicates there

[jira] [Created] (KAFKA-15657) Unexpected errors when producing transactionally in 3.6

2023-10-19 Thread Travis Bischel (Jira)
Travis Bischel created KAFKA-15657: -- Summary: Unexpected errors when producing transactionally in 3.6 Key: KAFKA-15657 URL: https://issues.apache.org/jira/browse/KAFKA-15657 Project: Kafka

Re: [PR] KAFKA-15605: Fix topic deletion handling during ZK migration [kafka]

2023-10-19 Thread via GitHub
mumrah commented on code in PR #14545: URL: https://github.com/apache/kafka/pull/14545#discussion_r1366294162 ## metadata/src/main/java/org/apache/kafka/metadata/migration/KRaftMigrationZkWriter.java: ## @@ -146,6 +147,15 @@ void handleTopicsSnapshot(TopicsImage topicsImage,

[jira] [Updated] (KAFKA-14264) Refactor coordinator code

2023-10-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-14264: -- Parent: KAFKA-14246 Issue Type: Sub-task (was: Task) > Refactor coordinator code >

[jira] [Updated] (KAFKA-14468) Refactor Commit Logic

2023-10-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-14468: -- Parent: KAFKA-14246 Issue Type: Sub-task (was: Task) > Refactor Commit Logic >

Re: [PR] KAFKA-15605: Fix topic deletion handling during ZK migration [kafka]

2023-10-19 Thread via GitHub
mumrah commented on code in PR #14545: URL: https://github.com/apache/kafka/pull/14545#discussion_r1366292982 ## core/src/main/scala/kafka/zk/migration/ZkTopicMigrationClient.scala: ## @@ -47,8 +47,14 @@ class ZkTopicMigrationClient(zkClient: KafkaZkClient) extends

[jira] [Updated] (KAFKA-15639) Investigate ConsumerNetworkThreadTest's testResetPositionsProcessFailureIsIgnored

2023-10-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15639: -- Parent: KAFKA-14246 Issue Type: Sub-task (was: Task) > Investigate

[jira] [Updated] (KAFKA-14247) Implement EventHandler interface and DefaultEventHandler for Consumer

2023-10-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-14247: -- Parent: KAFKA-14246 Issue Type: Sub-task (was: Task) > Implement EventHandler interface and

[jira] [Updated] (KAFKA-15270) Integration tests for AsyncConsumer simple consume case

2023-10-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15270: -- Parent: KAFKA-14246 Issue Type: Sub-task (was: Task) > Integration tests for AsyncConsumer

[jira] [Updated] (KAFKA-15306) Integrate committed offsets logic when updating fetching positions

2023-10-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15306: -- Parent: KAFKA-14246 Issue Type: Sub-task (was: Task) > Integrate committed offsets logic

[jira] [Updated] (KAFKA-15115) Implement resetPositions functionality in OffsetsRequestManager

2023-10-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15115: -- Parent: KAFKA-14246 Issue Type: Sub-task (was: Task) > Implement resetPositions

[jira] [Updated] (KAFKA-14950) Implement assign() and assignment()

2023-10-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-14950: -- Parent: KAFKA-14246 Issue Type: Sub-task (was: Task) > Implement assign() and assignment() >

[jira] [Updated] (KAFKA-15163) Implement validatePositions functionality for new KafkaConsumer

2023-10-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15163: -- Parent: KAFKA-14246 Issue Type: Sub-task (was: Task) > Implement validatePositions

[jira] [Updated] (KAFKA-15164) Extract reusable logic from OffsetsForLeaderEpochClient

2023-10-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15164: -- Parent: KAFKA-14246 Issue Type: Sub-task (was: Task) > Extract reusable logic from

[jira] [Updated] (KAFKA-15174) Ensure the correct thread is executing the callbacks

2023-10-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15174: -- Parent: KAFKA-14246 Issue Type: Sub-task (was: Task) > Ensure the correct thread is

[jira] [Updated] (KAFKA-14196) Duplicated consumption during rebalance, causing OffsetValidationTest to act flaky

2023-10-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-14196: -- Labels: new-consumer-threading-should-fix (was: consumer-threading-refactor

[jira] [Updated] (KAFKA-14252) Create background thread skeleton for new Consumer threading model

2023-10-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-14252: -- Parent: KAFKA-14246 Issue Type: Sub-task (was: Task) > Create background thread skeleton for

[jira] [Commented] (KAFKA-15656) Frequent INVALID_RECORD on Kafka 3.6

2023-10-19 Thread Travis Bischel (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1515#comment-1515 ] Travis Bischel commented on KAFKA-15656: Note that if I change my code to retry on

[jira] [Updated] (KAFKA-15631) Do not send new heartbeat request while another one in-flight

2023-10-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15631: -- Labels: kip-848 kip-848-client-support kip-848-e2e kip-848-preview (was: kip-848-client-support

[jira] [Updated] (KAFKA-15282) Implement client support for KIP-848 client-side assignors

2023-10-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15282: -- Labels: kip-848 kip-848-client-support (was: consumer-threading-refactor kip-848

[jira] [Updated] (KAFKA-15279) Implement client support for KIP-848 assignment RPCs

2023-10-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15279: -- Labels: kip-848 kip-848-client-support (was: consumer-threading-refactor kip-848

[jira] [Updated] (KAFKA-15278) Implement client support for KIP-848 ConsumerGroupHeartbeat protocol RPC

2023-10-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15278: -- Labels: kip-848 kip-848-client-support kip-848-e2e kip-848-preview (was: consumer-threading-refactor

[jira] [Updated] (KAFKA-15651) Investigate auto commit guarantees during Consumer.assign()

2023-10-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15651: -- Labels: consumer-threading-refactor kip-848-preview (was: consumer-threading-refactor

[jira] [Updated] (KAFKA-15548) Ensure all resources created by the Consumer are close()-ed properly

2023-10-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15548: -- Labels: consumer-threading-refactor kip-848 kip-848-e2e kip-848-preview (was:

[jira] [Updated] (KAFKA-15637) Investigate FetcherTest's/FetchRequestManager's testFetchCompletedBeforeHandlerAdded

2023-10-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15637: -- Labels: consumer-threading-refactor (was: consumer-threading-refactor kip-848-client-support) >

[jira] [Updated] (KAFKA-15638) Investigate ConsumerNetworkThreadTest's testPollResultTimer

2023-10-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15638: -- Labels: consumer-threading-refactor (was: consumer-threading-refactor kip-848-client-support) >

[jira] [Updated] (KAFKA-15652) Add unit/integration tests to verify OffsetOutOfRangeException is thrown for OffsetFetcherUtils.getOffsetResetTimestamp()

2023-10-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15652: -- Labels: consumer-threading-refactor (was: consumer-threading-refactor kip-848-client-support) > Add

[jira] [Updated] (KAFKA-15557) Investigate FetcherTest's/FetchRequestManager's duplicate metadata update in assignFromUserNoId

2023-10-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15557: -- Labels: consumer-threading-refactor (was: consumer-threading-refactor kip-848-client-support) >

[jira] [Updated] (KAFKA-15558) Determine if Timer should be used elsewhere in PrototypeAsyncConsumer.updateFetchPositions()

2023-10-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15558: -- Labels: consumer-threading-refactor kip-848-preview (was: consumer-threading-refactor

[jira] [Updated] (KAFKA-15636) Investigate FetcherTest's/FetchRequestManager's testFetchResponseMetrics

2023-10-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15636: -- Labels: consumer-threading-refactor (was: consumer-threading-refactor kip-848-client-support) >

[jira] [Updated] (KAFKA-15615) Improve handling of fetching during metadata updates

2023-10-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15615: -- Labels: consumer-threading-refactor kip-848-preview (was: consumer-threading-refactor

[jira] [Updated] (KAFKA-15534) Propagate client response time when timeout to the request handler

2023-10-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15534: -- Labels: consumer-threading-refactor kip-848 kip-848-e2e kip-848-preview (was:

[jira] [Updated] (KAFKA-15617) Investigate FetcherTest's/FetchRequestManager's testFetchingPendingPartitions and testInflightFetchOnPendingPartitions overlap

2023-10-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15617: -- Labels: consumer-threading-refactor (was: consumer-threading-refactor kip-848-client-support) >

[jira] [Updated] (KAFKA-15556) Remove NetworkClientDelegate methods isUnavailable, maybeThrowAuthFailure, and tryConnect

2023-10-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15556: -- Labels: consumer-threading-refactor kip-848-preview (was: consumer-threading-refactor

[jira] [Updated] (KAFKA-15606) Investigate FetcherTest's/FetchRequestManager's testCompletedFetchRemoval

2023-10-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15606: -- Labels: consumer-threading-refactor (was: consumer-threading-refactor kip-848-client-support) >

[jira] [Updated] (KAFKA-15634) Investigate FetcherTest's/FetchRequestManager's testQuotaMetrics

2023-10-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15634: -- Labels: consumer-threading-refactor (was: consumer-threading-refactor kip-848-client-support) >

[jira] [Updated] (KAFKA-15635) Investigate FetcherTest's/FetchRequestManager's testFetcherLeadMetric

2023-10-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15635: -- Labels: consumer-threading-refactor (was: consumer-threading-refactor kip-848-client-support) >

[jira] [Updated] (KAFKA-15550) OffsetsForTimes validation for negative timestamps in new consumer

2023-10-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15550: -- Labels: consumer-threading-refactor kip-848 kip-848-preview (was: consumer-threading-refactor

[jira] [Updated] (KAFKA-15639) Investigate ConsumerNetworkThreadTest's testResetPositionsProcessFailureIsIgnored

2023-10-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15639: -- Component/s: unit tests > Investigate ConsumerNetworkThreadTest's >

[jira] [Updated] (KAFKA-15639) Investigate ConsumerNetworkThreadTest's testResetPositionsProcessFailureIsIgnored

2023-10-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15639: -- Summary: Investigate ConsumerNetworkThreadTest's testResetPositionsProcessFailureIsIgnored (was:

[jira] [Updated] (KAFKA-14724) Port tests in FetcherTest to FetchRequestManagerTest

2023-10-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-14724: -- Component/s: unit tests > Port tests in FetcherTest to FetchRequestManagerTest >

[jira] [Created] (KAFKA-15656) Frequent INVALID_RECORD on Kafka 3.6

2023-10-19 Thread Travis Bischel (Jira)
Travis Bischel created KAFKA-15656: -- Summary: Frequent INVALID_RECORD on Kafka 3.6 Key: KAFKA-15656 URL: https://issues.apache.org/jira/browse/KAFKA-15656 Project: Kafka Issue Type: Bug

[jira] [Updated] (KAFKA-15617) Investigate FetcherTest's/FetchRequestManager's testFetchingPendingPartitions and testInflightFetchOnPendingPartitions overlap

2023-10-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15617: -- Component/s: unit tests Labels: consumer-threading-refactor kip-848-client-support (was:

[jira] [Updated] (KAFKA-15636) Investigate FetcherTest's/FetchRequestManager's testFetchResponseMetrics

2023-10-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15636: -- Component/s: unit tests Labels: consumer-threading-refactor kip-848-client-support (was:

[jira] [Updated] (KAFKA-15638) Investigate ConsumerNetworkThreadTest's testPollResultTimer

2023-10-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15638: -- Component/s: unit tests Labels: consumer-threading-refactor kip-848-client-support (was:

[jira] [Updated] (KAFKA-15637) Investigate FetcherTest's/FetchRequestManager's testFetchCompletedBeforeHandlerAdded

2023-10-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15637: -- Component/s: unit tests Labels: consumer-threading-refactor kip-848-client-support (was:

[jira] [Updated] (KAFKA-15634) Investigate FetcherTest's/FetchRequestManager's testQuotaMetrics

2023-10-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15634: -- Component/s: unit tests Labels: consumer-threading-refactor kip-848-client-support (was:

[jira] [Updated] (KAFKA-15557) Investigate FetcherTest's/FetchRequestManager's duplicate metadata update in assignFromUserNoId

2023-10-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15557: -- Component/s: unit tests Labels: consumer-threading-refactor kip-848-client-support (was:

[jira] [Updated] (KAFKA-15606) Investigate FetcherTest's/FetchRequestManager's testCompletedFetchRemoval

2023-10-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15606: -- Labels: consumer-threading-refactor kip-848-client-support (was: consumer-threading-refactor

[jira] [Updated] (KAFKA-15652) Add unit/integration tests to verify OffsetOutOfRangeException is thrown for OffsetFetcherUtils.getOffsetResetTimestamp()

2023-10-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15652: -- Component/s: unit tests Labels: consumer-threading-refactor kip-848-client-support (was:

[jira] [Updated] (KAFKA-15635) Investigate FetcherTest's/FetchRequestManager's testFetcherLeadMetric

2023-10-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15635: -- Component/s: unit tests Labels: consumer-threading-refactor kip-848-client-support (was:

[jira] [Updated] (KAFKA-15638) Investigate ConsumerNetworkThreadTest's testPollResultTimer

2023-10-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15638: -- Summary: Investigate ConsumerNetworkThreadTest's testPollResultTimer (was: Investigate

[jira] [Updated] (KAFKA-15606) Investigate FetcherTest's/FetchRequestManager's testCompletedFetchRemoval

2023-10-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15606: -- Component/s: unit tests > Investigate FetcherTest's/FetchRequestManager's testCompletedFetchRemoval >

[jira] [Updated] (KAFKA-15277) Design & implement support for internal Consumer delegates

2023-10-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15277: -- Labels: consumer-threading-refactor kip-848 kip-848-e2e kip-848-preview (was:

[jira] [Updated] (KAFKA-15556) Remove NetworkClientDelegate methods isUnavailable, maybeThrowAuthFailure, and tryConnect

2023-10-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15556: -- Component/s: clients consumer > Remove NetworkClientDelegate methods isUnavailable,

[jira] [Updated] (KAFKA-15558) Determine if Timer should be used elsewhere in PrototypeAsyncConsumer.updateFetchPositions()

2023-10-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15558: -- Component/s: clients consumer > Determine if Timer should be used elsewhere in >

[jira] [Updated] (KAFKA-15615) Improve handling of fetching during metadata updates

2023-10-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15615: -- Component/s: clients consumer > Improve handling of fetching during metadata updates

[jira] [Updated] (KAFKA-15551) Evaluate conditions for short circuiting consumer API calls

2023-10-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15551: -- Component/s: clients > Evaluate conditions for short circuiting consumer API calls >

[jira] [Updated] (KAFKA-15553) Review committed offset refresh logic

2023-10-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15553: -- Component/s: clients > Review committed offset refresh logic > -

[jira] [Updated] (KAFKA-15250) DefaultBackgroundThread is running tight loop

2023-10-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15250: -- Component/s: clients > DefaultBackgroundThread is running tight loop >

[jira] [Updated] (KAFKA-15173) Consumer event queues should be bounded

2023-10-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15173: -- Component/s: clients > Consumer event queues should be bounded >

[jira] [Updated] (KAFKA-15320) Document event queueing patterns

2023-10-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15320: -- Component/s: clients consumer > Document event queueing patterns >

[jira] [Updated] (KAFKA-15606) Investigate FetcherTest's/FetchRequestManager's testCompletedFetchRemoval

2023-10-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15606: -- Labels: consumer-threading-refactor kip-848-client-support kip-848-preview (was:

[jira] [Updated] (KAFKA-15634) Investigate FetcherTest's/FetchRequestManager's testQuotaMetrics

2023-10-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15634: -- Labels: consumer-threading-refactor kip-848-client-support kip-848-preview (was:

[jira] [Updated] (KAFKA-15557) Investigate FetcherTest's/FetchRequestManager's duplicate metadata update in assignFromUserNoId

2023-10-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15557: -- Labels: consumer-threading-refactor kip-848-client-support kip-848-preview (was:

[jira] [Updated] (KAFKA-15651) Investigate auto commit guarantees during Consumer.assign()

2023-10-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15651: -- Labels: consumer-threading-refactor kip-848-client-support kip-848-preview (was:

[jira] [Updated] (KAFKA-15638) Investigate ConsumerNetworkThread's testPollResultTimer

2023-10-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15638: -- Labels: consumer-threading-refactor kip-848-client-support kip-848-preview (was:

[jira] [Updated] (KAFKA-15617) Investigate FetcherTest's/FetchRequestManager's testFetchingPendingPartitions and testInflightFetchOnPendingPartitions overlap

2023-10-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15617: -- Labels: consumer-threading-refactor kip-848-client-support kip-848-preview (was:

[jira] [Updated] (KAFKA-15615) Improve handling of fetching during metadata updates

2023-10-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15615: -- Labels: consumer-threading-refactor kip-848-client-support kip-848-preview (was:

[jira] [Updated] (KAFKA-15636) Investigate FetcherTest's/FetchRequestManager's testFetchResponseMetrics

2023-10-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15636: -- Labels: consumer-threading-refactor kip-848-client-support kip-848-preview (was:

[jira] [Updated] (KAFKA-15558) Determine if Timer should be used elsewhere in PrototypeAsyncConsumer.updateFetchPositions()

2023-10-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15558: -- Labels: consumer-threading-refactor kip-848-client-support kip-848-preview (was:

[jira] [Updated] (KAFKA-15637) Investigate FetcherTest's/FetchRequestManager's testFetchCompletedBeforeHandlerAdded

2023-10-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15637: -- Labels: consumer-threading-refactor kip-848-client-support kip-848-preview (was:

[jira] [Updated] (KAFKA-15635) Investigate FetcherTest's/FetchRequestManager's testFetcherLeadMetric

2023-10-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15635: -- Labels: consumer-threading-refactor kip-848-client-support kip-848-preview (was:

[jira] [Updated] (KAFKA-15652) Add unit/integration tests to verify OffsetOutOfRangeException is thrown for OffsetFetcherUtils.getOffsetResetTimestamp()

2023-10-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15652: -- Labels: consumer-threading-refactor kip-848-client-support kip-848-preview (was:

[jira] [Commented] (KAFKA-14402) Transactions Server Side Defense

2023-10-19 Thread Travis Bischel (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1512#comment-1512 ] Travis Bischel commented on KAFKA-14402: Thanks, that is clearer. I note that clients also work

[jira] [Updated] (KAFKA-15556) Remove NetworkClientDelegate methods isUnavailable, maybeThrowAuthFailure, and tryConnect

2023-10-19 Thread Kirk True (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True updated KAFKA-15556: -- Labels: consumer-threading-refactor kip-848-client-support kip-848-preview (was:

  1   2   3   >