[jira] [Resolved] (KAFKA-16103) Review client logic for triggering offset commit callbacks

[ https://issues.apache.org/jira/browse/KAFKA-16103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy resolved KAFKA-16103. Resolution: Fixed > Review client logic for triggering offset commit callbacks >

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

Lucas Brutschy created KAFKA-16599: -- Summary: Always await async commit callbacks in commitSync and close Key: KAFKA-16599 URL: https://issues.apache.org/jira/browse/KAFKA-16599 Project: Kafka

[jira] [Resolved] (KAFKA-16008) Fix PlaintextConsumerTest.testMaxPollIntervalMs

[ https://issues.apache.org/jira/browse/KAFKA-16008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy resolved KAFKA-16008. Resolution: Duplicate > Fix PlaintextConsumerTest.testMaxPollIntervalMs >

[jira] [Resolved] (KAFKA-16010) Fix PlaintextConsumerTest.testMultiConsumerSessionTimeoutOnStopPolling

[ https://issues.apache.org/jira/browse/KAFKA-16010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy resolved KAFKA-16010. Resolution: Duplicate > Fix

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

Lucas Brutschy created KAFKA-16290: -- Summary: Investigate propagating subscription state updates via queues Key: KAFKA-16290 URL: https://issues.apache.org/jira/browse/KAFKA-16290 Project: Kafka

[jira] [Created] (KAFKA-16284) Performance regression in RocksDB

Lucas Brutschy created KAFKA-16284: -- Summary: Performance regression in RocksDB Key: KAFKA-16284 URL: https://issues.apache.org/jira/browse/KAFKA-16284 Project: Kafka Issue Type: Task

[jira] [Reopened] (KAFKA-16167) Fix PlaintextConsumerTest.testAutoCommitOnCloseAfterWakeup

[ https://issues.apache.org/jira/browse/KAFKA-16167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy reopened KAFKA-16167: > Fix PlaintextConsumerTest.testAutoCommitOnCloseAfterWakeup >

[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

[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 >

[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 >

[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 >

[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 >

[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

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

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

[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] [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] [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] [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

[jira] [Resolved] (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 resolved KAFKA-16097. Resolution: Fixed > State updater removes task without pending action in EOSv2 >

[jira] [Resolved] (KAFKA-15941) Flaky test: shouldRestoreNullRecord() – org.apache.kafka.streams.integration.RestoreIntegrationTest

[ https://issues.apache.org/jira/browse/KAFKA-15941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy resolved KAFKA-15941. Resolution: Cannot Reproduce > Flaky test: shouldRestoreNullRecord() – >

[jira] [Created] (KAFKA-16098) State updater may attempt to resume a task that is not assigned anymore

Lucas Brutschy created KAFKA-16098: -- Summary: State updater may attempt to resume a task that is not assigned anymore Key: KAFKA-16098 URL: https://issues.apache.org/jira/browse/KAFKA-16098 Project:

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

Lucas Brutschy created KAFKA-16097: -- Summary: State updater removes task without pending action in EOSv2 Key: KAFKA-16097 URL: https://issues.apache.org/jira/browse/KAFKA-16097 Project: Kafka

[jira] [Created] (KAFKA-16089) Kafka Streams still leaking memory in 3.7

Lucas Brutschy created KAFKA-16089: -- Summary: Kafka Streams still leaking memory in 3.7 Key: KAFKA-16089 URL: https://issues.apache.org/jira/browse/KAFKA-16089 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-16086) Kafka Streams has RocksDB native memory leak

Lucas Brutschy created KAFKA-16086: -- Summary: Kafka Streams has RocksDB native memory leak Key: KAFKA-16086 URL: https://issues.apache.org/jira/browse/KAFKA-16086 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-16077) State updater fails to close task when input partitions are updated

Lucas Brutschy created KAFKA-16077: -- Summary: State updater fails to close task when input partitions are updated Key: KAFKA-16077 URL: https://issues.apache.org/jira/browse/KAFKA-16077 Project:

[jira] [Resolved] (KAFKA-15696) Revoke partitions on Consumer.close()

[ https://issues.apache.org/jira/browse/KAFKA-15696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy resolved KAFKA-15696. Resolution: Fixed > Revoke partitions on Consumer.close() >

[jira] [Resolved] (KAFKA-15548) Send GroupConsumerHeartbeatRequest on Consumer.close()

[ https://issues.apache.org/jira/browse/KAFKA-15548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy resolved KAFKA-15548. Resolution: Fixed > Send GroupConsumerHeartbeatRequest on Consumer.close() >

[jira] [Created] (KAFKA-16001) Migrate ConsumerNetworkThreadTestBuilder away from ConsumerTestBuilder

Lucas Brutschy created KAFKA-16001: -- Summary: Migrate ConsumerNetworkThreadTestBuilder away from ConsumerTestBuilder Key: KAFKA-16001 URL: https://issues.apache.org/jira/browse/KAFKA-16001 Project:

[jira] [Created] (KAFKA-16000) Migrate MembershipManagerImpl away from ConsumerTestBuilder

Lucas Brutschy created KAFKA-16000: -- Summary: Migrate MembershipManagerImpl away from ConsumerTestBuilder Key: KAFKA-16000 URL: https://issues.apache.org/jira/browse/KAFKA-16000 Project: Kafka

[jira] [Created] (KAFKA-15999) Migrate HeartbeatRequestManagerTest away from ConsumerTestBuilder

Lucas Brutschy created KAFKA-15999: -- Summary: Migrate HeartbeatRequestManagerTest away from ConsumerTestBuilder Key: KAFKA-15999 URL: https://issues.apache.org/jira/browse/KAFKA-15999 Project: Kafka

[jira] [Created] (KAFKA-15977) DelegationTokenEndToEndAuthorizationWithOwnerTest leaks threads

Lucas Brutschy created KAFKA-15977: -- Summary: DelegationTokenEndToEndAuthorizationWithOwnerTest leaks threads Key: KAFKA-15977 URL: https://issues.apache.org/jira/browse/KAFKA-15977 Project: Kafka

[jira] [Created] (KAFKA-15967) Fix revocation in reconcilation logic

Lucas Brutschy created KAFKA-15967: -- Summary: Fix revocation in reconcilation logic Key: KAFKA-15967 URL: https://issues.apache.org/jira/browse/KAFKA-15967 Project: Kafka Issue Type:

[jira] [Resolved] (KAFKA-15690) EosIntegrationTest is flaky.

[ https://issues.apache.org/jira/browse/KAFKA-15690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy resolved KAFKA-15690. Resolution: Fixed > EosIntegrationTest is flaky. > > >

[jira] [Resolved] (KAFKA-15887) Autocommit during close consistently fails with exception in background thread

[ https://issues.apache.org/jira/browse/KAFKA-15887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy resolved KAFKA-15887. Resolution: Fixed > Autocommit during close consistently fails with exception in

[jira] [Created] (KAFKA-15930) Flaky test - testWithGroupId - TransactionsBounceTest

Lucas Brutschy created KAFKA-15930: -- Summary: Flaky test - testWithGroupId - TransactionsBounceTest Key: KAFKA-15930 URL: https://issues.apache.org/jira/browse/KAFKA-15930 Project: Kafka

[jira] [Created] (KAFKA-15929) Flaky test - testDescribeUnderReplicatedPartitionsWhenReassignmentIsInProgress - TopicCommandIntegrationTest

Lucas Brutschy created KAFKA-15929: -- Summary: Flaky test - testDescribeUnderReplicatedPartitionsWhenReassignmentIsInProgress - TopicCommandIntegrationTest Key: KAFKA-15929 URL:

[jira] [Created] (KAFKA-15928) Flaky test - testBalancePartitionLeaders - QuorumControllerTest

Lucas Brutschy created KAFKA-15928: -- Summary: Flaky test - testBalancePartitionLeaders - QuorumControllerTest Key: KAFKA-15928 URL: https://issues.apache.org/jira/browse/KAFKA-15928 Project: Kafka

[jira] [Created] (KAFKA-15927) Flaky test - testReplicateSourceDefault - MirrorConnectorsIntegrationExactlyOnceTest

Lucas Brutschy created KAFKA-15927: -- Summary: Flaky test - testReplicateSourceDefault - MirrorConnectorsIntegrationExactlyOnceTest Key: KAFKA-15927 URL: https://issues.apache.org/jira/browse/KAFKA-15927

[jira] [Created] (KAFKA-15926) Flaky test - testReplicateSourceDefault - MirrorConnectorsIntegrationSSLTest

Lucas Brutschy created KAFKA-15926: -- Summary: Flaky test - testReplicateSourceDefault - MirrorConnectorsIntegrationSSLTest Key: KAFKA-15926 URL: https://issues.apache.org/jira/browse/KAFKA-15926

[jira] [Created] (KAFKA-15925) Flaky test testReplicateSourceDefault - MirrorConnectorsIntegrationTransactionsTest

Lucas Brutschy created KAFKA-15925: -- Summary: Flaky test testReplicateSourceDefault - MirrorConnectorsIntegrationTransactionsTest Key: KAFKA-15925 URL: https://issues.apache.org/jira/browse/KAFKA-15925

[jira] [Resolved] (KAFKA-15544) Enable existing client integration tests for new protocol

[ https://issues.apache.org/jira/browse/KAFKA-15544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy resolved KAFKA-15544. Resolution: Fixed > Enable existing client integration tests for new protocol >

[jira] [Created] (KAFKA-15916) Flaky test - testClientSideTimeoutAfterFailureToReceiveResponse - KafkaAdminClientTest

Lucas Brutschy created KAFKA-15916: -- Summary: Flaky test - testClientSideTimeoutAfterFailureToReceiveResponse - KafkaAdminClientTest Key: KAFKA-15916 URL: https://issues.apache.org/jira/browse/KAFKA-15916

[jira] [Created] (KAFKA-15915) Flaky test - testUnrecoverableError - ProducerIdManagerTest

Lucas Brutschy created KAFKA-15915: -- Summary: Flaky test - testUnrecoverableError - ProducerIdManagerTest Key: KAFKA-15915 URL: https://issues.apache.org/jira/browse/KAFKA-15915 Project: Kafka

[jira] [Created] (KAFKA-15914) Flaky test - testAlterSinkConnectorOffsetsOverriddenConsumerGroupId - OffsetsApiIntegrationTest

Lucas Brutschy created KAFKA-15914: -- Summary: Flaky test - testAlterSinkConnectorOffsetsOverriddenConsumerGroupId - OffsetsApiIntegrationTest Key: KAFKA-15914 URL:

[jira] [Resolved] (KAFKA-14624) State restoration is broken with standby tasks and cache-enabled stores in processor API

[ https://issues.apache.org/jira/browse/KAFKA-14624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy resolved KAFKA-14624. Resolution: Fixed > State restoration is broken with standby tasks and cache-enabled

[jira] [Resolved] (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 resolved KAFKA-15798. Resolution: Fixed Test disabled in https://github.com/apache/kafka/pull/14830 since

[jira] [Resolved] (KAFKA-14014) Flaky test NamedTopologyIntegrationTest.shouldAllowRemovingAndAddingNamedTopologyToRunningApplicationWithMultipleNodesAndResetsOffsets()

[ https://issues.apache.org/jira/browse/KAFKA-14014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy resolved KAFKA-14014. Resolution: Fixed Test disabled since feature will be removed. > Flaky test >

[jira] [Resolved] (KAFKA-13531) Flaky test NamedTopologyIntegrationTest

[ https://issues.apache.org/jira/browse/KAFKA-13531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy resolved KAFKA-13531. Resolution: Fixed Test disabled since feature will be removed. > Flaky test

[jira] [Created] (KAFKA-15887) Autocommit during close consistently fails with exception in background thread

Lucas Brutschy created KAFKA-15887: -- Summary: Autocommit during close consistently fails with exception in background thread Key: KAFKA-15887 URL: https://issues.apache.org/jira/browse/KAFKA-15887

[jira] [Created] (KAFKA-15833) Restrict Consumer API to be used from one thread

Lucas Brutschy created KAFKA-15833: -- Summary: Restrict Consumer API to be used from one thread Key: KAFKA-15833 URL: https://issues.apache.org/jira/browse/KAFKA-15833 Project: Kafka Issue

[jira] [Resolved] (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 resolved KAFKA-15326. Resolution: Implemented > Decouple Processing Thread from Polling Thread >

[jira] [Resolved] (KAFKA-15463) StreamsException: Accessing from an unknown node

[ https://issues.apache.org/jira/browse/KAFKA-15463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy resolved KAFKA-15463. Resolution: Not A Problem > StreamsException: Accessing from an unknown node >

[jira] [Created] (KAFKA-15378) Rolling upgrade system tests are failing

Lucas Brutschy created KAFKA-15378: -- Summary: Rolling upgrade system tests are failing Key: KAFKA-15378 URL: https://issues.apache.org/jira/browse/KAFKA-15378 Project: Kafka Issue Type:

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

Lucas Brutschy created KAFKA-15326: -- Summary: Decouple Processing Thread from Polling Thread Key: KAFKA-15326 URL: https://issues.apache.org/jira/browse/KAFKA-15326 Project: Kafka Issue

[jira] [Resolved] (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 resolved KAFKA-14278. Resolution: Fixed > Convert INVALID_PRODUCER_EPOCH into PRODUCER_FENCED TxnOffsetCommit >

[jira] [Resolved] (KAFKA-14172) bug: State stores lose state when tasks are reassigned under EOS wit…

[ https://issues.apache.org/jira/browse/KAFKA-14172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy resolved KAFKA-14172. Resolution: Fixed > bug: State stores lose state when tasks are reassigned under EOS wit…

[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] [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

[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

[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

[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] [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] [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] [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] [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

[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-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: