[jira] [Updated] (KAFKA-13010) Flaky test org.apache.kafka.streams.integration.TaskMetadataIntegrationTest.shouldReportCorrectCommittedOffsetInformation()

[ https://issues.apache.org/jira/browse/KAFKA-13010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-13010: -- Labels: flaky-test (was: ) > Flaky test > org.apache.kafka.streams.integration.TaskMetadataI

[jira] [Created] (KAFKA-13010) Flaky test org.apache.kafka.streams.integration.TaskMetadataIntegrationTest.shouldReportCorrectCommittedOffsetInformation()

Bruno Cadonna created KAFKA-13010: - Summary: Flaky test org.apache.kafka.streams.integration.TaskMetadataIntegrationTest.shouldReportCorrectCommittedOffsetInformation() Key: KAFKA-13010 URL: https://issues.apache.

[jira] [Commented] (KAFKA-12511) Flaky test DynamicConnectionQuotaTest.testDynamicListenerConnectionCreationRateQuota()

[ https://issues.apache.org/jira/browse/KAFKA-12511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17370502#comment-17370502 ] Bruno Cadonna commented on KAFKA-12511: --- Failed again https://ci-builds.apache.or

[jira] [Comment Edited] (KAFKA-12993) Formatting of Streams 'Memory Management' docs is messed up

[ https://issues.apache.org/jira/browse/KAFKA-12993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17369454#comment-17369454 ] Bruno Cadonna edited comment on KAFKA-12993 at 6/25/21, 1:01 PM: -

[jira] [Comment Edited] (KAFKA-12993) Formatting of Streams 'Memory Management' docs is messed up

[ https://issues.apache.org/jira/browse/KAFKA-12993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17369454#comment-17369454 ] Bruno Cadonna edited comment on KAFKA-12993 at 6/25/21, 1:00 PM: -

[jira] [Commented] (KAFKA-12993) Formatting of Streams 'Memory Management' docs is messed up

[ https://issues.apache.org/jira/browse/KAFKA-12993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17369454#comment-17369454 ] Bruno Cadonna commented on KAFKA-12993: --- I thinkthis has already been done by htt

[jira] [Commented] (KAFKA-12629) Failing Test: RaftClusterTest

[ https://issues.apache.org/jira/browse/KAFKA-12629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17367264#comment-17367264 ] Bruno Cadonna commented on KAFKA-12629: --- Failed again: https://ci-builds.apache.o

[jira] [Commented] (KAFKA-12786) Getting SslTransportLayerTest error

[ https://issues.apache.org/jira/browse/KAFKA-12786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17367263#comment-17367263 ] Bruno Cadonna commented on KAFKA-12786: --- Failed again under JDK 11: https://ci-bu

[jira] [Commented] (KAFKA-12629) Failing Test: RaftClusterTest

[ https://issues.apache.org/jira/browse/KAFKA-12629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17367235#comment-17367235 ] Bruno Cadonna commented on KAFKA-12629: --- Failed again: https://ci-builds.apache.o

[jira] [Commented] (KAFKA-12892) InvalidACLException thrown in tests caused jenkins build unstable

[ https://issues.apache.org/jira/browse/KAFKA-12892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17360983#comment-17360983 ] Bruno Cadonna commented on KAFKA-12892: --- Is PR #10821 supposed to solve the issue?

[jira] [Commented] (KAFKA-12920) Consumer's cooperative sticky assignor need to clear generation / assignment data upon `onPartitionsLost`

[ https://issues.apache.org/jira/browse/KAFKA-12920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17359812#comment-17359812 ] Bruno Cadonna commented on KAFKA-12920: --- Is this regression? Should this be a bloc

[jira] [Commented] (KAFKA-12905) Replace EasyMock and PowerMock with Mockito for NamedCacheMetricsTest

[ https://issues.apache.org/jira/browse/KAFKA-12905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17359162#comment-17359162 ] Bruno Cadonna commented on KAFKA-12905: --- [~a493172422] Could you convert this tick

[jira] [Commented] (KAFKA-9168) Integrate JNI direct buffer support to RocksDBStore

[ https://issues.apache.org/jira/browse/KAFKA-9168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17356273#comment-17356273 ] Bruno Cadonna commented on KAFKA-9168: -- Hi [~sagarrao], our internal benchmark did n

[jira] [Resolved] (KAFKA-12519) Consider Removing Streams Old Built-in Metrics Version

[ https://issues.apache.org/jira/browse/KAFKA-12519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-12519. --- Resolution: Fixed > Consider Removing Streams Old Built-in Metrics Version > --

[jira] [Commented] (KAFKA-5676) MockStreamsMetrics should be in o.a.k.test

[ https://issues.apache.org/jira/browse/KAFKA-5676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17355048#comment-17355048 ] Bruno Cadonna commented on KAFKA-5676: -- [~marcolotz] Thank you for your analysis! I

[jira] [Commented] (KAFKA-9168) Integrate JNI direct buffer support to RocksDBStore

[ https://issues.apache.org/jira/browse/KAFKA-9168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17354586#comment-17354586 ] Bruno Cadonna commented on KAFKA-9168: -- [~sagarrao] and [~ableegoldman] I took the l

[jira] [Commented] (KAFKA-12629) Failing Test: RaftClusterTest

[ https://issues.apache.org/jira/browse/KAFKA-12629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17352353#comment-17352353 ] Bruno Cadonna commented on KAFKA-12629: --- Failed on: https://ci-builds.apache.org/

[jira] [Comment Edited] (KAFKA-5676) MockStreamsMetrics should be in o.a.k.test

[ https://issues.apache.org/jira/browse/KAFKA-5676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17350960#comment-17350960 ] Bruno Cadonna edited comment on KAFKA-5676 at 5/25/21, 10:42 AM: --

[jira] [Commented] (KAFKA-5676) MockStreamsMetrics should be in o.a.k.test

[ https://issues.apache.org/jira/browse/KAFKA-5676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17350960#comment-17350960 ] Bruno Cadonna commented on KAFKA-5676: -- [~marcolotz] Thank you for looking into this

[jira] [Commented] (KAFKA-12824) Remove Deprecated method KStream#branch

[ https://issues.apache.org/jira/browse/KAFKA-12824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17350941#comment-17350941 ] Bruno Cadonna commented on KAFKA-12824: --- [~mjsax] Do we know for which date AK 4.0

[jira] [Updated] (KAFKA-12796) Removal of deprecated classes under `streams-scala`

[ https://issues.apache.org/jira/browse/KAFKA-12796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-12796: -- Fix Version/s: 3.0.0 > Removal of deprecated classes under `streams-scala` > -

[jira] [Commented] (KAFKA-12629) Flaky Test RaftClusterTest

[ https://issues.apache.org/jira/browse/KAFKA-12629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17349143#comment-17349143 ] Bruno Cadonna commented on KAFKA-12629: --- I confirm that I also see this test fail

[jira] [Created] (KAFKA-12817) Make Task ID an Implementation Detail

Bruno Cadonna created KAFKA-12817: - Summary: Make Task ID an Implementation Detail Key: KAFKA-12817 URL: https://issues.apache.org/jira/browse/KAFKA-12817 Project: Kafka Issue Type: Improveme

[jira] [Updated] (KAFKA-12812) Consider refactoring state store registration path

[ https://issues.apache.org/jira/browse/KAFKA-12812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-12812: -- Issue Type: Improvement (was: Bug) > Consider refactoring state store registration path > ---

[jira] [Commented] (KAFKA-12812) Consider refactoring state store registration path

[ https://issues.apache.org/jira/browse/KAFKA-12812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17347422#comment-17347422 ] Bruno Cadonna commented on KAFKA-12812: --- [~guozhang] Thank you for the proposal! I

[jira] [Commented] (KAFKA-12808) Remove Deprecated methods under StreamsMetrics

[ https://issues.apache.org/jira/browse/KAFKA-12808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17347372#comment-17347372 ] Bruno Cadonna commented on KAFKA-12808: --- Awesome! Thank you [~josep.prat]! I forgo

[jira] [Commented] (KAFKA-12419) Remove Deprecated APIs of Kafka Streams in 3.0

[ https://issues.apache.org/jira/browse/KAFKA-12419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17346057#comment-17346057 ] Bruno Cadonna commented on KAFKA-12419: --- I am not sure we can remove all of them i

[jira] [Updated] (KAFKA-12419) Remove Deprecated APIs of Kafka Streams in 3.0

[ https://issues.apache.org/jira/browse/KAFKA-12419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-12419: -- Description: Here's a list of deprecated APIs that we have accumulated in the past, we can co

[jira] [Updated] (KAFKA-12419) Remove Deprecated APIs of Kafka Streams in 3.0

[ https://issues.apache.org/jira/browse/KAFKA-12419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-12419: -- Description: Here's a list of deprecated APIs that we have accumulated in the past, we can co

[jira] [Updated] (KAFKA-12796) Removal of deprecated classes under `streams-scala`

[ https://issues.apache.org/jira/browse/KAFKA-12796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-12796: -- Component/s: streams > Removal of deprecated classes under `streams-scala` > -

[jira] [Commented] (KAFKA-12796) Removal of deprecated classes under `streams-scala`

[ https://issues.apache.org/jira/browse/KAFKA-12796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17346023#comment-17346023 ] Bruno Cadonna commented on KAFKA-12796: --- Hi [~josep.prat], Thanks for the ticket!

[jira] [Commented] (KAFKA-12775) StreamsPartitionAssignor / ClientState throws an exception when a new Task gets added to a KStreams Application in a Backwards-Compatible Topology Change

[ https://issues.apache.org/jira/browse/KAFKA-12775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17344367#comment-17344367 ] Bruno Cadonna commented on KAFKA-12775: --- [~nhab] Would upgrading all Kafka Streams

[jira] [Commented] (KAFKA-12775) StreamsPartitionAssignor / ClientState throws an exception when a new Task gets added to a KStreams Application in a Backwards-Compatible Topology Change

[ https://issues.apache.org/jira/browse/KAFKA-12775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17343328#comment-17343328 ] Bruno Cadonna commented on KAFKA-12775: --- [~nhab] Thank you for filing this ticket

[jira] [Commented] (KAFKA-12766) Consider Disabling WAL-related Options in RocksDB

[ https://issues.apache.org/jira/browse/KAFKA-12766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17342337#comment-17342337 ] Bruno Cadonna commented on KAFKA-12766: --- I have to admit that I blindly followed y

[jira] [Commented] (KAFKA-12766) Consider Disabling WAL-related Options in RocksDB

[ https://issues.apache.org/jira/browse/KAFKA-12766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17341782#comment-17341782 ] Bruno Cadonna commented on KAFKA-12766: --- I think throwing an exception is too hars

[jira] [Created] (KAFKA-12766) Consider Disabling WAL-related Options in RocksDB

Bruno Cadonna created KAFKA-12766: - Summary: Consider Disabling WAL-related Options in RocksDB Key: KAFKA-12766 URL: https://issues.apache.org/jira/browse/KAFKA-12766 Project: Kafka Issue Typ

[jira] [Updated] (KAFKA-12766) Consider Disabling WAL-related Options in RocksDB

[ https://issues.apache.org/jira/browse/KAFKA-12766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-12766: -- Issue Type: Improvement (was: Test) > Consider Disabling WAL-related Options in RocksDB > ---

[jira] [Resolved] (KAFKA-8897) Increase Version of RocksDB

[ https://issues.apache.org/jira/browse/KAFKA-8897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-8897. -- Resolution: Fixed > Increase Version of RocksDB > --- > >

[jira] [Commented] (KAFKA-9009) Flaky Test kafka.integration.MetricsDuringTopicCreationDeletionTest.testMetricsDuringTopicCreateDelete

[ https://issues.apache.org/jira/browse/KAFKA-9009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17340259#comment-17340259 ] Bruno Cadonna commented on KAFKA-9009: -- https://ci-builds.apache.org/job/Kafka/job/k

[jira] [Commented] (KAFKA-12657) Flaky Tests BlockingConnectorTest.testWorkerRestartWithBlockInConnectorStop

[ https://issues.apache.org/jira/browse/KAFKA-12657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17340257#comment-17340257 ] Bruno Cadonna commented on KAFKA-12657: --- https://ci-builds.apache.org/job/Kafka/jo

[jira] [Resolved] (KAFKA-10767) Add Unit Test cases for missing methods in ThreadCacheTest

[ https://issues.apache.org/jira/browse/KAFKA-10767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-10767. --- Resolution: Fixed > Add Unit Test cases for missing methods in ThreadCacheTest > ---

[jira] [Updated] (KAFKA-10767) Add Unit Test cases for missing methods in ThreadCacheTest

[ https://issues.apache.org/jira/browse/KAFKA-10767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-10767: -- Fix Version/s: 3.0.0 > Add Unit Test cases for missing methods in ThreadCacheTest > --

[jira] [Commented] (KAFKA-9009) Flaky Test kafka.integration.MetricsDuringTopicCreationDeletionTest.testMetricsDuringTopicCreateDelete

[ https://issues.apache.org/jira/browse/KAFKA-9009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17340118#comment-17340118 ] Bruno Cadonna commented on KAFKA-9009: -- Failed again: [https://ci-builds.apache.org

[jira] [Commented] (KAFKA-9295) KTableKTableForeignKeyInnerJoinMultiIntegrationTest#shouldInnerJoinMultiPartitionQueryable

[ https://issues.apache.org/jira/browse/KAFKA-9295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17339760#comment-17339760 ] Bruno Cadonna commented on KAFKA-9295: -- Failed multiple times for a PR (https://ci-

[jira] [Commented] (KAFKA-10493) KTable out-of-order updates are not being ignored

[ https://issues.apache.org/jira/browse/KAFKA-10493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17331171#comment-17331171 ] Bruno Cadonna commented on KAFKA-10493: --- Are you proposing to drop out-of-order re

[jira] [Commented] (KAFKA-10493) KTable out-of-order updates are not being ignored

[ https://issues.apache.org/jira/browse/KAFKA-10493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17329387#comment-17329387 ] Bruno Cadonna commented on KAFKA-10493: --- Good point about the compaction!   {quot

[jira] [Commented] (KAFKA-10493) KTable out-of-order updates are not being ignored

[ https://issues.apache.org/jira/browse/KAFKA-10493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17327212#comment-17327212 ] Bruno Cadonna commented on KAFKA-10493: --- The options that I see are: # verify the

[jira] [Commented] (KAFKA-12667) Incorrect error log on StateDirectory close

[ https://issues.apache.org/jira/browse/KAFKA-12667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17320768#comment-17320768 ] Bruno Cadonna commented on KAFKA-12667: --- [~antrenta] Thank you for the ticket! Thi

[jira] [Updated] (KAFKA-12667) Incorrect error log on StateDirectory close

[ https://issues.apache.org/jira/browse/KAFKA-12667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-12667: -- Priority: Major (was: Trivial) > Incorrect error log on StateDirectory close > --

[jira] [Updated] (KAFKA-12667) Incorrect error log on StateDirectory close

[ https://issues.apache.org/jira/browse/KAFKA-12667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-12667: -- Fix Version/s: (was: 2.7.1) 2.7.2 > Incorrect error log on StateDirecto

[jira] [Updated] (KAFKA-12667) Incorrect error log on StateDirectory close

[ https://issues.apache.org/jira/browse/KAFKA-12667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-12667: -- Fix Version/s: 2.6.3 > Incorrect error log on StateDirectory close > -

[jira] [Updated] (KAFKA-12667) Incorrect error log on StateDirectory close

[ https://issues.apache.org/jira/browse/KAFKA-12667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-12667: -- Fix Version/s: 2.7.1 > Incorrect error log on StateDirectory close > -

[jira] [Comment Edited] (KAFKA-9295) KTableKTableForeignKeyInnerJoinMultiIntegrationTest#shouldInnerJoinMultiPartitionQueryable

[ https://issues.apache.org/jira/browse/KAFKA-9295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17320704#comment-17320704 ] Bruno Cadonna edited comment on KAFKA-9295 at 4/14/21, 5:07 AM: ---

[jira] [Commented] (KAFKA-9295) KTableKTableForeignKeyInnerJoinMultiIntegrationTest#shouldInnerJoinMultiPartitionQueryable

[ https://issues.apache.org/jira/browse/KAFKA-9295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17320704#comment-17320704 ] Bruno Cadonna commented on KAFKA-9295: -- [~ableegoldman] Makes sense! My bad, I looke

[jira] [Created] (KAFKA-12666) Fix flaky kafka.server.RaftClusterTest.testCreateClusterAndCreateListDeleteTopic

Bruno Cadonna created KAFKA-12666: - Summary: Fix flaky kafka.server.RaftClusterTest.testCreateClusterAndCreateListDeleteTopic Key: KAFKA-12666 URL: https://issues.apache.org/jira/browse/KAFKA-12666 Pr

[jira] [Commented] (KAFKA-9295) KTableKTableForeignKeyInnerJoinMultiIntegrationTest#shouldInnerJoinMultiPartitionQueryable

[ https://issues.apache.org/jira/browse/KAFKA-9295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17320696#comment-17320696 ] Bruno Cadonna commented on KAFKA-9295: -- Documenting that I found this test failure i

[jira] [Updated] (KAFKA-8941) Add RocksDB Metrics that Could not be Added due to RocksDB Version

[ https://issues.apache.org/jira/browse/KAFKA-8941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-8941: - Labels: newbie (was: ) > Add RocksDB Metrics that Could not be Added due to RocksDB Version > --

[jira] [Assigned] (KAFKA-8941) Add RocksDB Metrics that Could not be Added due to RocksDB Version

[ https://issues.apache.org/jira/browse/KAFKA-8941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna reassigned KAFKA-8941: Assignee: (was: Bruno Cadonna) > Add RocksDB Metrics that Could not be Added due to Ro

[jira] [Commented] (KAFKA-12650) NPE in InternalTopicManager#cleanUpCreatedTopics

[ https://issues.apache.org/jira/browse/KAFKA-12650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17320051#comment-17320051 ] Bruno Cadonna commented on KAFKA-12650: --- [~mjsax] [~ableegoldman] , Thank you for

[jira] [Comment Edited] (KAFKA-12608) Simple identity pipeline sometimes loses data

[ https://issues.apache.org/jira/browse/KAFKA-12608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17320005#comment-17320005 ] Bruno Cadonna edited comment on KAFKA-12608 at 4/13/21, 8:01 AM: -

[jira] [Comment Edited] (KAFKA-12608) Simple identity pipeline sometimes loses data

[ https://issues.apache.org/jira/browse/KAFKA-12608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17320005#comment-17320005 ] Bruno Cadonna edited comment on KAFKA-12608 at 4/13/21, 8:04 AM: -

[jira] [Comment Edited] (KAFKA-12608) Simple identity pipeline sometimes loses data

[ https://issues.apache.org/jira/browse/KAFKA-12608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17320005#comment-17320005 ] Bruno Cadonna edited comment on KAFKA-12608 at 4/13/21, 8:01 AM: -

[jira] [Commented] (KAFKA-12608) Simple identity pipeline sometimes loses data

[ https://issues.apache.org/jira/browse/KAFKA-12608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17320005#comment-17320005 ] Bruno Cadonna commented on KAFKA-12608: --- Hi [~jamii], I think [~hpgrahsl] is righ

[jira] [Assigned] (KAFKA-12519) Consider Removing Streams Old Built-in Metrics Version

[ https://issues.apache.org/jira/browse/KAFKA-12519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna reassigned KAFKA-12519: - Assignee: Bruno Cadonna > Consider Removing Streams Old Built-in Metrics Version > ---

[jira] [Updated] (KAFKA-12519) Consider Removing Streams Old Built-in Metrics Version

[ https://issues.apache.org/jira/browse/KAFKA-12519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-12519: -- Labels: needs-kip (was: ) > Consider Removing Streams Old Built-in Metrics Version > ---

[jira] [Commented] (KAFKA-12475) Kafka Streams breaks EOS with remote state stores

[ https://issues.apache.org/jira/browse/KAFKA-12475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17306916#comment-17306916 ] Bruno Cadonna commented on KAFKA-12475: --- Yes, I agree with you. I mainly brought t

[jira] [Commented] (KAFKA-12519) Consider Removing Streams Old Built-in Metrics Version

[ https://issues.apache.org/jira/browse/KAFKA-12519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17306914#comment-17306914 ] Bruno Cadonna commented on KAFKA-12519: --- [~ableegoldman] Good catch! I was sure I

[jira] [Updated] (KAFKA-12519) Consider Removing Streams Old Built-in Metrics Version

[ https://issues.apache.org/jira/browse/KAFKA-12519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-12519: -- Priority: Blocker (was: Major) > Consider Removing Streams Old Built-in Metrics Version > --

[jira] [Commented] (KAFKA-12519) Consider Removing Streams Old Built-in Metrics Version

[ https://issues.apache.org/jira/browse/KAFKA-12519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17306467#comment-17306467 ] Bruno Cadonna commented on KAFKA-12519: --- No, I would either remove the config {{bu

[jira] [Commented] (KAFKA-12519) Consider Removing Streams Old Built-in Metrics Version

[ https://issues.apache.org/jira/browse/KAFKA-12519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17306348#comment-17306348 ] Bruno Cadonna commented on KAFKA-12519: --- Yes, that is correct. For AK 3.0, we cou

[jira] [Updated] (KAFKA-12519) Consider Removing Streams Old Built-in Metrics Version

[ https://issues.apache.org/jira/browse/KAFKA-12519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-12519: -- Issue Type: Task (was: Improvement) > Consider Removing Streams Old Built-in Metrics Version

[jira] [Created] (KAFKA-12519) Consider Removing Streams Old Built-in Metrics Version

Bruno Cadonna created KAFKA-12519: - Summary: Consider Removing Streams Old Built-in Metrics Version Key: KAFKA-12519 URL: https://issues.apache.org/jira/browse/KAFKA-12519 Project: Kafka Iss

[jira] [Commented] (KAFKA-12475) Kafka Streams breaks EOS with remote state stores

[ https://issues.apache.org/jira/browse/KAFKA-12475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17306060#comment-17306060 ] Bruno Cadonna commented on KAFKA-12475: --- [~guozhang] Good point about bookkeeping.

[jira] [Commented] (KAFKA-12508) Emit-on-change tables may lose updates on error or restart in at_least_once

[ https://issues.apache.org/jira/browse/KAFKA-12508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17304925#comment-17304925 ] Bruno Cadonna commented on KAFKA-12508: --- You are right! My bad! > Emit-on-change

[jira] [Commented] (KAFKA-12508) Emit-on-change tables may lose updates on error or restart in at_least_once

[ https://issues.apache.org/jira/browse/KAFKA-12508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17304915#comment-17304915 ] Bruno Cadonna commented on KAFKA-12508: --- [~ableegoldman], [~mimaison], and [~vvcep

[jira] [Updated] (KAFKA-12508) Emit-on-change tables may lose updates on error or restart in at_least_once

[ https://issues.apache.org/jira/browse/KAFKA-12508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-12508: -- Fix Version/s: 2.6.2 2.7.1 2.8.0 > Emit-on-change tables

[jira] [Commented] (KAFKA-12508) Emit-on-change tables may lose updates on error or restart in at_least_once

[ https://issues.apache.org/jira/browse/KAFKA-12508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17304894#comment-17304894 ] Bruno Cadonna commented on KAFKA-12508: --- [~nhab] Thank you for the bug report. I c

[jira] [Updated] (KAFKA-12508) Emit-on-change tables may lose updates on error or restart in at_least_once

[ https://issues.apache.org/jira/browse/KAFKA-12508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-12508: -- Priority: Blocker (was: Major) > Emit-on-change tables may lose updates on error or restart i

[jira] [Assigned] (KAFKA-12508) Emit-on-change tables may lose updates on error or restart in at_least_once

[ https://issues.apache.org/jira/browse/KAFKA-12508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna reassigned KAFKA-12508: - Assignee: Bruno Cadonna > Emit-on-change tables may lose updates on error or restart in

[jira] [Commented] (KAFKA-12384) Flaky Test ListOffsetsRequestTest.testResponseIncludesLeaderEpoch

[ https://issues.apache.org/jira/browse/KAFKA-12384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17304053#comment-17304053 ] Bruno Cadonna commented on KAFKA-12384: --- Failed again https://ci-builds.apache.o

[jira] [Commented] (KAFKA-12475) Kafka Streams breaks EOS with remote state stores

[ https://issues.apache.org/jira/browse/KAFKA-12475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17302336#comment-17302336 ] Bruno Cadonna commented on KAFKA-12475: --- Another aspect that we need to consider h

[jira] [Closed] (KAFKA-10293) fix flaky streams/streams_eos_test.py

[ https://issues.apache.org/jira/browse/KAFKA-10293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna closed KAFKA-10293. - > fix flaky streams/streams_eos_test.py > - > >

[jira] [Closed] (KAFKA-10287) fix flaky streams/streams_standby_replica_test.py

[ https://issues.apache.org/jira/browse/KAFKA-10287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna closed KAFKA-10287. - > fix flaky streams/streams_standby_replica_test.py > --

[jira] [Closed] (KAFKA-10166) Excessive TaskCorruptedException seen in testing

[ https://issues.apache.org/jira/browse/KAFKA-10166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna closed KAFKA-10166. - > Excessive TaskCorruptedException seen in testing > ---

[jira] [Closed] (KAFKA-10148) Kafka Streams Restores too few Records with eos-beta Enabled

[ https://issues.apache.org/jira/browse/KAFKA-10148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna closed KAFKA-10148. - > Kafka Streams Restores too few Records with eos-beta Enabled > --

[jira] [Closed] (KAFKA-9173) StreamsPartitionAssignor assigns partitions to only one worker

[ https://issues.apache.org/jira/browse/KAFKA-9173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna closed KAFKA-9173. > StreamsPartitionAssignor assigns partitions to only one worker >

[jira] [Closed] (KAFKA-8263) Flaky Test MetricsIntegrationTest#testStreamMetricOfWindowStore

[ https://issues.apache.org/jira/browse/KAFKA-8263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna closed KAFKA-8263. > Flaky Test MetricsIntegrationTest#testStreamMetricOfWindowStore > ---

[jira] [Closed] (KAFKA-8262) Flaky Test MetricsIntegrationTest#testStreamMetric

[ https://issues.apache.org/jira/browse/KAFKA-8262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna closed KAFKA-8262. > Flaky Test MetricsIntegrationTest#testStreamMetric >

[jira] [Closed] (KAFKA-10772) java.lang.IllegalStateException: There are insufficient bytes available to read assignment from the sync-group response (actual byte size 0)

[ https://issues.apache.org/jira/browse/KAFKA-10772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna closed KAFKA-10772. - > java.lang.IllegalStateException: There are insufficient bytes available to > read assignment from

[jira] [Closed] (KAFKA-10221) Backport fix for KAFKA-9603 to 2.5

[ https://issues.apache.org/jira/browse/KAFKA-10221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna closed KAFKA-10221. - > Backport fix for KAFKA-9603 to 2.5 > --- > > Key:

[jira] [Closed] (KAFKA-10355) Handle accidental deletion of source-topics as exceptional failure

[ https://issues.apache.org/jira/browse/KAFKA-10355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna closed KAFKA-10355. - > Handle accidental deletion of source-topics as exceptional failure > -

[jira] [Closed] (KAFKA-10179) State Store Passes Wrong Changelog Topic to Serde for Optimized Source Tables

[ https://issues.apache.org/jira/browse/KAFKA-10179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna closed KAFKA-10179. - > State Store Passes Wrong Changelog Topic to Serde for Optimized Source Tables > --

[jira] [Closed] (KAFKA-9924) Add RocksDB Memory Consumption to RocksDB Metrics

[ https://issues.apache.org/jira/browse/KAFKA-9924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna closed KAFKA-9924. > Add RocksDB Memory Consumption to RocksDB Metrics >

[jira] [Closed] (KAFKA-9664) Flaky Test KafkaStreamsTest#testStateThreadClose

[ https://issues.apache.org/jira/browse/KAFKA-9664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna closed KAFKA-9664. > Flaky Test KafkaStreamsTest#testStateThreadClose > >

[jira] [Closed] (KAFKA-9770) Caching State Store does not Close Underlying State Store When Exception is Thrown During Flushing

[ https://issues.apache.org/jira/browse/KAFKA-9770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna closed KAFKA-9770. > Caching State Store does not Close Underlying State Store When Exception is > Thrown During Flushing

[jira] [Closed] (KAFKA-9675) RocksDB metrics reported always at zero

[ https://issues.apache.org/jira/browse/KAFKA-9675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna closed KAFKA-9675. > RocksDB metrics reported always at zero > --- > >

[jira] [Closed] (KAFKA-9355) RocksDB statistics are removed from JMX when EOS enabled and empty local state dir

[ https://issues.apache.org/jira/browse/KAFKA-9355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna closed KAFKA-9355. > RocksDB statistics are removed from JMX when EOS enabled and empty local > state dir > -

[jira] [Closed] (KAFKA-9603) Number of open files keeps increasing in Streams application

[ https://issues.apache.org/jira/browse/KAFKA-9603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna closed KAFKA-9603. > Number of open files keeps increasing in Streams application > --

[jira] [Closed] (KAFKA-9606) Document Metrics Changes from KIP-444

[ https://issues.apache.org/jira/browse/KAFKA-9606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna closed KAFKA-9606. > Document Metrics Changes from KIP-444 > - > > Key

[jira] [Closed] (KAFKA-8578) Add Functionality to Expose RocksDB Metrics

[ https://issues.apache.org/jira/browse/KAFKA-8578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna closed KAFKA-8578. > Add Functionality to Expose RocksDB Metrics > --- > >

<    1   2   3   4   5   6   7   8   9   10   >