[jira] [Commented] (KAFKA-12960) WindowStore and SessionStore do not enforce strict retention time

[ https://issues.apache.org/jira/browse/KAFKA-12960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17632297#comment-17632297 ] Lucas Brutschy commented on KAFKA-12960: There is a third PR here: https://githu

[jira] [Resolved] (KAFKA-14309) Kafka Streams upgrade tests do not cover for FK-joins

[ https://issues.apache.org/jira/browse/KAFKA-14309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy resolved KAFKA-14309. Resolution: Fixed > Kafka Streams upgrade tests do not cover for FK-joins > --

[jira] [Updated] (KAFKA-14415) ThreadCache is getting slower with every additional state store

[ https://issues.apache.org/jira/browse/KAFKA-14415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy updated KAFKA-14415: --- Summary: ThreadCache is getting slower with every additional state store (was: `ThreadCache

[jira] [Assigned] (KAFKA-14415) ThreadCache is getting slower with every additional state store

[ https://issues.apache.org/jira/browse/KAFKA-14415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy reassigned KAFKA-14415: -- Assignee: Lucas Brutschy > ThreadCache is getting slower with every additional state

[jira] [Created] (KAFKA-14415) `ThreadCache` is getting slower with every additional state store

Lucas Brutschy created KAFKA-14415: -- Summary: `ThreadCache` is getting slower with every additional state store Key: KAFKA-14415 URL: https://issues.apache.org/jira/browse/KAFKA-14415 Project: Kafka

[jira] [Updated] (KAFKA-14415) ThreadCache is getting slower with every additional state store

[ https://issues.apache.org/jira/browse/KAFKA-14415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy updated KAFKA-14415: --- Description: There are a few lines in `ThreadCache` that I think should be optimized. `size

[jira] [Resolved] (KAFKA-14299) Benchmark and stabilize state updater

[ https://issues.apache.org/jira/browse/KAFKA-14299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy resolved KAFKA-14299. Assignee: Lucas Brutschy Resolution: Fixed > Benchmark and stabilize state updater >

[jira] [Commented] (KAFKA-12679) Rebalancing a restoring or running task may cause directory livelocking with newly created task

[ https://issues.apache.org/jira/browse/KAFKA-12679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17640125#comment-17640125 ] Lucas Brutschy commented on KAFKA-12679: I addressed this in the new state resto

[jira] [Commented] (KAFKA-14415) ThreadCache is getting slower with every additional state store

[ https://issues.apache.org/jira/browse/KAFKA-14415?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17640936#comment-17640936 ] Lucas Brutschy commented on KAFKA-14415: I fear the tool for generating this is

[jira] [Created] (KAFKA-14432) RocksDBStore relies on finalizers to not leak memory

Lucas Brutschy created KAFKA-14432: -- Summary: RocksDBStore relies on finalizers to not leak memory Key: KAFKA-14432 URL: https://issues.apache.org/jira/browse/KAFKA-14432 Project: Kafka Issu

[jira] [Updated] (KAFKA-14432) RocksDBStore relies on finalizers to not leak memory

[ https://issues.apache.org/jira/browse/KAFKA-14432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy updated KAFKA-14432: --- Description: Relying on finalizers in RocksDB has been deprecated for a long time, and star

[jira] [Updated] (KAFKA-14309) Kafka Streams upgrade tests do not cover for FK-joins

[ https://issues.apache.org/jira/browse/KAFKA-14309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy updated KAFKA-14309: --- Component/s: streams > Kafka Streams upgrade tests do not cover for FK-joins > -

[jira] [Assigned] (KAFKA-14278) Convert INVALID_PRODUCER_EPOCH into PRODUCER_FENCED TxnOffsetCommit

[ https://issues.apache.org/jira/browse/KAFKA-14278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy reassigned KAFKA-14278: -- Assignee: Lucas Brutschy > Convert INVALID_PRODUCER_EPOCH into PRODUCER_FENCED TxnOff

[jira] [Updated] (KAFKA-14278) Convert INVALID_PRODUCER_EPOCH into PRODUCER_FENCED TxnOffsetCommit

[ https://issues.apache.org/jira/browse/KAFKA-14278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy updated KAFKA-14278: --- Component/s: producer streams > Convert INVALID_PRODUCER_EPOCH into PRODUC

[jira] [Commented] (KAFKA-12679) Rebalancing a restoring or running task may cause directory livelocking with newly created task

[ https://issues.apache.org/jira/browse/KAFKA-12679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17642502#comment-17642502 ] Lucas Brutschy commented on KAFKA-12679: I referenced this ticket in the PR > R

[jira] [Updated] (KAFKA-14432) RocksDBStore relies on finalizers to not leak memory

[ https://issues.apache.org/jira/browse/KAFKA-14432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy updated KAFKA-14432: --- Priority: Blocker (was: Major) > RocksDBStore relies on finalizers to not leak memory > ---

[jira] [Updated] (KAFKA-14432) RocksDBStore relies on finalizers to not leak memory

[ https://issues.apache.org/jira/browse/KAFKA-14432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy updated KAFKA-14432: --- Fix Version/s: 3.4.0 > RocksDBStore relies on finalizers to not leak memory > --

[jira] [Commented] (KAFKA-14054) Unexpected client shutdown as TimeoutException is thrown as IllegalStateException

[ https://issues.apache.org/jira/browse/KAFKA-14054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17647099#comment-17647099 ] Lucas Brutschy commented on KAFKA-14054: Bug confirmed with 3.1.1. > Unexpected

[jira] [Created] (KAFKA-14530) Check state updater more than once in process loops

Lucas Brutschy created KAFKA-14530: -- Summary: Check state updater more than once in process loops Key: KAFKA-14530 URL: https://issues.apache.org/jira/browse/KAFKA-14530 Project: Kafka Issue

[jira] [Assigned] (KAFKA-14530) Check state updater more than once in process loops

[ https://issues.apache.org/jira/browse/KAFKA-14530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy reassigned KAFKA-14530: -- Assignee: Lucas Brutschy > Check state updater more than once in process loops >

[jira] [Created] (KAFKA-14532) IllegalStateException when fetch failure happens after assignment changed

Lucas Brutschy created KAFKA-14532: -- Summary: IllegalStateException when fetch failure happens after assignment changed Key: KAFKA-14532 URL: https://issues.apache.org/jira/browse/KAFKA-14532 Project

[jira] [Updated] (KAFKA-14532) IllegalStateException when fetch failure happens after assignment changed

[ https://issues.apache.org/jira/browse/KAFKA-14532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy updated KAFKA-14532: --- Description: On master, all our long-running test jobs are running into this exception:   

[jira] [Updated] (KAFKA-14532) IllegalStateException when fetch failure happens after assignment changed

[ https://issues.apache.org/jira/browse/KAFKA-14532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy updated KAFKA-14532: --- Description: On master, all our long-running test jobs are running into this exception:  {co

[jira] [Updated] (KAFKA-14532) IllegalStateException when fetch failure happens after assignment changed

[ https://issues.apache.org/jira/browse/KAFKA-14532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy updated KAFKA-14532: --- Priority: Blocker (was: Major) > IllegalStateException when fetch failure happens after ass

[jira] [Updated] (KAFKA-14532) IllegalStateException when fetch failure happens after assignment changed

[ https://issues.apache.org/jira/browse/KAFKA-14532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy updated KAFKA-14532: --- Labels: clients (was: ) > IllegalStateException when fetch failure happens after assignment

[jira] [Updated] (KAFKA-14532) IllegalStateException when fetch failure happens after assignment changed

[ https://issues.apache.org/jira/browse/KAFKA-14532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy updated KAFKA-14532: --- Labels: (was: clients) > IllegalStateException when fetch failure happens after assignment

[jira] [Resolved] (KAFKA-14343) Write upgrade/downgrade tests for enabling the state updater

[ https://issues.apache.org/jira/browse/KAFKA-14343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy resolved KAFKA-14343. Resolution: Fixed > Write upgrade/downgrade tests for enabling the state updater > --

[jira] [Assigned] (KAFKA-12689) Remove deprecated EOS configs

[ https://issues.apache.org/jira/browse/KAFKA-12689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy reassigned KAFKA-12689: -- Assignee: Lucas Brutschy (was: loboxu) > Remove deprecated EOS configs > ---

[jira] [Updated] (KAFKA-10733) Enhance Transactional Producer Exception Handling

[ https://issues.apache.org/jira/browse/KAFKA-10733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy updated KAFKA-10733: --- Summary: Enhance Transactional Producer Exception Handling (was: Enforce exception thrown f

[jira] [Assigned] (KAFKA-10733) Enhance Transactional Producer Exception Handling

[ https://issues.apache.org/jira/browse/KAFKA-10733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy reassigned KAFKA-10733: -- Assignee: Lucas Brutschy > Enhance Transactional Producer Exception Handling > --

[jira] [Created] (KAFKA-14278) Convert INVALID_PRODUCER_EPOCH into PRODUCER_FENCED TxnOffsetCommit

Lucas Brutschy created KAFKA-14278: -- Summary: Convert INVALID_PRODUCER_EPOCH into PRODUCER_FENCED TxnOffsetCommit Key: KAFKA-14278 URL: https://issues.apache.org/jira/browse/KAFKA-14278 Project: Kafk

[jira] [Assigned] (KAFKA-12307) Wrap non-fatal exception as AbortableException

[ https://issues.apache.org/jira/browse/KAFKA-12307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy reassigned KAFKA-12307: -- Assignee: Lucas Brutschy > Wrap non-fatal exception as AbortableException > -

[jira] [Updated] (KAFKA-12307) Wrap non-fatal exception as AbortableException

[ https://issues.apache.org/jira/browse/KAFKA-12307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy updated KAFKA-12307: --- Summary: Wrap non-fatal exception as AbortableException (was: Wrap non-fatal exception as C

[jira] [Updated] (KAFKA-14199) Installed kafka in ubuntu and not able to access in browser. org.apache.kafka.common.network.InvalidReceiveException: Invalid receive (size = 1195725856 larger than 104

[ https://issues.apache.org/jira/browse/KAFKA-14199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy updated KAFKA-14199: --- Component/s: (was: streams) > Installed kafka in ubuntu and not able to access in browse

[jira] [Created] (KAFKA-14299) Benchmark and stabilize state updater

Lucas Brutschy created KAFKA-14299: -- Summary: Benchmark and stabilize state updater Key: KAFKA-14299 URL: https://issues.apache.org/jira/browse/KAFKA-14299 Project: Kafka Issue Type: Task

[jira] [Created] (KAFKA-14309) Kafka Streams upgrade tests do not cover for FK-joins

Lucas Brutschy created KAFKA-14309: -- Summary: Kafka Streams upgrade tests do not cover for FK-joins Key: KAFKA-14309 URL: https://issues.apache.org/jira/browse/KAFKA-14309 Project: Kafka Iss

[jira] [Assigned] (KAFKA-14309) Kafka Streams upgrade tests do not cover for FK-joins

[ https://issues.apache.org/jira/browse/KAFKA-14309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy reassigned KAFKA-14309: -- Assignee: Lucas Brutschy > Kafka Streams upgrade tests do not cover for FK-joins > --

[jira] [Created] (KAFKA-14343) Write upgrade/downgrade tests for enabling the state updater

Lucas Brutschy created KAFKA-14343: -- Summary: Write upgrade/downgrade tests for enabling the state updater Key: KAFKA-14343 URL: https://issues.apache.org/jira/browse/KAFKA-14343 Project: Kafka

[jira] [Assigned] (KAFKA-14294) Kafka Streams should commit transaction when no records are processed

[ https://issues.apache.org/jira/browse/KAFKA-14294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy reassigned KAFKA-14294: -- Assignee: Lucas Brutschy > Kafka Streams should commit transaction when no records ar

[jira] [Assigned] (KAFKA-14294) Kafka Streams should commit transaction when no records are processed

[ https://issues.apache.org/jira/browse/KAFKA-14294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy reassigned KAFKA-14294: -- Assignee: (was: Lucas Brutschy) > Kafka Streams should commit transaction when no

[jira] [Commented] (KAFKA-12679) Rebalancing a restoring or running task may cause directory livelocking with newly created task

[ https://issues.apache.org/jira/browse/KAFKA-12679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17847334#comment-17847334 ] Lucas Brutschy commented on KAFKA-12679: Hey [~coltmcnealy-lh]. It is true that

[jira] [Updated] (KAFKA-12679) Rebalancing a restoring or running task may cause directory livelocking with newly created task

[ https://issues.apache.org/jira/browse/KAFKA-12679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy updated KAFKA-12679: --- Fix Version/s: 3.8.0 (was: 3.7.0) > Rebalancing a restoring or runnin

[jira] [Comment Edited] (KAFKA-12679) Rebalancing a restoring or running task may cause directory livelocking with newly created task

[ https://issues.apache.org/jira/browse/KAFKA-12679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17847334#comment-17847334 ] Lucas Brutschy edited comment on KAFKA-12679 at 5/17/24 2:20 PM: -

[jira] [Comment Edited] (KAFKA-12679) Rebalancing a restoring or running task may cause directory livelocking with newly created task

[ https://issues.apache.org/jira/browse/KAFKA-12679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17847334#comment-17847334 ] Lucas Brutschy edited comment on KAFKA-12679 at 5/17/24 2:26 PM: -

[jira] [Commented] (KAFKA-17299) Kafka streams consumer stops consumption

[ https://issues.apache.org/jira/browse/KAFKA-17299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17872077#comment-17872077 ] Lucas Brutschy commented on KAFKA-17299: Hey. The change looks safe to me. How

[jira] [Commented] (KAFKA-16290) Investigate propagating subscription state updates via queues

[ https://issues.apache.org/jira/browse/KAFKA-16290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17873966#comment-17873966 ] Lucas Brutschy commented on KAFKA-16290: Nice! > Investigate propagating subscr

[jira] [Commented] (KAFKA-16567) Add New Stream Metrics based on KIP-869

[ https://issues.apache.org/jira/browse/KAFKA-16567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17876618#comment-17876618 ] Lucas Brutschy commented on KAFKA-16567: [~balajirrao] I think you are right, th

[jira] [Resolved] (KAFKA-16567) Add New Stream Metrics based on KIP-869

[ https://issues.apache.org/jira/browse/KAFKA-16567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy resolved KAFKA-16567. Resolution: Fixed > Add New Stream Metrics based on KIP-869 >

[jira] [Commented] (KAFKA-17229) Multiple punctuators that together exceed the transaction timeout cause ProducerFencedException

[ https://issues.apache.org/jira/browse/KAFKA-17229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17876628#comment-17876628 ] Lucas Brutschy commented on KAFKA-17229: Yes. This should be fixed in the non-pr

[jira] [Updated] (KAFKA-16336) Remove Deprecated metric standby-process-ratio

[ https://issues.apache.org/jira/browse/KAFKA-16336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy updated KAFKA-16336: --- Fix Version/s: (was: 4.0.0) > Remove Deprecated metric standby-process-ratio > -

[jira] [Updated] (KAFKA-16599) LegacyConsumer: Always await async commit callbacks in commitSync and close

[ https://issues.apache.org/jira/browse/KAFKA-16599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy updated KAFKA-16599: --- Fix Version/s: (was: 3.8.0) > LegacyConsumer: Always await async commit callbacks in com

[jira] [Created] (KAFKA-17125) Streams Rebalance Protocol

Lucas Brutschy created KAFKA-17125: -- Summary: Streams Rebalance Protocol Key: KAFKA-17125 URL: https://issues.apache.org/jira/browse/KAFKA-17125 Project: Kafka Issue Type: Task Co

[jira] [Created] (KAFKA-16133) Commits during reconciliation always time out

Lucas Brutschy created KAFKA-16133: -- Summary: Commits during reconciliation always time out Key: KAFKA-16133 URL: https://issues.apache.org/jira/browse/KAFKA-16133 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-16155) Investigate testAutoCommitIntercept

Lucas Brutschy created KAFKA-16155: -- Summary: Investigate testAutoCommitIntercept Key: KAFKA-16155 URL: https://issues.apache.org/jira/browse/KAFKA-16155 Project: Kafka Issue Type: Bug

[jira] [Updated] (KAFKA-16155) Investigate testAutoCommitIntercept

[ https://issues.apache.org/jira/browse/KAFKA-16155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy updated KAFKA-16155: --- Description: Even with KAFKA-15942, the test PlaintextConsumerTest.testAutoCommitIntercept

[jira] [Assigned] (KAFKA-16111) Implement tests for tricky rebalance callback scenarios

[ https://issues.apache.org/jira/browse/KAFKA-16111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy reassigned KAFKA-16111: -- Assignee: (was: Lucas Brutschy) > Implement tests for tricky rebalance callback s

[jira] [Created] (KAFKA-16169) FencedException in commitAsync not propagated without callback

Lucas Brutschy created KAFKA-16169: -- Summary: FencedException in commitAsync not propagated without callback Key: KAFKA-16169 URL: https://issues.apache.org/jira/browse/KAFKA-16169 Project: Kafka

[jira] [Commented] (KAFKA-16169) FencedException in commitAsync not propagated without callback

[ https://issues.apache.org/jira/browse/KAFKA-16169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17808735#comment-17808735 ] Lucas Brutschy commented on KAFKA-16169: Sound good! I'd suggest doing it after

[jira] [Created] (KAFKA-16198) Reconciliation may lose partitions when topic metadata is delayed

Lucas Brutschy created KAFKA-16198: -- Summary: Reconciliation may lose partitions when topic metadata is delayed Key: KAFKA-16198 URL: https://issues.apache.org/jira/browse/KAFKA-16198 Project: Kafka

[jira] [Updated] (KAFKA-16198) Reconciliation may lose partitions when topic metadata is delayed

[ https://issues.apache.org/jira/browse/KAFKA-16198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy updated KAFKA-16198: --- Description: The current reconciliation code in `AsyncKafkaConsumer`s `MembershipManager` m

[jira] [Created] (KAFKA-16220) KTableKTableForeignKeyInnerJoinCustomPartitionerIntegrationTest#shouldThrowIllegalArgumentExceptionWhenCustomPartionerReturnsMultiplePartitions flaky

Lucas Brutschy created KAFKA-16220: -- Summary: KTableKTableForeignKeyInnerJoinCustomPartitionerIntegrationTest#shouldThrowIllegalArgumentExceptionWhenCustomPartionerReturnsMultiplePartitions flaky Key: KAFKA-16220

[jira] [Updated] (KAFKA-16220) KTableKTableForeignKeyInnerJoinCustomPartitionerIntegrationTest#shouldThrowIllegalArgumentExceptionWhenCustomPartionerReturnsMultiplePartitions is flaky

[ https://issues.apache.org/jira/browse/KAFKA-16220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy updated KAFKA-16220: --- Summary: KTableKTableForeignKeyInnerJoinCustomPartitionerIntegrationTest#shouldThrowIllegalA

[jira] [Assigned] (KAFKA-14454) KTableKTableForeignKeyInnerJoinCustomPartitionerIntegrationTest#shouldThrowIllegalArgumentExceptionWhenCustomPartionerReturnsMultiplePartitions passes when run individu

[ https://issues.apache.org/jira/browse/KAFKA-14454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy reassigned KAFKA-14454: -- Assignee: Lucas Brutschy (was: Sagar Rao) > KTableKTableForeignKeyInnerJoinCustomPar

[jira] [Assigned] (KAFKA-14454) KTableKTableForeignKeyInnerJoinCustomPartitionerIntegrationTest#shouldThrowIllegalArgumentExceptionWhenCustomPartionerReturnsMultiplePartitions passes when run individu

[ https://issues.apache.org/jira/browse/KAFKA-14454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy reassigned KAFKA-14454: -- Assignee: Sagar Rao (was: Lucas Brutschy) > KTableKTableForeignKeyInnerJoinCustomPar

[jira] [Commented] (KAFKA-14454) KTableKTableForeignKeyInnerJoinCustomPartitionerIntegrationTest#shouldThrowIllegalArgumentExceptionWhenCustomPartionerReturnsMultiplePartitions passes when run individ

[ https://issues.apache.org/jira/browse/KAFKA-14454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17813611#comment-17813611 ] Lucas Brutschy commented on KAFKA-14454: I think the test is flaky, but the prob

[jira] [Resolved] (KAFKA-9897) Flaky Test StoreQueryIntegrationTest#shouldQuerySpecificActivePartitionStores

[ https://issues.apache.org/jira/browse/KAFKA-9897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy resolved KAFKA-9897. --- Resolution: Fixed > Flaky Test StoreQueryIntegrationTest#shouldQuerySpecificActivePartitionSt

[jira] [Commented] (KAFKA-9897) Flaky Test StoreQueryIntegrationTest#shouldQuerySpecificActivePartitionStores

[ https://issues.apache.org/jira/browse/KAFKA-9897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814360#comment-17814360 ] Lucas Brutschy commented on KAFKA-9897: --- Hasn't flaked in the last 30 days, so clos

[jira] [Commented] (KAFKA-8691) Flakey test ProcessorContextTest#shouldNotAllowToScheduleZeroMillisecondPunctuation

[ https://issues.apache.org/jira/browse/KAFKA-8691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814361#comment-17814361 ] Lucas Brutschy commented on KAFKA-8691: --- Hasn't failed in the last 30 days:   [ht

[jira] [Resolved] (KAFKA-8691) Flakey test ProcessorContextTest#shouldNotAllowToScheduleZeroMillisecondPunctuation

[ https://issues.apache.org/jira/browse/KAFKA-8691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy resolved KAFKA-8691. --- Resolution: Fixed > Flakey test > ProcessorContextTest#shouldNotAllowToScheduleZeroMillisec

[jira] [Commented] (KAFKA-14385) Flaky Test QueryableStateIntegrationTest.shouldNotMakeStoreAvailableUntilAllStoresAvailable

[ https://issues.apache.org/jira/browse/KAFKA-14385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814362#comment-17814362 ] Lucas Brutschy commented on KAFKA-14385: Hasn't failed in the last 30 days, so c

[jira] [Resolved] (KAFKA-14385) Flaky Test QueryableStateIntegrationTest.shouldNotMakeStoreAvailableUntilAllStoresAvailable

[ https://issues.apache.org/jira/browse/KAFKA-14385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy resolved KAFKA-14385. Resolution: Fixed > Flaky Test > QueryableStateIntegrationTest.shouldNotMakeStoreAvailabl

[jira] [Resolved] (KAFKA-14384) Flaky Test SelfJoinUpgradeIntegrationTest.shouldUpgradeWithTopologyOptimizationOff

[ https://issues.apache.org/jira/browse/KAFKA-14384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy resolved KAFKA-14384. Resolution: Fixed > Flaky Test > SelfJoinUpgradeIntegrationTest.shouldUpgradeWithTopology

[jira] [Commented] (KAFKA-14384) Flaky Test SelfJoinUpgradeIntegrationTest.shouldUpgradeWithTopologyOptimizationOff

[ https://issues.apache.org/jira/browse/KAFKA-14384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814363#comment-17814363 ] Lucas Brutschy commented on KAFKA-14384: Hasn't failed in the last 30 dasy, so c

[jira] [Commented] (KAFKA-16220) KTableKTableForeignKeyInnerJoinCustomPartitionerIntegrationTest#shouldThrowIllegalArgumentExceptionWhenCustomPartionerReturnsMultiplePartitions is flaky

[ https://issues.apache.org/jira/browse/KAFKA-16220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17816550#comment-17816550 ] Lucas Brutschy commented on KAFKA-16220: Closing, as it hasn't failed in the las

[jira] [Resolved] (KAFKA-16220) KTableKTableForeignKeyInnerJoinCustomPartitionerIntegrationTest#shouldThrowIllegalArgumentExceptionWhenCustomPartionerReturnsMultiplePartitions is flaky

[ https://issues.apache.org/jira/browse/KAFKA-16220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy resolved KAFKA-16220. Resolution: Fixed > KTableKTableForeignKeyInnerJoinCustomPartitionerIntegrationTest#should

[jira] [Assigned] (KAFKA-16243) Idle kafka-console-consumer with new consumer group protocol preemptively leaves group

[ https://issues.apache.org/jira/browse/KAFKA-16243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy reassigned KAFKA-16243: -- Assignee: Lucas Brutschy (was: Andrew Schofield) > Idle kafka-console-consumer with

[jira] [Created] (KAFKA-16248) Kafka consumer should cache leader offset ranges

Lucas Brutschy created KAFKA-16248: -- Summary: Kafka consumer should cache leader offset ranges Key: KAFKA-16248 URL: https://issues.apache.org/jira/browse/KAFKA-16248 Project: Kafka Issue Ty

[jira] [Updated] (KAFKA-15344) Kafka Streams should include the message leader epoch when committing offsets

[ https://issues.apache.org/jira/browse/KAFKA-15344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy updated KAFKA-15344: --- Description: We noticed an application received an OFFSET_OUT_OF_RANGE error following a ne

[jira] [Updated] (KAFKA-16248) Kafka consumer should cache leader offset ranges

[ https://issues.apache.org/jira/browse/KAFKA-16248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy updated KAFKA-16248: --- Priority: Critical (was: Major) > Kafka consumer should cache leader offset ranges > --

[jira] [Updated] (KAFKA-16248) Kafka consumer should cache leader offset ranges

[ https://issues.apache.org/jira/browse/KAFKA-16248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy updated KAFKA-16248: --- Description: We noticed a streams application received an OFFSET_OUT_OF_RANGE error followi

[jira] [Assigned] (KAFKA-16009) Fix PlaintextConsumerTest.testMaxPollIntervalMsDelayInRevocation

[ https://issues.apache.org/jira/browse/KAFKA-16009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy reassigned KAFKA-16009: -- Assignee: Lucas Brutschy (was: Kirk True) > Fix PlaintextConsumerTest.testMaxPollInt

[jira] [Assigned] (KAFKA-16009) Fix PlaintextConsumerTest.testMaxPollIntervalMsDelayInRevocation

[ https://issues.apache.org/jira/browse/KAFKA-16009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy reassigned KAFKA-16009: -- Assignee: Lucas Brutschy (was: Lucas Brutschy) > Fix PlaintextConsumerTest.testMaxPo

[jira] [Updated] (KAFKA-16155) Investigate testAutoCommitIntercept

[ https://issues.apache.org/jira/browse/KAFKA-16155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy updated KAFKA-16155: --- Reporter: Lucas Brutschy (was: Lucas Brutschy) > Investigate testAutoCommitIntercept >

[jira] [Assigned] (KAFKA-16243) Idle kafka-console-consumer with new consumer group protocol preemptively leaves group

[ https://issues.apache.org/jira/browse/KAFKA-16243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy reassigned KAFKA-16243: -- Assignee: Lucas Brutschy (was: Lucas Brutschy) > Idle kafka-console-consumer with ne

[jira] [Assigned] (KAFKA-16155) Investigate testAutoCommitIntercept

[ https://issues.apache.org/jira/browse/KAFKA-16155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy reassigned KAFKA-16155: -- Assignee: Lucas Brutschy (was: Lucas Brutschy) > Investigate testAutoCommitIntercept

[jira] [Assigned] (KAFKA-16077) Streams fails to close task after restoration when input partitions are updated

[ https://issues.apache.org/jira/browse/KAFKA-16077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy reassigned KAFKA-16077: -- Assignee: Lucas Brutschy (was: Lucas Brutschy) > Streams fails to close task after r

[jira] [Assigned] (KAFKA-9545) Flaky Test `RegexSourceIntegrationTest.testRegexMatchesTopicsAWhenDeleted`

[ https://issues.apache.org/jira/browse/KAFKA-9545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy reassigned KAFKA-9545: - Assignee: Lucas Brutschy (was: Lucas Brutschy) > Flaky Test `RegexSourceIntegrationTest

[jira] [Assigned] (KAFKA-12935) Flaky Test RestoreIntegrationTest.shouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore

[ https://issues.apache.org/jira/browse/KAFKA-12935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy reassigned KAFKA-12935: -- Assignee: Lucas Brutschy (was: Lucas Brutschy) > Flaky Test > RestoreIntegrationTes

[jira] [Assigned] (KAFKA-14299) Benchmark and stabilize state updater

[ https://issues.apache.org/jira/browse/KAFKA-14299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy reassigned KAFKA-14299: -- Assignee: Lucas Brutschy (was: Lucas Brutschy) > Benchmark and stabilize state updat

[jira] [Assigned] (KAFKA-15319) Upgrade rocksdb to fix CVE-2022-37434

[ https://issues.apache.org/jira/browse/KAFKA-15319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy reassigned KAFKA-15319: -- Assignee: Lucas Brutschy (was: Lucas Brutschy) > Upgrade rocksdb to fix CVE-2022-374

[jira] [Assigned] (KAFKA-14278) Convert INVALID_PRODUCER_EPOCH into PRODUCER_FENCED TxnOffsetCommit

[ https://issues.apache.org/jira/browse/KAFKA-14278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy reassigned KAFKA-14278: -- Assignee: Lucas Brutschy (was: Lucas Brutschy) > Convert INVALID_PRODUCER_EPOCH into

[jira] [Assigned] (KAFKA-15865) Ensure consumer.poll() execute autocommit callback

[ https://issues.apache.org/jira/browse/KAFKA-15865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy reassigned KAFKA-15865: -- Assignee: Lucas Brutschy (was: Lucas Brutschy) > Ensure consumer.poll() execute auto

[jira] [Assigned] (KAFKA-16220) KTableKTableForeignKeyInnerJoinCustomPartitionerIntegrationTest#shouldThrowIllegalArgumentExceptionWhenCustomPartionerReturnsMultiplePartitions is flaky

[ https://issues.apache.org/jira/browse/KAFKA-16220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy reassigned KAFKA-16220: -- Assignee: Lucas Brutschy (was: Lucas Brutschy) > KTableKTableForeignKeyInnerJoinCust

[jira] [Assigned] (KAFKA-15798) Flaky Test NamedTopologyIntegrationTest.shouldAddAndRemoveNamedTopologiesBeforeStartingAndRouteQueriesToCorrectTopology()

[ https://issues.apache.org/jira/browse/KAFKA-15798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy reassigned KAFKA-15798: -- Assignee: Lucas Brutschy (was: Lucas Brutschy) > Flaky Test > NamedTopologyIntegrat

[jira] [Assigned] (KAFKA-16097) State updater removes task without pending action in EOSv2

[ https://issues.apache.org/jira/browse/KAFKA-16097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy reassigned KAFKA-16097: -- Assignee: Lucas Brutschy (was: Lucas Brutschy) > State updater removes task without

[jira] [Assigned] (KAFKA-15942) Implement ConsumerInterceptor

[ https://issues.apache.org/jira/browse/KAFKA-15942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy reassigned KAFKA-15942: -- Assignee: Lucas Brutschy (was: Lucas Brutschy) > Implement ConsumerInterceptor > ---

[jira] [Assigned] (KAFKA-15326) Decouple Processing Thread from Polling Thread

[ https://issues.apache.org/jira/browse/KAFKA-15326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy reassigned KAFKA-15326: -- Assignee: Lucas Brutschy (was: Lucas Brutschy) > Decouple Processing Thread from Pol

[jira] [Assigned] (KAFKA-15803) Update last seen epoch during commit

[ https://issues.apache.org/jira/browse/KAFKA-15803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy reassigned KAFKA-15803: -- Assignee: Lucas Brutschy (was: Lucas Brutschy) > Update last seen epoch during commi

[jira] [Assigned] (KAFKA-14309) Kafka Streams upgrade tests do not cover for FK-joins

[ https://issues.apache.org/jira/browse/KAFKA-14309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy reassigned KAFKA-14309: -- Assignee: Lucas Brutschy (was: Lucas Brutschy) > Kafka Streams upgrade tests do not

[jira] [Assigned] (KAFKA-14532) Correctly handle failed fetch when partitions unassigned

[ https://issues.apache.org/jira/browse/KAFKA-14532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy reassigned KAFKA-14532: -- Assignee: Lucas Brutschy (was: Lucas Brutschy) > Correctly handle failed fetch when

  1   2   3   4   >