[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=17148407#comment-17148407 ] Bruno Cadonna commented on KAFKA-10219: --- [~sachinkurle] The current Kafka Streams documentation

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

[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=17154406#comment-17154406 ] Bruno Cadonna commented on KAFKA-10252: --- Thank you for the bug report, [~bulbfreeman]. I think

[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=17152034#comment-17152034 ] Bruno Cadonna commented on KAFKA-10217: --- To use {{nodeLevelSensor()}} in {{StreamsMetrics}} we

[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=17152030#comment-17152030 ] Bruno Cadonna commented on KAFKA-10217: --- If the goal of this ticket is to get rid of the casts of

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

[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

[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] [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] [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=17146243#comment-17146243 ] Bruno Cadonna commented on KAFKA-10166: --- [~ableegoldman] [~rhauch] Good news regarding the

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

[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=17144788#comment-17144788 ] Bruno Cadonna commented on KAFKA-10166: --- [~ableegoldman] I agree that splitting is a good idea. >

[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

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

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

[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=17133096#comment-17133096 ] Bruno Cadonna commented on KAFKA-10119: --- [~ableegoldman] Thank you for taking care of this. >

[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] [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-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=17164402#comment-17164402 ] Bruno Cadonna commented on KAFKA-9924: -- The scope of this ticket was extended to not only monitor

[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=17163485#comment-17163485 ] Bruno Cadonna edited comment on KAFKA-8037 at 7/23/20, 12:04 PM: - I find

[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=17163485#comment-17163485 ] Bruno Cadonna edited comment on KAFKA-8037 at 7/23/20, 12:21 PM: - I find

[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=17163485#comment-17163485 ] Bruno Cadonna commented on KAFKA-8037: -- I find the idea of putting records in its original byte

[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=17165743#comment-17165743 ] Bruno Cadonna commented on KAFKA-9013: -- https://builds.apache.org/job/kafka-pr-jdk11-scala2.13/7576/

[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=17165744#comment-17165744 ] Bruno Cadonna commented on KAFKA-9013: -- https://builds.apache.org/job/kafka-pr-jdk14-scala2.13/1714

[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

[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=17163911#comment-17163911 ] Bruno Cadonna commented on KAFKA-10287: --- [~chia7712] Sorry, I was not aware that you assigned this

[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=17168521#comment-17168521 ] Bruno Cadonna commented on KAFKA-10137: --- I also noticed this the last time I looked at

[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: -- Component/s: unit tests streams > Add Unit Test cases for missing methods in

[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: -- Labels: newbie (was: ) > Add Unit Test cases for missing methods in ThreadCacheTest >

[jira] [Updated] (KAFKA-10766) Add Unit Test cases for RocksDbRangeIterator

[ https://issues.apache.org/jira/browse/KAFKA-10766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-10766: -- Labels: newbie (was: ) > Add Unit Test cases for RocksDbRangeIterator >

[jira] [Updated] (KAFKA-10766) Add Unit Test cases for RocksDbRangeIterator

[ https://issues.apache.org/jira/browse/KAFKA-10766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-10766: -- Component/s: unit tests streams > Add Unit Test cases for

[jira] [Commented] (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:comment-tabpanel=17245848#comment-17245848 ] Bruno Cadonna commented on KAFKA-10772: --- [~thebearmayor], do you run 2.6.1 built from

[jira] [Commented] (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:comment-tabpanel=17245927#comment-17245927 ] Bruno Cadonna commented on KAFKA-10772: --- The fix for KAFKA-10284 is a pure broker-side fix. So

[jira] [Comment Edited] (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:comment-tabpanel=17245927#comment-17245927 ] Bruno Cadonna edited comment on KAFKA-10772 at 12/8/20, 2:48 PM: - The

[jira] [Assigned] (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 reassigned KAFKA-10772: - Assignee: Bruno Cadonna > java.lang.IllegalStateException: There are insufficient

[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=17246404#comment-17246404 ] Bruno Cadonna commented on KAFKA-7540: --

[jira] [Comment Edited] (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:comment-tabpanel=17246806#comment-17246806 ] Bruno Cadonna edited comment on KAFKA-10772 at 12/9/20, 8:35 PM: - bq. It

[jira] [Commented] (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:comment-tabpanel=17246797#comment-17246797 ] Bruno Cadonna commented on KAFKA-10772: --- I think this issue is fixed for brokers 2.5 and above via

[jira] [Commented] (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:comment-tabpanel=17246806#comment-17246806 ] Bruno Cadonna commented on KAFKA-10772: --- bq. It seems bad, and quite possibly a regression, for

[jira] [Comment Edited] (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:comment-tabpanel=17246797#comment-17246797 ] Bruno Cadonna edited comment on KAFKA-10772 at 12/9/20, 8:22 PM: - I

[jira] [Comment Edited] (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:comment-tabpanel=17246797#comment-17246797 ] Bruno Cadonna edited comment on KAFKA-10772 at 12/9/20, 8:22 PM: - I

[jira] [Comment Edited] (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:comment-tabpanel=17246797#comment-17246797 ] Bruno Cadonna edited comment on KAFKA-10772 at 12/9/20, 8:20 PM: - I

[jira] [Commented] (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:comment-tabpanel=17246677#comment-17246677 ] Bruno Cadonna commented on KAFKA-10772: --- I think, I found the bug. If a static member joins the

[jira] [Resolved] (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 resolved KAFKA-10772. --- Resolution: Duplicate > java.lang.IllegalStateException: There are insufficient bytes

[jira] [Comment Edited] (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:comment-tabpanel=17247142#comment-17247142 ] Bruno Cadonna edited comment on KAFKA-10772 at 12/10/20, 10:13 AM: ---

[jira] [Commented] (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:comment-tabpanel=17247142#comment-17247142 ] Bruno Cadonna commented on KAFKA-10772: --- [~lkokhreidze] [~thebearmayor] To sum up: - This bug is

[jira] [Updated] (KAFKA-10292) fix flaky streams/streams_broker_bounce_test.py

[ https://issues.apache.org/jira/browse/KAFKA-10292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-10292: -- Description: {quote} Module: kafkatest.tests.streams.streams_broker_bounce_test Class:

[jira] [Updated] (KAFKA-10788) Streamlining Tests in CachingInMemoryKeyValueStoreTest

[ https://issues.apache.org/jira/browse/KAFKA-10788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-10788: -- Labels: newbie (was: ) > Streamlining Tests in CachingInMemoryKeyValueStoreTest >

[jira] [Updated] (KAFKA-10789) Streamlining Tests in ChangeLoggingKeyValueBytesStoreTest

[ https://issues.apache.org/jira/browse/KAFKA-10789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-10789: -- Component/s: streams > Streamlining Tests in ChangeLoggingKeyValueBytesStoreTest >

[jira] [Updated] (KAFKA-10789) Streamlining Tests in ChangeLoggingKeyValueBytesStoreTest

[ https://issues.apache.org/jira/browse/KAFKA-10789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-10789: -- Priority: Minor (was: Major) > Streamlining Tests in ChangeLoggingKeyValueBytesStoreTest >

[jira] [Updated] (KAFKA-10789) Streamlining Tests in ChangeLoggingKeyValueBytesStoreTest

[ https://issues.apache.org/jira/browse/KAFKA-10789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-10789: -- Labels: newbie (was: ) > Streamlining Tests in ChangeLoggingKeyValueBytesStoreTest >

[jira] [Updated] (KAFKA-10788) Streamlining Tests in CachingInMemoryKeyValueStoreTest

[ https://issues.apache.org/jira/browse/KAFKA-10788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-10788: -- Component/s: unit tests streams > Streamlining Tests in

[jira] [Updated] (KAFKA-10789) Streamlining Tests in ChangeLoggingKeyValueBytesStoreTest

[ https://issues.apache.org/jira/browse/KAFKA-10789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-10789: -- Component/s: unit tests > Streamlining Tests in ChangeLoggingKeyValueBytesStoreTest >

[jira] [Commented] (KAFKA-10843) Kafka Streams metadataForKey method returns null but allMetadata has the details

[ https://issues.apache.org/jira/browse/KAFKA-10843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17249674#comment-17249674 ] Bruno Cadonna commented on KAFKA-10843: --- [~maria_87] What do you mean exactly with "stretch

[jira] [Commented] (KAFKA-10843) Kafka Streams metadataForKey method returns null but allMetadata has the details

[ https://issues.apache.org/jira/browse/KAFKA-10843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17251690#comment-17251690 ] Bruno Cadonna commented on KAFKA-10843: --- I had another look at the code and I see two options

[jira] [Comment Edited] (KAFKA-10843) Kafka Streams metadataForKey method returns null but allMetadata has the details

[ https://issues.apache.org/jira/browse/KAFKA-10843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17251690#comment-17251690 ] Bruno Cadonna edited comment on KAFKA-10843 at 12/18/20, 11:02 AM: --- I

[jira] [Commented] (KAFKA-10843) Kafka Streams metadataForKey method returns null but allMetadata has the details

[ https://issues.apache.org/jira/browse/KAFKA-10843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17247886#comment-17247886 ] Bruno Cadonna commented on KAFKA-10843: --- [~maria_87] Thank you for the report! {{allMetadata()}}

[jira] [Commented] (KAFKA-10062) Add a method to retrieve the current timestamp as known by the Streams app

[ https://issues.apache.org/jira/browse/KAFKA-10062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17232638#comment-17232638 ] Bruno Cadonna commented on KAFKA-10062: --- [~rohitdeshaws] I think [~wbottrell] and [~psmolinski]

[jira] [Commented] (KAFKA-10688) Handle accidental truncation of repartition topics as exceptional failure

[ https://issues.apache.org/jira/browse/KAFKA-10688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17228465#comment-17228465 ] Bruno Cadonna commented on KAFKA-10688: --- Maybe I misunderstood your previous comment. In your

[jira] [Comment Edited] (KAFKA-10643) Static membership - repetitive PreparingRebalance with updating metadata for member reason

[ https://issues.apache.org/jira/browse/KAFKA-10643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17237265#comment-17237265 ] Bruno Cadonna edited comment on KAFKA-10643 at 11/23/20, 10:08 AM: ---

[jira] [Commented] (KAFKA-10758) Kafka Streams consuming from a pattern goes to PENDING_SHUTDOWN when adding a new topic

[ https://issues.apache.org/jira/browse/KAFKA-10758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17237270#comment-17237270 ] Bruno Cadonna commented on KAFKA-10758: --- [~davideicardi] Thank you for the report! Could you

[jira] [Commented] (KAFKA-10643) Static membership - repetitive PreparingRebalance with updating metadata for member reason

[ https://issues.apache.org/jira/browse/KAFKA-10643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17237265#comment-17237265 ] Bruno Cadonna commented on KAFKA-10643: --- [~eran-levy] Just to avoid misunderstandings: What do you

[jira] [Commented] (KAFKA-10614) Group coordinator onElection/onResignation should guard against leader epoch

[ https://issues.apache.org/jira/browse/KAFKA-10614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17224992#comment-17224992 ] Bruno Cadonna commented on KAFKA-10614: --- FYI: This bug makes system test

[jira] [Commented] (KAFKA-10633) Constant probing rebalances in Streams 2.6

[ https://issues.apache.org/jira/browse/KAFKA-10633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17224555#comment-17224555 ] Bruno Cadonna commented on KAFKA-10633: --- [~thebearmayor] [~eran-levy] FYI: The 2.6.1 release is

[jira] [Updated] (KAFKA-10631) ProducerFencedException is not Handled on Offest Commit

[ https://issues.apache.org/jira/browse/KAFKA-10631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-10631: -- Description: The transaction manager does currently not handle producer fenced errors

[jira] [Created] (KAFKA-10631) ProducerFencedException is not Handled on Offest Commit

Bruno Cadonna created KAFKA-10631: - Summary: ProducerFencedException is not Handled on Offest Commit Key: KAFKA-10631 URL: https://issues.apache.org/jira/browse/KAFKA-10631 Project: Kafka

[jira] [Commented] (KAFKA-10686) Pluggable standby tasks assignor for Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-10686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17226725#comment-17226725 ] Bruno Cadonna commented on KAFKA-10686: --- Hi [~lkokhreidze], I guess this ticket makes sense.

[jira] [Commented] (KAFKA-10688) Handle accidental truncation of repartition topics as exceptional failure

[ https://issues.apache.org/jira/browse/KAFKA-10688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17227236#comment-17227236 ] Bruno Cadonna commented on KAFKA-10688: --- [~guozhang], Thank you for the proposal. Shouldn't we

[jira] [Comment Edited] (KAFKA-12230) Some Kafka TopologyTestDriver-based unit tests can't be run on Windows file system

[ https://issues.apache.org/jira/browse/KAFKA-12230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17269434#comment-17269434 ] Bruno Cadonna edited comment on KAFKA-12230 at 1/21/21, 4:57 PM: - Hi

[jira] [Commented] (KAFKA-12230) Some Kafka TopologyTestDriver-based unit tests can't be run on Windows file system

[ https://issues.apache.org/jira/browse/KAFKA-12230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17269434#comment-17269434 ] Bruno Cadonna commented on KAFKA-12230: --- Hi [~iponomarev], Thank you for the ticket and the PR.

[jira] [Assigned] (KAFKA-12185) Flaky Test StoreQueryIntegrationTest#shouldQueryAllStalePartitionStores

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

[jira] [Reopened] (KAFKA-12185) Flaky Test StoreQueryIntegrationTest#shouldQueryAllStalePartitionStores

[ https://issues.apache.org/jira/browse/KAFKA-12185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna reopened KAFKA-12185: --- > Flaky Test StoreQueryIntegrationTest#shouldQueryAllStalePartitionStores >

[jira] [Assigned] (KAFKA-12185) Flaky Test StoreQueryIntegrationTest#shouldQueryAllStalePartitionStores

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

[jira] [Updated] (KAFKA-12223) Consider not to Treat Mixed Usage of Shared and Dedicated Block Caches among RocksDB State Stores as Illegal State

[ https://issues.apache.org/jira/browse/KAFKA-12223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-12223: -- Issue Type: Improvement (was: Bug) > Consider not to Treat Mixed Usage of Shared and

[jira] [Created] (KAFKA-12223) Consider not to Treat Mixed Usage of Shared and Dedicated Block Caches among RocksDB State Stores as Illegal State

Bruno Cadonna created KAFKA-12223: - Summary: Consider not to Treat Mixed Usage of Shared and Dedicated Block Caches among RocksDB State Stores as Illegal State Key: KAFKA-12223 URL:

[jira] [Commented] (KAFKA-10292) fix flaky streams/streams_broker_bounce_test.py

[ https://issues.apache.org/jira/browse/KAFKA-10292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17250224#comment-17250224 ] Bruno Cadonna commented on KAFKA-10292: --- [~chia7712] Sorry for the late reply. I think the fix

[jira] [Comment Edited] (KAFKA-10292) fix flaky streams/streams_broker_bounce_test.py

[ https://issues.apache.org/jira/browse/KAFKA-10292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17250224#comment-17250224 ] Bruno Cadonna edited comment on KAFKA-10292 at 12/16/20, 10:14 AM: ---

[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: - Fix Version/s: 2.6.0 > Verify whether RocksDBMetrics Get Measurements from RocksDB in a Unit

[jira] [Assigned] (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 reassigned KAFKA-9881: Assignee: Bruno Cadonna > Verify whether RocksDBMetrics Get Measurements from RocksDB in

[jira] [Closed] (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 closed KAFKA-9881. > Verify whether RocksDBMetrics Get Measurements from RocksDB in a Unit Test > instead of an

[jira] [Resolved] (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 resolved KAFKA-9881. -- Resolution: Fixed > Verify whether RocksDBMetrics Get Measurements from RocksDB in a Unit Test

[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=17359812#comment-17359812 ] Bruno Cadonna commented on KAFKA-12920: --- Is this regression? Should this be a blocker for 3.0? >

[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=17359162#comment-17359162 ] Bruno Cadonna commented on KAFKA-12905: --- [~a493172422] Could you convert this ticket to a sub-task

[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=17360983#comment-17360983 ] Bruno Cadonna commented on KAFKA-12892: --- Is PR #10821 supposed to solve the issue? I still see a

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

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

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

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

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

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

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