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

[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] [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] [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] [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] [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] [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-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] [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-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: -- Labels: newbie (was: ) > 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: -- Component/s: streams > Streamlining Tests in ChangeLoggingKeyValueBytesStoreTest >

[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-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-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] [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] [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] [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-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-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] [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] [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-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-10635) Streams application fails with OutOfOrderSequenceException after rolling restarts of brokers

[ https://issues.apache.org/jira/browse/KAFKA-10635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-10635: -- Component/s: (was: streams) producer core > Streams

[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-10555) Improve client state machine

[ https://issues.apache.org/jira/browse/KAFKA-10555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17210968#comment-17210968 ] Bruno Cadonna commented on KAFKA-10555: --- [~ableegoldman] Thank you for your detailed analysis!

[jira] [Resolved] (KAFKA-9585) Flaky Test: LagFetchIntegrationTest#shouldFetchLagsDuringRebalancingWithOptimization

[ https://issues.apache.org/jira/browse/KAFKA-9585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-9585. -- Resolution: Cannot Reproduce > Flaky Test: >

[jira] [Assigned] (KAFKA-10484) Reduce Metrics Exposed by Streams

[ https://issues.apache.org/jira/browse/KAFKA-10484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna reassigned KAFKA-10484: - Assignee: Bruno Cadonna > Reduce Metrics Exposed by Streams >

[jira] [Commented] (KAFKA-10514) failed test StateDirectoryTest.shouldLogStateDirCleanerMessage

[ https://issues.apache.org/jira/browse/KAFKA-10514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17200647#comment-17200647 ] Bruno Cadonna commented on KAFKA-10514: --- Thank you for catching this! This test seems to be flaky

[jira] [Assigned] (KAFKA-10514) failed test StateDirectoryTest.shouldLogStateDirCleanerMessage

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

[jira] [Commented] (KAFKA-8266) Improve `testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup`

[ https://issues.apache.org/jira/browse/KAFKA-8266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17199409#comment-17199409 ] Bruno Cadonna commented on KAFKA-8266: -- This test failed for me with: {code:java}

[jira] [Commented] (KAFKA-10484) Reduce Metrics Exposed by Streams

[ https://issues.apache.org/jira/browse/KAFKA-10484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17199387#comment-17199387 ] Bruno Cadonna commented on KAFKA-10484: --- I think, we should first try to find a good way to

[jira] [Commented] (KAFKA-8690) Flakey test ConnectWorkerIntegrationTest#testAddAndRemoveWorke

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

[jira] [Updated] (KAFKA-10500) Add API to Start and Stop Stream Threads

[ https://issues.apache.org/jira/browse/KAFKA-10500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-10500: -- Parent: (was: KAFKA-10015) Issue Type: New Feature (was: Sub-task) > Add API to

[jira] [Updated] (KAFKA-10500) Add API to Start and Stop Stream Threads

[ https://issues.apache.org/jira/browse/KAFKA-10500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-10500: -- Labels: needs-kip (was: ) > Add API to Start and Stop Stream Threads >

[jira] [Created] (KAFKA-10500) Add API to Start and Stop Stream Threads

Bruno Cadonna created KAFKA-10500: - Summary: Add API to Start and Stop Stream Threads Key: KAFKA-10500 URL: https://issues.apache.org/jira/browse/KAFKA-10500 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-10484) Reduce Metrics Exposed by Streams

Bruno Cadonna created KAFKA-10484: - Summary: Reduce Metrics Exposed by Streams Key: KAFKA-10484 URL: https://issues.apache.org/jira/browse/KAFKA-10484 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-10481) Consider Improving the Success Criteria of Streams' System Test StreamsBrokerBounceTest

Bruno Cadonna created KAFKA-10481: - Summary: Consider Improving the Success Criteria of Streams' System Test StreamsBrokerBounceTest Key: KAFKA-10481 URL: https://issues.apache.org/jira/browse/KAFKA-10481

[jira] [Assigned] (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 reassigned KAFKA-10292: - Assignee: Bruno Cadonna > fix flaky streams/streams_broker_bounce_test.py >

[jira] [Commented] (KAFKA-10405) Flaky Test org.apache.kafka.streams.integration.PurgeRepartitionTopicIntegrationTest.shouldRestoreState

[ https://issues.apache.org/jira/browse/KAFKA-10405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17192122#comment-17192122 ] Bruno Cadonna commented on KAFKA-10405: --- Another failure:

[jira] [Updated] (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 updated KAFKA-9924: - Fix Version/s: 2.7.0 > Add RocksDB Memory Consumption to RocksDB Metrics >

[jira] [Resolved] (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 resolved KAFKA-9924. -- Resolution: Fixed > Add RocksDB Memory Consumption to RocksDB Metrics >

[jira] [Updated] (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 updated KAFKA-10355: -- Fix Version/s: 2.7.0 > Handle accidental deletion of source-topics as exceptional failure >

[jira] [Resolved] (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 resolved KAFKA-10293. --- Resolution: Fixed > fix flaky streams/streams_eos_test.py >

[jira] [Assigned] (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 reassigned KAFKA-10293: - Assignee: Bruno Cadonna > fix flaky streams/streams_eos_test.py >

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

[ https://issues.apache.org/jira/browse/KAFKA-10293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17183927#comment-17183927 ] Bruno Cadonna commented on KAFKA-10293: --- [~chia7712] I will close this ticket because it seems

[jira] [Comment Edited] (KAFKA-10357) Handle accidental deletion of repartition-topics as exceptional failure

[ https://issues.apache.org/jira/browse/KAFKA-10357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17183918#comment-17183918 ] Bruno Cadonna edited comment on KAFKA-10357 at 8/25/20, 10:30 AM: -- Yes,

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

[ https://issues.apache.org/jira/browse/KAFKA-10357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17183918#comment-17183918 ] Bruno Cadonna commented on KAFKA-10357: --- Yes, I also agree that initialize + config is the easiest

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

[ https://issues.apache.org/jira/browse/KAFKA-10357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17179535#comment-17179535 ] Bruno Cadonna commented on KAFKA-10357: --- bq. Can we leverage the committed offsets somehow? It

[jira] [Assigned] (KAFKA-10408) Calendar based windows

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

[jira] [Created] (KAFKA-10397) Do not Expose Statistics-based RocksDB Metrics If User Provides Statistics Object

Bruno Cadonna created KAFKA-10397: - Summary: Do not Expose Statistics-based RocksDB Metrics If User Provides Statistics Object Key: KAFKA-10397 URL: https://issues.apache.org/jira/browse/KAFKA-10397

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

[ https://issues.apache.org/jira/browse/KAFKA-10357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17177007#comment-17177007 ] Bruno Cadonna commented on KAFKA-10357: --- The {{KafkaStreams#initialize()}} approach would not

[jira] [Comment Edited] (KAFKA-10396) Overall memory of container keep on growing due to kafka stream / rocksdb and OOM killed once limit reached

[ https://issues.apache.org/jira/browse/KAFKA-10396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17176892#comment-17176892 ] Bruno Cadonna edited comment on KAFKA-10396 at 8/13/20, 10:07 AM: --

[jira] [Commented] (KAFKA-10396) Overall memory of container keep on growing due to kafka stream / rocksdb and OOM killed once limit reached

[ https://issues.apache.org/jira/browse/KAFKA-10396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17176892#comment-17176892 ] Bruno Cadonna commented on KAFKA-10396: --- [~vmathapati], thank you for the report. Could you please

[jira] [Updated] (KAFKA-10396) Overall memory of container keep on growing due to kafka stream / rocksdb and OOM killed once limit reached

[ https://issues.apache.org/jira/browse/KAFKA-10396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-10396: -- Component/s: (was: KafkaConnect) > Overall memory of container keep on growing due to

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

[ https://issues.apache.org/jira/browse/KAFKA-10357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17174279#comment-17174279 ] Bruno Cadonna commented on KAFKA-10357: --- I have a couple of questions regarding wild idea 1): 1)

[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] [Commented] (KAFKA-10255) Fix flaky testOneWayReplicationWithAutorOffsetSync1 test

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

[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=17167726#comment-17167726 ] Bruno Cadonna commented on KAFKA-9013: -- https://builds.apache.org/job/kafka-pr-jdk8-scala2.12/3608

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

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

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

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

<    2   3   4   5   6   7   8   9   10   >