[jira] [Commented] (KAFKA-10137) Clean-up retain Duplicate logic in Window Stores

[ https://issues.apache.org/jira/browse/KAFKA-10137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17168521#comment-17168521 ] Bruno Cadonna commented on KAFKA-10137: --- I also noticed this the last time I looke

[jira] [Commented] (KAFKA-10255) Fix flaky testOneWayReplicationWithAutorOffsetSync1 test

[ https://issues.apache.org/jira/browse/KAFKA-10255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17167727#comment-17167727 ] Bruno Cadonna commented on KAFKA-10255: --- https://builds.apache.org/job/kafka-pr-jd

[jira] [Commented] (KAFKA-9013) Flaky Test MirrorConnectorsIntegrationTest#testReplication

[ https://issues.apache.org/jira/browse/KAFKA-9013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17167726#comment-17167726 ] Bruno Cadonna commented on KAFKA-9013: -- https://builds.apache.org/job/kafka-pr-jdk8-

[jira] [Commented] (KAFKA-7540) Flaky Test ConsumerBounceTest#testClose

[ https://issues.apache.org/jira/browse/KAFKA-7540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17167720#comment-17167720 ] Bruno Cadonna commented on KAFKA-7540: -- https://builds.apache.org/job/kafka-pr-jdk11

[jira] [Commented] (KAFKA-9013) Flaky Test MirrorConnectorsIntegrationTest#testReplication

[ https://issues.apache.org/jira/browse/KAFKA-9013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17165744#comment-17165744 ] Bruno Cadonna commented on KAFKA-9013: -- https://builds.apache.org/job/kafka-pr-jdk14

[jira] [Issue Comment Deleted] (KAFKA-9013) Flaky Test MirrorConnectorsIntegrationTest#testReplication

[ https://issues.apache.org/jira/browse/KAFKA-9013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-9013: - Comment: was deleted (was: https://builds.apache.org/job/kafka-pr-jdk14-scala2.13/1714 {code:jav

[jira] [Commented] (KAFKA-9013) Flaky Test MirrorConnectorsIntegrationTest#testReplication

[ https://issues.apache.org/jira/browse/KAFKA-9013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17165743#comment-17165743 ] Bruno Cadonna commented on KAFKA-9013: -- https://builds.apache.org/job/kafka-pr-jdk11

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

[ https://issues.apache.org/jira/browse/KAFKA-9924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17164402#comment-17164402 ] Bruno Cadonna commented on KAFKA-9924: -- The scope of this ticket was extended to not

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=17163911#comment-17163911 ] Bruno Cadonna commented on KAFKA-10287: --- [~chia7712] Sorry, I was not aware that y

[jira] [Comment Edited] (KAFKA-8037) KTable restore may load bad data

[ https://issues.apache.org/jira/browse/KAFKA-8037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17163485#comment-17163485 ] Bruno Cadonna edited comment on KAFKA-8037 at 7/23/20, 12:21 PM: --

[jira] [Comment Edited] (KAFKA-8037) KTable restore may load bad data

[ https://issues.apache.org/jira/browse/KAFKA-8037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17163485#comment-17163485 ] Bruno Cadonna edited comment on KAFKA-8037 at 7/23/20, 12:04 PM: --

[jira] [Commented] (KAFKA-8037) KTable restore may load bad data

[ https://issues.apache.org/jira/browse/KAFKA-8037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17163485#comment-17163485 ] Bruno Cadonna commented on KAFKA-8037: -- I find the idea of putting records in its or

[jira] [Commented] (KAFKA-10252) MeteredTimestampedKeyValueStore not setting up correct topic name for GlobalKTable associating StateStores

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

[jira] [Assigned] (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 reassigned KAFKA-10221: - Assignee: Bruno Cadonna > Backport fix for KAFKA-9603 to 2.5 > ---

[jira] [Commented] (KAFKA-10217) Move nodeLevelSensor and storeLevelSensor methods from StreamsMetricsImpl to StreamsMetrics

[ https://issues.apache.org/jira/browse/KAFKA-10217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17152034#comment-17152034 ] Bruno Cadonna commented on KAFKA-10217: --- To use {{nodeLevelSensor()}} in {{Streams

[jira] [Commented] (KAFKA-10217) Move nodeLevelSensor and storeLevelSensor methods from StreamsMetricsImpl to StreamsMetrics

[ https://issues.apache.org/jira/browse/KAFKA-10217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17152030#comment-17152030 ] Bruno Cadonna commented on KAFKA-10217: --- If the goal of this ticket is to get rid

[jira] [Updated] (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 updated KAFKA-10221: -- Fix Version/s: 2.5.1 > Backport fix for KAFKA-9603 to 2.5 > -

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

Bruno Cadonna created KAFKA-10221: - Summary: Backport fix for KAFKA-9603 to 2.5 Key: KAFKA-10221 URL: https://issues.apache.org/jira/browse/KAFKA-10221 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-10219) KStream API support for multiple cluster broker

[ https://issues.apache.org/jira/browse/KAFKA-10219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17148407#comment-17148407 ] Bruno Cadonna commented on KAFKA-10219: --- [~sachinkurle] The current Kafka Streams

[jira] [Updated] (KAFKA-10219) KStream API support for multiple cluster broker

[ https://issues.apache.org/jira/browse/KAFKA-10219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-10219: -- Component/s: (was: KafkaConnect) streams > KStream API support for multip

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

[ https://issues.apache.org/jira/browse/KAFKA-10166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17146243#comment-17146243 ] Bruno Cadonna commented on KAFKA-10166: --- [~ableegoldman] [~rhauch] Good news rega

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

[ https://issues.apache.org/jira/browse/KAFKA-10166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17144788#comment-17144788 ] Bruno Cadonna commented on KAFKA-10166: --- [~ableegoldman] I agree that splitting is

[jira] [Assigned] (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 reassigned KAFKA-10166: - Assignee: Bruno Cadonna > Excessive TaskCorruptedException seen in testing > --

[jira] [Resolved] (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 resolved KAFKA-10148. --- Resolution: Fixed > Kafka Streams Restores too few Records with eos-beta Enabled >

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=17140328#comment-17140328 ] Bruno Cadonna commented on KAFKA-10179: --- [~desai.p.rohan] While I find the idea of

[jira] [Assigned] (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 reassigned KAFKA-10179: - Assignee: Bruno Cadonna > State Store Passes Wrong Changelog Topic to Serde for Optimiz

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

Bruno Cadonna created KAFKA-10179: - Summary: State Store Passes Wrong Changelog Topic to Serde for Optimized Source Tables Key: KAFKA-10179 URL: https://issues.apache.org/jira/browse/KAFKA-10179 Proje

[jira] [Updated] (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 updated KAFKA-10148: -- Description: System test {{StreamsEosTest.test_failure_and_recovery}} for eos-beta exposes a

[jira] [Updated] (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 updated KAFKA-10148: -- Description: System test {{StreamsEosTest.test_failure_and_recovery}} for eos-beta exposes a

[jira] [Updated] (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 updated KAFKA-10148: -- Description: System test {{StreamsEosTest.test_failure_and_recovery}} for eos-beta exposes a

[jira] [Updated] (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 updated KAFKA-10148: -- Description: System test {{StreamsEosTest.test_failure_and_recovery}} for eos-beta exposes a

[jira] [Updated] (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 updated KAFKA-10148: -- Description: System test {{StreamsEosTest.test_failure_and_recovery}} for eos-beta exposes a

[jira] [Updated] (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 updated KAFKA-10148: -- Description: System test {{StreamsEosTest.test_failure_and_recovery}} for eos-beta exposes a

[jira] [Updated] (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 updated KAFKA-10148: -- Description: System test {{StreamsEosTest.test_failure_and_recovery}} for eos-beta exposes a

[jira] [Updated] (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 updated KAFKA-10148: -- Description: System test {{StreamsEosTest.test_failure_and_recovery}} for eos-beta exposes a

[jira] [Updated] (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 updated KAFKA-10148: -- Description: System test {{StreamsEosTest.test_failure_and_recovery}} for eos-beta exposes a

[jira] [Commented] (KAFKA-10119) StreamsResetter fails with TimeoutException for older Brokers

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

[jira] [Assigned] (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 reassigned KAFKA-10148: - Assignee: Bruno Cadonna > Kafka Streams Restores too few Records with eos-beta Enabled

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

Bruno Cadonna created KAFKA-10148: - Summary: Kafka Streams Restores too few Records with eos-beta Enabled Key: KAFKA-10148 URL: https://issues.apache.org/jira/browse/KAFKA-10148 Project: Kafka

[jira] [Created] (KAFKA-10137) Clean-up retain Duplicate logic in Window Stores

Bruno Cadonna created KAFKA-10137: - Summary: Clean-up retain Duplicate logic in Window Stores Key: KAFKA-10137 URL: https://issues.apache.org/jira/browse/KAFKA-10137 Project: Kafka Issue Type

[jira] [Updated] (KAFKA-10119) StreamsResetter fails with TimeoutException for older Brokers

[ https://issues.apache.org/jira/browse/KAFKA-10119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-10119: -- Priority: Blocker (was: Major) > StreamsResetter fails with TimeoutException for older Broker

[jira] [Assigned] (KAFKA-9991) Flaky Test KTableSourceTopicRestartIntegrationTest.shouldRestoreAndProgressWhenTopicWrittenToDuringRestorationWithEosAlphaEnabled

[ https://issues.apache.org/jira/browse/KAFKA-9991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna reassigned KAFKA-9991: Assignee: Guozhang Wang > Flaky Test > KTableSourceTopicRestartIntegrationTest.shouldRest

[jira] [Created] (KAFKA-10119) StreamsResetter fails with TimeoutException for older Brokers

Bruno Cadonna created KAFKA-10119: - Summary: StreamsResetter fails with TimeoutException for older Brokers Key: KAFKA-10119 URL: https://issues.apache.org/jira/browse/KAFKA-10119 Project: Kafka

[jira] [Resolved] (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 resolved KAFKA-9173. -- Fix Version/s: 2.6.0 Resolution: Fixed > StreamsPartitionAssignor assigns partitions to

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

[ https://issues.apache.org/jira/browse/KAFKA-9173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17113958#comment-17113958 ] Bruno Cadonna commented on KAFKA-9173: -- The issue that all 10 tasks are assigned to

[jira] [Updated] (KAFKA-10015) React Smartly to Unexpected Errors on Stream Threads

[ https://issues.apache.org/jira/browse/KAFKA-10015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-10015: -- Affects Version/s: 2.5.0 > React Smartly to Unexpected Errors on Stream Threads >

[jira] [Updated] (KAFKA-10015) React Smartly to Unexpected Errors on Stream Threads

[ https://issues.apache.org/jira/browse/KAFKA-10015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-10015: -- Labels: needs-kip (was: ) > React Smartly to Unexpected Errors on Stream Threads > --

[jira] [Updated] (KAFKA-10015) React Smartly to Unexpected Errors on Stream Threads

[ https://issues.apache.org/jira/browse/KAFKA-10015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-10015: -- Summary: React Smartly to Unexpected Errors on Stream Threads (was: React to Unexpected Error

[jira] [Assigned] (KAFKA-10015) React Smartly to Unexpected Errors on Stream Threads

[ https://issues.apache.org/jira/browse/KAFKA-10015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna reassigned KAFKA-10015: - Assignee: Bruno Cadonna > React Smartly to Unexpected Errors on Stream Threads > --

[jira] [Created] (KAFKA-10015) React to Unexpected Errors on Stream Threads

Bruno Cadonna created KAFKA-10015: - Summary: React to Unexpected Errors on Stream Threads Key: KAFKA-10015 URL: https://issues.apache.org/jira/browse/KAFKA-10015 Project: Kafka Issue Type: Im

[jira] [Commented] (KAFKA-9989) StreamsUpgradeTest.test_metadata_upgrade could not guarantee all processor gets assigned task

[ https://issues.apache.org/jira/browse/KAFKA-9989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17108076#comment-17108076 ] Bruno Cadonna commented on KAFKA-9989: -- We do not really check for an empty assignme

[jira] [Closed] (KAFKA-6039) Improve TaskAssignor to be more load balanced

[ https://issues.apache.org/jira/browse/KAFKA-6039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna closed KAFKA-6039. > Improve TaskAssignor to be more load balanced > - > >

[jira] [Closed] (KAFKA-5578) Streams Task Assignor should consider the staleness of state directories when allocating tasks

[ https://issues.apache.org/jira/browse/KAFKA-5578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna closed KAFKA-5578. > Streams Task Assignor should consider the staleness of state directories when > allocating tasks > -

[jira] [Resolved] (KAFKA-5578) Streams Task Assignor should consider the staleness of state directories when allocating tasks

[ https://issues.apache.org/jira/browse/KAFKA-5578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-5578. -- Resolution: Duplicate > Streams Task Assignor should consider the staleness of state directorie

[jira] [Resolved] (KAFKA-6039) Improve TaskAssignor to be more load balanced

[ https://issues.apache.org/jira/browse/KAFKA-6039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-6039. -- Resolution: Duplicate > Improve TaskAssignor to be more load balanced > ---

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=17105703#comment-17105703 ] Bruno Cadonna commented on KAFKA-9603: -- I think I found the cause of this issue. Wit

[jira] [Assigned] (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 reassigned KAFKA-9603: Assignee: Bruno Cadonna > Number of open files keeps increasing in Streams application > -

[jira] [Resolved] (KAFKA-5948) EosIntegrationTest fails with TopicAlreadyMarkedForDeletionException

[ https://issues.apache.org/jira/browse/KAFKA-5948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-5948. -- Resolution: Cannot Reproduce > EosIntegrationTest fails with TopicAlreadyMarkedForDeletionExcep

[jira] [Assigned] (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 reassigned KAFKA-9924: Assignee: Bruno Cadonna > Add RocksDB Memory Consumption to RocksDB Metrics > ---

[jira] [Assigned] (KAFKA-5948) EosIntegrationTest fails with TopicAlreadyMarkedForDeletionException

[ https://issues.apache.org/jira/browse/KAFKA-5948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna reassigned KAFKA-5948: Assignee: Bruno Cadonna > EosIntegrationTest fails with TopicAlreadyMarkedForDeletionExcep

[jira] [Commented] (KAFKA-9936) kafka-streams 2.5.0 missing dependency?

[ https://issues.apache.org/jira/browse/KAFKA-9936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17096982#comment-17096982 ] Bruno Cadonna commented on KAFKA-9936: -- Ah, OK. So closing the ticket as "Not a Bug"

[jira] [Commented] (KAFKA-9936) kafka-streams 2.5.0 missing dependency?

[ https://issues.apache.org/jira/browse/KAFKA-9936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17096979#comment-17096979 ] Bruno Cadonna commented on KAFKA-9936: -- Now I am a bit confused. Earlier you wrote t

[jira] [Commented] (KAFKA-9936) kafka-streams 2.5.0 missing dependency?

[ https://issues.apache.org/jira/browse/KAFKA-9936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17096973#comment-17096973 ] Bruno Cadonna commented on KAFKA-9936: -- Fair enough. However, it was introduced in p

[jira] [Resolved] (KAFKA-9936) kafka-streams 2.5.0 missing dependency?

[ https://issues.apache.org/jira/browse/KAFKA-9936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-9936. -- Resolution: Not A Bug > kafka-streams 2.5.0 missing dependency? > -

[jira] [Commented] (KAFKA-9936) kafka-streams 2.5.0 missing dependency?

[ https://issues.apache.org/jira/browse/KAFKA-9936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17096351#comment-17096351 ] Bruno Cadonna commented on KAFKA-9936: -- [~SledgeHammer], Thank you for the report! A

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

Bruno Cadonna created KAFKA-9924: Summary: Add RocksDB Memory Consumption to RocksDB Metrics Key: KAFKA-9924 URL: https://issues.apache.org/jira/browse/KAFKA-9924 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-9923) Join window store duplicates can be compacted in changelog

[ https://issues.apache.org/jira/browse/KAFKA-9923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17093816#comment-17093816 ] Bruno Cadonna commented on KAFKA-9923: -- [~ableegoldman] Is https://issues.apache.org

[jira] [Comment Edited] (KAFKA-9916) Materialize Table-Table Join Result to Avoid Performing Same Join Twice

[ https://issues.apache.org/jira/browse/KAFKA-9916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17093416#comment-17093416 ] Bruno Cadonna edited comment on KAFKA-9916 at 4/27/20, 12:34 PM: --

[jira] [Comment Edited] (KAFKA-9916) Materialize Table-Table Join Result to Avoid Performing Same Join Twice

[ https://issues.apache.org/jira/browse/KAFKA-9916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17093416#comment-17093416 ] Bruno Cadonna edited comment on KAFKA-9916 at 4/27/20, 12:33 PM: --

[jira] [Comment Edited] (KAFKA-9916) Materialize Table-Table Join Result to Avoid Performing Same Join Twice

[ https://issues.apache.org/jira/browse/KAFKA-9916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17093416#comment-17093416 ] Bruno Cadonna edited comment on KAFKA-9916 at 4/27/20, 12:15 PM: --

[jira] [Commented] (KAFKA-9916) Materialize Table-Table Join Result to Avoid Performing Same Join Twice

[ https://issues.apache.org/jira/browse/KAFKA-9916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17093416#comment-17093416 ] Bruno Cadonna commented on KAFKA-9916: -- [~guozhang] Thank you for adding all the det

[jira] [Created] (KAFKA-9916) Materialize Table-Table Join Result to Avoid Performing Same Join Twice

Bruno Cadonna created KAFKA-9916: Summary: Materialize Table-Table Join Result to Avoid Performing Same Join Twice Key: KAFKA-9916 URL: https://issues.apache.org/jira/browse/KAFKA-9916 Project: Kafka

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=17090715#comment-17090715 ] Bruno Cadonna commented on KAFKA-9603: -- [~lpandzic] Thank you for the information.

[jira] [Commented] (KAFKA-8924) Default grace period (-1) of TimeWindows causes suppress to emit events after 24h

[ https://issues.apache.org/jira/browse/KAFKA-8924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17088442#comment-17088442 ] Bruno Cadonna commented on KAFKA-8924: -- [~vvcephei] I like your proposal {code:java

[jira] [Updated] (KAFKA-9881) Verify whether RocksDBMetrics Get Measurements from RocksDB in a Unit Test instead of an Intergration Test

[ https://issues.apache.org/jira/browse/KAFKA-9881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-9881: - Summary: Verify whether RocksDBMetrics Get Measurements from RocksDB in a Unit Test instead of an

[jira] [Created] (KAFKA-9881) Verify whether RocksDBMetrics Get Measurements from RocksDB in a Unit Test instead of a Intergration Test

Bruno Cadonna created KAFKA-9881: Summary: Verify whether RocksDBMetrics Get Measurements from RocksDB in a Unit Test instead of a Intergration Test Key: KAFKA-9881 URL: https://issues.apache.org/jira/browse/KAFKA

[jira] [Resolved] (KAFKA-9117) Add active-process-ratio Metric

[ https://issues.apache.org/jira/browse/KAFKA-9117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-9117. -- Fix Version/s: (was: 2.6.0) Resolution: Duplicate > Add active-process-ratio Metric

[jira] [Updated] (KAFKA-9230) Change User Customizable Metrics API in StreamsMetrics interface

[ https://issues.apache.org/jira/browse/KAFKA-9230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-9230: - Fix Version/s: 2.5.0 > Change User Customizable Metrics API in StreamsMetrics interface > ---

[jira] [Resolved] (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 resolved KAFKA-9664. -- Resolution: Cannot Reproduce > Flaky Test KafkaStreamsTest#testStateThreadClose > -

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

[ https://issues.apache.org/jira/browse/KAFKA-9664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17083922#comment-17083922 ] Bruno Cadonna commented on KAFKA-9664: -- Thank you for checking! Will close the ticke

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

[ https://issues.apache.org/jira/browse/KAFKA-9664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17078293#comment-17078293 ] Bruno Cadonna commented on KAFKA-9664: -- [~ableegoldman] Where did this flaky test ha

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=17073468#comment-17073468 ] Bruno Cadonna commented on KAFKA-9770: -- I will keep this ticket open until you will

[jira] [Reopened] (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 reopened KAFKA-9770: -- > Caching State Store does not Close Underlying State Store When Exception is > Thrown During Flus

[jira] [Updated] (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 updated KAFKA-9770: - Affects Version/s: (was: 2.5.0) 2.0.0 > Caching State Store does not C

[jira] [Updated] (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 updated KAFKA-9770: - Affects Version/s: (was: 2.6.0) 2.5.0 > Caching State Store does not C

[jira] [Assigned] (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 reassigned KAFKA-9770: Assignee: Bruno Cadonna > Caching State Store does not Close Underlying State Store When E

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

Bruno Cadonna created KAFKA-9770: Summary: Caching State Store does not Close Underlying State Store When Exception is Thrown During Flushing Key: KAFKA-9770 URL: https://issues.apache.org/jira/browse/KAFKA-9770

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

[ https://issues.apache.org/jira/browse/KAFKA-8897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17065935#comment-17065935 ] Bruno Cadonna commented on KAFKA-8897: -- [~mjsax], [~axitkhurana] could investigate w

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

[ https://issues.apache.org/jira/browse/KAFKA-8897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17065799#comment-17065799 ] Bruno Cadonna commented on KAFKA-8897: -- Hi [~axitkhurana]! Thank you for picking thi

[jira] [Created] (KAFKA-9738) Add Generics Type Parameters to forwarded() in MockProcessorContext

Bruno Cadonna created KAFKA-9738: Summary: Add Generics Type Parameters to forwarded() in MockProcessorContext Key: KAFKA-9738 URL: https://issues.apache.org/jira/browse/KAFKA-9738 Project: Kafka

[jira] [Updated] (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 updated KAFKA-9675: - Fix Version/s: 2.5.1 > RocksDB metrics reported always at zero >

[jira] [Commented] (KAFKA-9717) KafkaStreams#metrics() method randomly throws NullPointerException

[ https://issues.apache.org/jira/browse/KAFKA-9717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17058972#comment-17058972 ] Bruno Cadonna commented on KAFKA-9717: -- FYI: All metrics are also exposed to JMX.

[jira] [Commented] (KAFKA-9717) KafkaStreams#metrics() method randomly throws NullPointerException

[ https://issues.apache.org/jira/browse/KAFKA-9717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17058929#comment-17058929 ] Bruno Cadonna commented on KAFKA-9717: -- [~Bataitis] Thank you for the bug report! J

[jira] [Assigned] (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 reassigned KAFKA-9675: Assignee: Bruno Cadonna > RocksDB metrics reported always at zero > --

[jira] [Updated] (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 updated KAFKA-9675: - Issue Type: Bug (was: Improvement) > RocksDB metrics reported always at zero > -

[jira] [Commented] (KAFKA-9611) KGroupedTable.aggregate(...) emits incorrect values

[ https://issues.apache.org/jira/browse/KAFKA-9611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17047386#comment-17047386 ] Bruno Cadonna commented on KAFKA-9611: -- I am glad that we reached an agreement. > K

[jira] [Updated] (KAFKA-9611) KGroupedTable.aggregate(...) emits incorrect values

[ https://issues.apache.org/jira/browse/KAFKA-9611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-9611: - Issue Type: Improvement (was: Bug) > KGroupedTable.aggregate(...) emits incorrect values > -

[jira] [Commented] (KAFKA-9611) KGroupedTable.aggregate(...) emits incorrect values

[ https://issues.apache.org/jira/browse/KAFKA-9611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17047318#comment-17047318 ] Bruno Cadonna commented on KAFKA-9611: -- [~vvcephei] Thank you for the detailed expla

[jira] [Commented] (KAFKA-9611) KGroupedTable.aggregate(...) emits incorrect values

[ https://issues.apache.org/jira/browse/KAFKA-9611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17046648#comment-17046648 ] Bruno Cadonna commented on KAFKA-9611: -- [~mjsax] OK, I see. That would explain the o

[jira] [Commented] (KAFKA-9611) KGroupedTable.aggregate(...) emits incorrect values

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

<    3   4   5   6   7   8   9   10   11   >