[jira] [Updated] (KAFKA-12506) Expand AdjustStreamThreadCountTest

[ https://issues.apache.org/jira/browse/KAFKA-12506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12506: --- Description: Right now the AdjustStreamThreadCountTest runs a minimal topolo

[jira] [Created] (KAFKA-12521) Expand coverage of integration tests with more realistic applications

A. Sophie Blee-Goldman created KAFKA-12521: -- Summary: Expand coverage of integration tests with more realistic applications Key: KAFKA-12521 URL: https://issues.apache.org/jira/browse/KAFKA-12521

[jira] [Updated] (KAFKA-12506) Expand AdjustStreamThreadCountTest

[ https://issues.apache.org/jira/browse/KAFKA-12506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12506: --- Parent: KAFKA-12521 Issue Type: Sub-task (was: Improvement) > Expan

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

[ https://issues.apache.org/jira/browse/KAFKA-12475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17306615#comment-17306615 ] A. Sophie Blee-Goldman commented on KAFKA-12475: Well, many remote stora

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

[ https://issues.apache.org/jira/browse/KAFKA-12519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17306571#comment-17306571 ] A. Sophie Blee-Goldman commented on KAFKA-12519: [~cadonna] Can we mark

[jira] [Commented] (KAFKA-10721) Rewrite topology to allow for overlapping unequal topic subscriptions

[ https://issues.apache.org/jira/browse/KAFKA-10721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17306567#comment-17306567 ] A. Sophie Blee-Goldman commented on KAFKA-10721: Sure thing -- I also ad

[jira] [Assigned] (KAFKA-12492) Formatting of example RocksDBConfigSetter is messed up

[ https://issues.apache.org/jira/browse/KAFKA-12492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman reassigned KAFKA-12492: -- Assignee: Ben Chen > Formatting of example RocksDBConfigSetter is mes

[jira] [Commented] (KAFKA-12492) Formatting of example RocksDBConfigSetter is messed up

[ https://issues.apache.org/jira/browse/KAFKA-12492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17305792#comment-17305792 ] A. Sophie Blee-Goldman commented on KAFKA-12492: Hey [~ben.c], I added y

[jira] [Commented] (KAFKA-12509) Tighten up StateDirectory thread locking

[ https://issues.apache.org/jira/browse/KAFKA-12509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17305590#comment-17305590 ] A. Sophie Blee-Goldman commented on KAFKA-12509: Sure thing, feel free t

[jira] [Assigned] (KAFKA-12509) Tighten up StateDirectory thread locking

[ https://issues.apache.org/jira/browse/KAFKA-12509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman reassigned KAFKA-12509: -- Assignee: Ketul Gupta > Tighten up StateDirectory thread locking > --

[jira] [Commented] (KAFKA-12472) Add a Consumer / Streams metric to indicate the current rebalance status

[ https://issues.apache.org/jira/browse/KAFKA-12472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17305217#comment-17305217 ] A. Sophie Blee-Goldman commented on KAFKA-12472: That all makes sense to

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

[ https://issues.apache.org/jira/browse/KAFKA-12475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17305191#comment-17305191 ] A. Sophie Blee-Goldman edited comment on KAFKA-12475 at 3/19/21, 8:51 PM:

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

[ https://issues.apache.org/jira/browse/KAFKA-12475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17305191#comment-17305191 ] A. Sophie Blee-Goldman commented on KAFKA-12475: An alternative is to ju

[jira] [Updated] (KAFKA-12288) Remove task-level filesystem locks

[ https://issues.apache.org/jira/browse/KAFKA-12288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12288: --- Fix Version/s: 2.8.1 2.7.2 2.6.3 > Rem

[jira] [Updated] (KAFKA-12288) Remove task-level filesystem locks

[ https://issues.apache.org/jira/browse/KAFKA-12288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12288: --- Fix Version/s: (was: 2.6.3) > Remove task-level filesystem locks > -

[jira] [Updated] (KAFKA-12288) Remove task-level filesystem locks

[ https://issues.apache.org/jira/browse/KAFKA-12288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12288: --- Fix Version/s: (was: 2.7.2) (was: 2.8.0)

[jira] [Updated] (KAFKA-12509) Tighten up StateDirectory thread locking

[ https://issues.apache.org/jira/browse/KAFKA-12509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12509: --- Labels: newbie (was: ) > Tighten up StateDirectory thread locking > ---

[jira] [Created] (KAFKA-12509) Tighten up StateDirectory thread locking

A. Sophie Blee-Goldman created KAFKA-12509: -- Summary: Tighten up StateDirectory thread locking Key: KAFKA-12509 URL: https://issues.apache.org/jira/browse/KAFKA-12509 Project: Kafka

[jira] [Commented] (KAFKA-10563) Make sure task directories don't remain locked by dead threads

[ https://issues.apache.org/jira/browse/KAFKA-10563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17304637#comment-17304637 ] A. Sophie Blee-Goldman commented on KAFKA-10563: I partially addressed t

[jira] [Resolved] (KAFKA-12503) Resizing the thread cache in a non thread safe way can cause records to be redirected throughout the topology

[ https://issues.apache.org/jira/browse/KAFKA-12503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman resolved KAFKA-12503. Resolution: Fixed > Resizing the thread cache in a non thread safe way can

[jira] [Commented] (KAFKA-12506) Expand AdjustStreamThreadCountTest

[ https://issues.apache.org/jira/browse/KAFKA-12506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17304551#comment-17304551 ] A. Sophie Blee-Goldman commented on KAFKA-12506: cc [~wcarlson5] -- the

[jira] [Updated] (KAFKA-12506) Expand AdjustStreamThreadCountTest

[ https://issues.apache.org/jira/browse/KAFKA-12506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12506: --- Description: Right now the AdjustStreamThreadCountTest runs a minimal topolo

[jira] [Created] (KAFKA-12506) Expand AdjustStreamThreadCountTest

A. Sophie Blee-Goldman created KAFKA-12506: -- Summary: Expand AdjustStreamThreadCountTest Key: KAFKA-12506 URL: https://issues.apache.org/jira/browse/KAFKA-12506 Project: Kafka Issue

[jira] [Updated] (KAFKA-12506) Expand AdjustStreamThreadCountTest

[ https://issues.apache.org/jira/browse/KAFKA-12506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12506: --- Labels: newbie newbie++ (was: ) > Expand AdjustStreamThreadCountTest >

[jira] [Commented] (KAFKA-12499) Adjust transaction timeout according to commit interval on Streams EOS

[ https://issues.apache.org/jira/browse/KAFKA-12499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17304537#comment-17304537 ] A. Sophie Blee-Goldman commented on KAFKA-12499: Nice catch, but just wo

[jira] [Updated] (KAFKA-10563) Make sure task directories don't remain locked by dead threads

[ https://issues.apache.org/jira/browse/KAFKA-10563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-10563: --- Fix Version/s: (was: 2.8.0) > Make sure task directories don't remain lo

[jira] [Assigned] (KAFKA-12503) Resizing the thread cache in a non thread safe way can cause records to be redirected throughout the topology

[ https://issues.apache.org/jira/browse/KAFKA-12503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman reassigned KAFKA-12503: -- Assignee: Walker Carlson > Resizing the thread cache in a non thread

[jira] [Commented] (KAFKA-12503) Resizing the thread cache in a non thread safe way can cause records to be redirected throughout the topology

[ https://issues.apache.org/jira/browse/KAFKA-12503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17304518#comment-17304518 ] A. Sophie Blee-Goldman commented on KAFKA-12503: Thanks for the writeup!

[jira] [Commented] (KAFKA-12463) Update default consumer partition assignor for sink tasks

[ https://issues.apache.org/jira/browse/KAFKA-12463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17304452#comment-17304452 ] A. Sophie Blee-Goldman commented on KAFKA-12463: Out of curiosity, why u

[jira] [Assigned] (KAFKA-12500) Cache memory is leaked after removing/replacing a StreamThread

[ https://issues.apache.org/jira/browse/KAFKA-12500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman reassigned KAFKA-12500: -- Assignee: A. Sophie Blee-Goldman > Cache memory is leaked after remov

[jira] [Created] (KAFKA-12500) Cache memory is leaked after removing/replacing a StreamThread

A. Sophie Blee-Goldman created KAFKA-12500: -- Summary: Cache memory is leaked after removing/replacing a StreamThread Key: KAFKA-12500 URL: https://issues.apache.org/jira/browse/KAFKA-12500 Pr

[jira] [Commented] (KAFKA-12313) Consider deprecating the default.windowed.serde.inner.class configs

[ https://issues.apache.org/jira/browse/KAFKA-12313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17303862#comment-17303862 ] A. Sophie Blee-Goldman commented on KAFKA-12313: Yep, that all looks goo

[jira] [Commented] (KAFKA-12486) Utilize HighAvailabilityTaskAssignor to avoid downtime on corrupted task

[ https://issues.apache.org/jira/browse/KAFKA-12486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17303793#comment-17303793 ] A. Sophie Blee-Goldman commented on KAFKA-12486: Ideally we would only k

[jira] [Updated] (KAFKA-12486) Utilize HighAvailabilityTaskAssignor to avoid downtime on corrupted task

[ https://issues.apache.org/jira/browse/KAFKA-12486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12486: --- Description: In KIP-441, we added the HighAvailabilityTaskAssignor to addres

[jira] [Assigned] (KAFKA-12477) Smart rebalancing with dynamic protocol selection

[ https://issues.apache.org/jira/browse/KAFKA-12477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman reassigned KAFKA-12477: -- Assignee: A. Sophie Blee-Goldman > Smart rebalancing with dynamic pro

[jira] [Updated] (KAFKA-12288) Remove task-level filesystem locks

[ https://issues.apache.org/jira/browse/KAFKA-12288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12288: --- Fix Version/s: 2.6.3 2.7.1 2.8.0 > Rem

[jira] [Created] (KAFKA-12492) Formatting of example RocksDBConfigSetter is messed up

A. Sophie Blee-Goldman created KAFKA-12492: -- Summary: Formatting of example RocksDBConfigSetter is messed up Key: KAFKA-12492 URL: https://issues.apache.org/jira/browse/KAFKA-12492 Project: Ka

[jira] [Assigned] (KAFKA-12491) RocksDB not being pulled in as a transitive dependency

[ https://issues.apache.org/jira/browse/KAFKA-12491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman reassigned KAFKA-12491: -- Assignee: Ismael Juma > RocksDB not being pulled in as a transitive d

[jira] [Updated] (KAFKA-12491) RocksDB not being pulled in as a transitive dependency

[ https://issues.apache.org/jira/browse/KAFKA-12491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12491: --- Description: In [pull/10203|https://github.com/apache/kafka/pull/10203] we s

[jira] [Created] (KAFKA-12491) RocksDB not being pulled in as a transitive dependency

A. Sophie Blee-Goldman created KAFKA-12491: -- Summary: RocksDB not being pulled in as a transitive dependency Key: KAFKA-12491 URL: https://issues.apache.org/jira/browse/KAFKA-12491 Project: Ka

[jira] [Updated] (KAFKA-12464) Enhance constrained sticky Assign algorithm

[ https://issues.apache.org/jira/browse/KAFKA-12464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12464: --- Component/s: (was: streams) consumer > Enhance constrai

[jira] [Commented] (KAFKA-12313) Consider deprecating the default.windowed.serde.inner.class configs

[ https://issues.apache.org/jira/browse/KAFKA-12313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17303608#comment-17303608 ] A. Sophie Blee-Goldman commented on KAFKA-12313: > Having said that, the

[jira] [Assigned] (KAFKA-12446) Define KGroupedTable#aggregate subtractor + adder order of execution

[ https://issues.apache.org/jira/browse/KAFKA-12446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman reassigned KAFKA-12446: -- Assignee: Ben Ellis > Define KGroupedTable#aggregate subtractor + add

[jira] [Commented] (KAFKA-12446) Define KGroupedTable#aggregate subtractor + adder order of execution

[ https://issues.apache.org/jira/browse/KAFKA-12446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17303577#comment-17303577 ] A. Sophie Blee-Goldman commented on KAFKA-12446: Yeah, I don't think thi

[jira] [Comment Edited] (KAFKA-12485) Speed up Consumer#committed by returning cached offsets for owned partitions

[ https://issues.apache.org/jira/browse/KAFKA-12485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17302980#comment-17302980 ] A. Sophie Blee-Goldman edited comment on KAFKA-12485 at 3/17/21, 12:04 AM: ---

[jira] [Comment Edited] (KAFKA-12485) Speed up Consumer#committed by returning cached offsets for owned partitions

[ https://issues.apache.org/jira/browse/KAFKA-12485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17302980#comment-17302980 ] A. Sophie Blee-Goldman edited comment on KAFKA-12485 at 3/17/21, 12:03 AM: ---

[jira] [Comment Edited] (KAFKA-12485) Speed up Consumer#committed by returning cached offsets for owned partitions

[ https://issues.apache.org/jira/browse/KAFKA-12485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17302980#comment-17302980 ] A. Sophie Blee-Goldman edited comment on KAFKA-12485 at 3/17/21, 12:03 AM: ---

[jira] [Commented] (KAFKA-12485) Speed up Consumer#committed by returning cached offsets for owned partitions

[ https://issues.apache.org/jira/browse/KAFKA-12485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17302980#comment-17302980 ] A. Sophie Blee-Goldman commented on KAFKA-12485: Side note: if we get th

[jira] [Updated] (KAFKA-12485) Speed up Consumer#committed by returning cached offsets for owned partitions

[ https://issues.apache.org/jira/browse/KAFKA-12485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12485: --- Description: All of the KafkaConsumer#committed APIs will currently make a r

[jira] [Commented] (KAFKA-12472) Add a Consumer / Streams metric to indicate the current rebalance status

[ https://issues.apache.org/jira/browse/KAFKA-12472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17302952#comment-17302952 ] A. Sophie Blee-Goldman commented on KAFKA-12472: By the way, I just file

[jira] [Updated] (KAFKA-12486) Utilize HighAvailabilityTaskAssignor to avoid downtime on corrupted task

[ https://issues.apache.org/jira/browse/KAFKA-12486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12486: --- Priority: Critical (was: Major) > Utilize HighAvailabilityTaskAssignor to a

[jira] [Created] (KAFKA-12486) Utilize HighAvailabilityTaskAssignor to avoid downtime on corrupted task

A. Sophie Blee-Goldman created KAFKA-12486: -- Summary: Utilize HighAvailabilityTaskAssignor to avoid downtime on corrupted task Key: KAFKA-12486 URL: https://issues.apache.org/jira/browse/KAFKA-12486

[jira] [Commented] (KAFKA-12472) Add a Consumer / Streams metric to indicate the current rebalance status

[ https://issues.apache.org/jira/browse/KAFKA-12472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17302889#comment-17302889 ] A. Sophie Blee-Goldman commented on KAFKA-12472: {quote} illegal generat

[jira] [Updated] (KAFKA-12485) Speed up Consumer#committed by returning cached offsets for owned partitions

[ https://issues.apache.org/jira/browse/KAFKA-12485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12485: --- Labels: newbie++ (was: ) > Speed up Consumer#committed by returning cached

[jira] [Created] (KAFKA-12485) Speed up Consumer#committed by returning cached offsets for owned partitions

A. Sophie Blee-Goldman created KAFKA-12485: -- Summary: Speed up Consumer#committed by returning cached offsets for owned partitions Key: KAFKA-12485 URL: https://issues.apache.org/jira/browse/KAFKA-12485

[jira] [Commented] (KAFKA-12477) Smart rebalancing with dynamic protocol selection

[ https://issues.apache.org/jira/browse/KAFKA-12477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17302833#comment-17302833 ] A. Sophie Blee-Goldman commented on KAFKA-12477: Yes, I totally agree –

[jira] [Commented] (KAFKA-12477) Smart rebalancing with dynamic protocol selection

[ https://issues.apache.org/jira/browse/KAFKA-12477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17302226#comment-17302226 ] A. Sophie Blee-Goldman commented on KAFKA-12477: [~guozhang] any thought

[jira] [Commented] (KAFKA-12463) Update default consumer partition assignor for sink tasks

[ https://issues.apache.org/jira/browse/KAFKA-12463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17302225#comment-17302225 ] A. Sophie Blee-Goldman commented on KAFKA-12463: Filed https://issues.ap

[jira] [Created] (KAFKA-12477) Smart rebalancing with dynamic protocol selection

A. Sophie Blee-Goldman created KAFKA-12477: -- Summary: Smart rebalancing with dynamic protocol selection Key: KAFKA-12477 URL: https://issues.apache.org/jira/browse/KAFKA-12477 Project: Kafka

[jira] [Commented] (KAFKA-12463) Update default consumer partition assignor for sink tasks

[ https://issues.apache.org/jira/browse/KAFKA-12463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17302202#comment-17302202 ] A. Sophie Blee-Goldman commented on KAFKA-12463: Maybe we could improve

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

[ https://issues.apache.org/jira/browse/KAFKA-12475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17302200#comment-17302200 ] A. Sophie Blee-Goldman edited comment on KAFKA-12475 at 3/16/21, 3:37 AM:

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

[ https://issues.apache.org/jira/browse/KAFKA-12475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17302200#comment-17302200 ] A. Sophie Blee-Goldman commented on KAFKA-12475: One option to fix this

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

A. Sophie Blee-Goldman created KAFKA-12475: -- Summary: Kafka Streams breaks EOS with remote state stores Key: KAFKA-12475 URL: https://issues.apache.org/jira/browse/KAFKA-12475 Project: Kafka

[jira] [Commented] (KAFKA-12463) Update default consumer partition assignor for sink tasks

[ https://issues.apache.org/jira/browse/KAFKA-12463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17302192#comment-17302192 ] A. Sophie Blee-Goldman commented on KAFKA-12463: I think it still has th

[jira] [Updated] (KAFKA-12473) Make the CooperativeStickyAssignor the default assignor

[ https://issues.apache.org/jira/browse/KAFKA-12473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12473: --- Description: Now that 3.0 is coming up, we can change the default ConsumerPa

[jira] [Assigned] (KAFKA-12473) Make the CooperativeStickyAssignor the default assignor

[ https://issues.apache.org/jira/browse/KAFKA-12473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman reassigned KAFKA-12473: -- Assignee: Luke Chen > Make the CooperativeStickyAssignor the default

[jira] [Commented] (KAFKA-12473) Make the CooperativeStickyAssignor the default assignor

[ https://issues.apache.org/jira/browse/KAFKA-12473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17302190#comment-17302190 ] A. Sophie Blee-Goldman commented on KAFKA-12473: Yeah, I believe this wi

[jira] [Updated] (KAFKA-12473) Make the CooperativeStickyAssignor the default assignor

[ https://issues.apache.org/jira/browse/KAFKA-12473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12473: --- Labels: needs-kip (was: ) > Make the CooperativeStickyAssignor the default

[jira] [Comment Edited] (KAFKA-12463) Update default consumer partition assignor for sink tasks

[ https://issues.apache.org/jira/browse/KAFKA-12463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17302179#comment-17302179 ] A. Sophie Blee-Goldman edited comment on KAFKA-12463 at 3/16/21, 3:09 AM:

[jira] [Commented] (KAFKA-12283) Flaky Test RebalanceSourceConnectorsIntegrationTest#testMultipleWorkersRejoining

[ https://issues.apache.org/jira/browse/KAFKA-12283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17302184#comment-17302184 ] A. Sophie Blee-Goldman commented on KAFKA-12283: https://ci-builds.apach

[jira] [Commented] (KAFKA-12463) Update default consumer partition assignor for sink tasks

[ https://issues.apache.org/jira/browse/KAFKA-12463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17302183#comment-17302183 ] A. Sophie Blee-Goldman commented on KAFKA-12463: Now I don't know if Con

[jira] [Commented] (KAFKA-12463) Update default consumer partition assignor for sink tasks

[ https://issues.apache.org/jira/browse/KAFKA-12463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17302179#comment-17302179 ] A. Sophie Blee-Goldman commented on KAFKA-12463: Wait, no, I double chec

[jira] [Comment Edited] (KAFKA-12463) Update default consumer partition assignor for sink tasks

[ https://issues.apache.org/jira/browse/KAFKA-12463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17302167#comment-17302167 ] A. Sophie Blee-Goldman edited comment on KAFKA-12463 at 3/16/21, 2:51 AM:

[jira] [Commented] (KAFKA-12463) Update default consumer partition assignor for sink tasks

[ https://issues.apache.org/jira/browse/KAFKA-12463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17302167#comment-17302167 ] A. Sophie Blee-Goldman commented on KAFKA-12463: Isn't the upgrade path

[jira] [Created] (KAFKA-12473) Make the CooperativeStickyAssignor the default assignor

A. Sophie Blee-Goldman created KAFKA-12473: -- Summary: Make the CooperativeStickyAssignor the default assignor Key: KAFKA-12473 URL: https://issues.apache.org/jira/browse/KAFKA-12473 Project: K

[jira] [Commented] (KAFKA-12472) Add a Consumer / Streams metric to indicate the current rebalance status

[ https://issues.apache.org/jira/browse/KAFKA-12472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17302155#comment-17302155 ] A. Sophie Blee-Goldman commented on KAFKA-12472: This sounds like a grea

[jira] [Commented] (KAFKA-12453) Guidance on whether a topology is eligible for optimisation

[ https://issues.apache.org/jira/browse/KAFKA-12453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17302087#comment-17302087 ] A. Sophie Blee-Goldman commented on KAFKA-12453: [~mjsax] I thought we d

[jira] [Commented] (KAFKA-12313) Consider deprecating the default.windowed.serde.inner.class configs

[ https://issues.apache.org/jira/browse/KAFKA-12313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17301917#comment-17301917 ] A. Sophie Blee-Goldman commented on KAFKA-12313: Ah, I didn't notice (or

[jira] [Commented] (KAFKA-12464) Enhance constrained sticky Assign algorithm

[ https://issues.apache.org/jira/browse/KAFKA-12464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17301824#comment-17301824 ] A. Sophie Blee-Goldman commented on KAFKA-12464: Thanks for the proposal

[jira] [Commented] (KAFKA-12463) Update default consumer partition assignor for sink tasks

[ https://issues.apache.org/jira/browse/KAFKA-12463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17301321#comment-17301321 ] A. Sophie Blee-Goldman commented on KAFKA-12463: [~ChrisEgerton] just fy

[jira] [Commented] (KAFKA-12462) Threads in PENDING_SHUTDOWN entering a rebalance can cause an illegal state exception

[ https://issues.apache.org/jira/browse/KAFKA-12462?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17300654#comment-17300654 ] A. Sophie Blee-Goldman commented on KAFKA-12462: The only real downside

[jira] [Assigned] (KAFKA-12462) Threads in PENDING_SHUTDOWN entering a rebalance can cause an illegal state exception

[ https://issues.apache.org/jira/browse/KAFKA-12462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman reassigned KAFKA-12462: -- Assignee: A. Sophie Blee-Goldman > Threads in PENDING_SHUTDOWN enteri

[jira] [Commented] (KAFKA-12462) Threads in PENDING_SHUTDOWN entering a rebalance can cause an illegal state exception

[ https://issues.apache.org/jira/browse/KAFKA-12462?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17300650#comment-17300650 ] A. Sophie Blee-Goldman commented on KAFKA-12462: Thanks Walker! This act

[jira] [Commented] (KAFKA-12446) Define KGroupedTable#aggregate subtractor + adder order of execution

[ https://issues.apache.org/jira/browse/KAFKA-12446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17299226#comment-17299226 ] A. Sophie Blee-Goldman commented on KAFKA-12446: Thanks for the ticket!

[jira] [Commented] (KAFKA-12313) Consider deprecating the default.windowed.serde.inner.class configs

[ https://issues.apache.org/jira/browse/KAFKA-12313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17297818#comment-17297818 ] A. Sophie Blee-Goldman commented on KAFKA-12313: By the way, even though

[jira] [Commented] (KAFKA-12313) Consider deprecating the default.windowed.serde.inner.class configs

[ https://issues.apache.org/jira/browse/KAFKA-12313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17297816#comment-17297816 ] A. Sophie Blee-Goldman commented on KAFKA-12313: Sure, feel free to kick

[jira] [Resolved] (KAFKA-12409) Leaking gauge in ReplicaManager

[ https://issues.apache.org/jira/browse/KAFKA-12409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman resolved KAFKA-12409. Resolution: Fixed > Leaking gauge in ReplicaManager >

[jira] [Updated] (KAFKA-12409) Leaking gauge in ReplicaManager

[ https://issues.apache.org/jira/browse/KAFKA-12409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12409: --- Fix Version/s: 2.6.2 2.7.1 3.0.0 > Lea

[jira] [Comment Edited] (KAFKA-10340) Source connectors should report error when trying to produce records to non-existent topics instead of hanging forever

[ https://issues.apache.org/jira/browse/KAFKA-10340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17294278#comment-17294278 ] A. Sophie Blee-Goldman edited comment on KAFKA-10340 at 3/3/21, 4:58 AM: -

[jira] [Commented] (KAFKA-10340) Source connectors should report error when trying to produce records to non-existent topics instead of hanging forever

[ https://issues.apache.org/jira/browse/KAFKA-10340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17294278#comment-17294278 ] A. Sophie Blee-Goldman commented on KAFKA-10340: Temporarily removed 2.6

[jira] [Updated] (KAFKA-10340) Source connectors should report error when trying to produce records to non-existent topics instead of hanging forever

[ https://issues.apache.org/jira/browse/KAFKA-10340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-10340: --- Fix Version/s: (was: 2.6.2) > Source connectors should report error when

[jira] [Reopened] (KAFKA-10251) Flaky Test kafka.api.TransactionsBounceTest.testWithGroupMetadata

[ https://issues.apache.org/jira/browse/KAFKA-10251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman reopened KAFKA-10251: Looks like it's still failing – saw at least one test failure on a build which

[jira] [Commented] (KAFKA-10251) Flaky Test kafka.api.TransactionsBounceTest.testWithGroupMetadata

[ https://issues.apache.org/jira/browse/KAFKA-10251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17293953#comment-17293953 ] A. Sophie Blee-Goldman commented on KAFKA-10251: Merged [https://github.

[jira] [Commented] (KAFKA-9880) Error while range compacting during bulk loading of FIFO compacted RocksDB Store

[ https://issues.apache.org/jira/browse/KAFKA-9880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17291899#comment-17291899 ] A. Sophie Blee-Goldman commented on KAFKA-9880: --- Since we turned off bulk l

[jira] [Resolved] (KAFKA-9880) Error while range compacting during bulk loading of FIFO compacted RocksDB Store

[ https://issues.apache.org/jira/browse/KAFKA-9880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman resolved KAFKA-9880. --- Fix Version/s: 2.6.0 Resolution: Fixed > Error while range compacting

[jira] [Commented] (KAFKA-12375) ReplaceStreamThread creates a new consumer with the same name as the one it's replacing

[ https://issues.apache.org/jira/browse/KAFKA-12375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17291753#comment-17291753 ] A. Sophie Blee-Goldman commented on KAFKA-12375: My primary motivation f

[jira] [Comment Edited] (KAFKA-12375) ReplaceStreamThread creates a new consumer with the same name as the one it's replacing

[ https://issues.apache.org/jira/browse/KAFKA-12375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17291354#comment-17291354 ] A. Sophie Blee-Goldman edited comment on KAFKA-12375 at 2/26/21, 3:11 AM:

[jira] [Commented] (KAFKA-12375) ReplaceStreamThread creates a new consumer with the same name as the one it's replacing

[ https://issues.apache.org/jira/browse/KAFKA-12375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17291354#comment-17291354 ] A. Sophie Blee-Goldman commented on KAFKA-12375: Just to keep everyone u

[jira] [Comment Edited] (KAFKA-12375) ReplaceStreamThread creates a new consumer with the same name as the one it's replacing

[ https://issues.apache.org/jira/browse/KAFKA-12375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17291333#comment-17291333 ] A. Sophie Blee-Goldman edited comment on KAFKA-12375 at 2/26/21, 1:36 AM:

[jira] [Commented] (KAFKA-12375) ReplaceStreamThread creates a new consumer with the same name as the one it's replacing

[ https://issues.apache.org/jira/browse/KAFKA-12375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17291333#comment-17291333 ] A. Sophie Blee-Goldman commented on KAFKA-12375: The reason this is a pr

<    4   5   6   7   8   9   10   11   >