[jira] [Commented] (KAFKA-8326) Add List Serde

[ https://issues.apache.org/jira/browse/KAFKA-8326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16974886#comment-16974886 ] Sophie Blee-Goldman commented on KAFKA-8326: Oh sorry, I thought the code part had already

[jira] [Created] (KAFKA-9177) Pause completed partitions on restore consumer

Sophie Blee-Goldman created KAFKA-9177: -- Summary: Pause completed partitions on restore consumer Key: KAFKA-9177 URL: https://issues.apache.org/jira/browse/KAFKA-9177 Project: Kafka

[jira] [Updated] (KAFKA-9178) restoredPartitions is not cleared until the last restoring task completes

[ https://issues.apache.org/jira/browse/KAFKA-9178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9178: --- Description: We check the `active` set is empty during closeLostTasks(). However we

[jira] [Updated] (KAFKA-9178) restoredPartitions is not cleared until the last restoring task completes

[ https://issues.apache.org/jira/browse/KAFKA-9178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9178: --- Affects Version/s: 2.4.0 > restoredPartitions is not cleared until the last

[jira] [Updated] (KAFKA-9178) restoredPartitions is not cleared until the last restoring task completes

[ https://issues.apache.org/jira/browse/KAFKA-9178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9178: --- Summary: restoredPartitions is not cleared until the last restoring task completes

[jira] [Commented] (KAFKA-9148) Consider forking RocksDB for Streams

[ https://issues.apache.org/jira/browse/KAFKA-9148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16968777#comment-16968777 ] Sophie Blee-Goldman commented on KAFKA-9148: It seems to also be under the Apache license, so

[jira] [Commented] (KAFKA-9148) Consider forking RocksDB for Streams

[ https://issues.apache.org/jira/browse/KAFKA-9148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16968772#comment-16968772 ] Sophie Blee-Goldman commented on KAFKA-9148: That's an interesting idea...and we might be

[jira] [Commented] (KAFKA-9208) Flaky Test SslAdminClientIntegrationTest.testCreatePartitions

[ https://issues.apache.org/jira/browse/KAFKA-9208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16976843#comment-16976843 ] Sophie Blee-Goldman commented on KAFKA-9208: Results cleaned up already but I saw this fail

[jira] [Created] (KAFKA-9208) Flaky Test SslAdminClientIntegrationTest.testCreatePartitions

Sophie Blee-Goldman created KAFKA-9208: -- Summary: Flaky Test SslAdminClientIntegrationTest.testCreatePartitions Key: KAFKA-9208 URL: https://issues.apache.org/jira/browse/KAFKA-9208 Project:

[jira] [Commented] (KAFKA-9225) kafka fail to run on linux-aarch64

[ https://issues.apache.org/jira/browse/KAFKA-9225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16980228#comment-16980228 ] Sophie Blee-Goldman commented on KAFKA-9225: Thanks for reporting this issue, we are in fact

[jira] [Updated] (KAFKA-9225) kafka fail to run on linux-aarch64

[ https://issues.apache.org/jira/browse/KAFKA-9225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9225: --- Priority: Blocker (was: Major) > kafka fail to run on linux-aarch64 >

[jira] [Updated] (KAFKA-9225) kafka fail to run on linux-aarch64

[ https://issues.apache.org/jira/browse/KAFKA-9225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9225: --- Fix Version/s: 3.0.0 > kafka fail to run on linux-aarch64 >

[jira] [Commented] (KAFKA-9210) kafka stream loss data

[ https://issues.apache.org/jira/browse/KAFKA-9210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16986466#comment-16986466 ] Sophie Blee-Goldman commented on KAFKA-9210: Hi [~panpan.liu], it seems you might be hitting

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

[ https://issues.apache.org/jira/browse/KAFKA-9173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16986460#comment-16986460 ] Sophie Blee-Goldman commented on KAFKA-9173: I agree we should aim to fix this, but the

[jira] [Commented] (KAFKA-9088) Consolidate InternalMockProcessorContext and MockInternalProcessorContext

[ https://issues.apache.org/jira/browse/KAFKA-9088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16988149#comment-16988149 ] Sophie Blee-Goldman commented on KAFKA-9088: I'm also fine with going ahead with the EasyMock

[jira] [Commented] (KAFKA-9268) Follow-on: Streams Threads may die from recoverable errors with EOS enabled

[ https://issues.apache.org/jira/browse/KAFKA-9268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16988022#comment-16988022 ] Sophie Blee-Goldman commented on KAFKA-9268: Do you have any thoughts (or guesses) at how far

[jira] [Commented] (KAFKA-9281) Consider more flexible node grouping for Pattern subscription

[ https://issues.apache.org/jira/browse/KAFKA-9281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16990281#comment-16990281 ] Sophie Blee-Goldman commented on KAFKA-9281: Haha whoops...I was lead to believe the first

[jira] [Resolved] (KAFKA-9281) Consider more flexible node grouping for Pattern subscription

[ https://issues.apache.org/jira/browse/KAFKA-9281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman resolved KAFKA-9281. Resolution: Duplicate > Consider more flexible node grouping for Pattern

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

[ https://issues.apache.org/jira/browse/KAFKA-9173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991960#comment-16991960 ] Sophie Blee-Goldman commented on KAFKA-9173: [~mjsax] See 

[jira] [Updated] (KAFKA-9161) Close gaps in Streams configs documentation

[ https://issues.apache.org/jira/browse/KAFKA-9161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9161: --- Description: There are a number of Streams configs that aren't documented in the

[jira] [Comment Edited] (KAFKA-9161) Close gaps in Streams configs documentation

[ https://issues.apache.org/jira/browse/KAFKA-9161?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16997741#comment-16997741 ] Sophie Blee-Goldman edited comment on KAFKA-9161 at 12/17/19 12:29 AM:

[jira] [Commented] (KAFKA-9161) Close gaps in Streams configs documentation

[ https://issues.apache.org/jira/browse/KAFKA-9161?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16997741#comment-16997741 ] Sophie Blee-Goldman commented on KAFKA-9161: upgrade.from > Close gaps in Streams configs

[jira] [Updated] (KAFKA-9148) Consider forking RocksDB for Streams

[ https://issues.apache.org/jira/browse/KAFKA-9148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9148: --- Description: We recently upgraded our RocksDB dependency to 5.18 for its

[jira] [Updated] (KAFKA-8784) Remove default implementation of RocksDBConfigSetter#close

[ https://issues.apache.org/jira/browse/KAFKA-8784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8784: --- Fix Version/s: 3.0.0 > Remove default implementation of RocksDBConfigSetter#close >

[jira] [Updated] (KAFKA-8784) Remove default implementation of RocksDBConfigSetter#close

[ https://issues.apache.org/jira/browse/KAFKA-8784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8784: --- Affects Version/s: (was: 3.0.0) > Remove default implementation of

[jira] [Assigned] (KAFKA-9305) Add version 2.4 to streams system tests

[ https://issues.apache.org/jira/browse/KAFKA-9305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman reassigned KAFKA-9305: -- Assignee: Bruno Cadonna (was: Sophie Blee-Goldman) > Add version 2.4 to

[jira] [Assigned] (KAFKA-9305) Add version 2.4 to streams system tests

[ https://issues.apache.org/jira/browse/KAFKA-9305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman reassigned KAFKA-9305: -- Assignee: Sophie Blee-Goldman > Add version 2.4 to streams system tests >

[jira] [Commented] (KAFKA-9148) Consider forking RocksDB for Streams

[ https://issues.apache.org/jira/browse/KAFKA-9148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16997804#comment-16997804 ] Sophie Blee-Goldman commented on KAFKA-9148: Thanks [~adamretter]! It helps a lot to have

[jira] [Commented] (KAFKA-8948) Flaky Test StreamsEosTest#test_rebalance_complex is broken for multiple runs

[ https://issues.apache.org/jira/browse/KAFKA-8948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16987334#comment-16987334 ] Sophie Blee-Goldman commented on KAFKA-8948: Turns out this was most likely a real issue that

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

[ https://issues.apache.org/jira/browse/KAFKA-9173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16989070#comment-16989070 ] Sophie Blee-Goldman commented on KAFKA-9173: That's a good point, it does need to be

[jira] [Commented] (KAFKA-9225) kafka fail to run on linux-aarch64

[ https://issues.apache.org/jira/browse/KAFKA-9225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16989206#comment-16989206 ] Sophie Blee-Goldman commented on KAFKA-9225: At that point we might as well just [fork

[jira] [Updated] (KAFKA-9148) Consider forking RocksDB for Streams

[ https://issues.apache.org/jira/browse/KAFKA-9148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9148: --- Description: We recently upgraded our RocksDB dependency to 5.18 for its

[jira] [Updated] (KAFKA-9148) Consider forking RocksDB for Streams

[ https://issues.apache.org/jira/browse/KAFKA-9148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9148: --- Description: We recently upgraded our RocksDB dependency to 5.18 for its

[jira] [Created] (KAFKA-9281) Consider more flexible node grouping for Pattern subscription

Sophie Blee-Goldman created KAFKA-9281: -- Summary: Consider more flexible node grouping for Pattern subscription Key: KAFKA-9281 URL: https://issues.apache.org/jira/browse/KAFKA-9281 Project:

[jira] [Created] (KAFKA-9282) Consider more flexible node grouping for Pattern subscription

Sophie Blee-Goldman created KAFKA-9282: -- Summary: Consider more flexible node grouping for Pattern subscription Key: KAFKA-9282 URL: https://issues.apache.org/jira/browse/KAFKA-9282 Project:

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

[ https://issues.apache.org/jira/browse/KAFKA-9173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16990136#comment-16990136 ] Sophie Blee-Goldman commented on KAFKA-9173: [~o.muravskiy] Opened [this

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

[ https://issues.apache.org/jira/browse/KAFKA-9173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16990136#comment-16990136 ] Sophie Blee-Goldman edited comment on KAFKA-9173 at 12/6/19 8:03 PM: -

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

[ https://issues.apache.org/jira/browse/KAFKA-9173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16987410#comment-16987410 ] Sophie Blee-Goldman commented on KAFKA-9173: What exactly do you mean by "subscribed to 21

[jira] [Created] (KAFKA-9053) AssignmentInfo#encode hardcodes the LATEST_SUPPORTED_VERSION

Sophie Blee-Goldman created KAFKA-9053: -- Summary: AssignmentInfo#encode hardcodes the LATEST_SUPPORTED_VERSION Key: KAFKA-9053 URL: https://issues.apache.org/jira/browse/KAFKA-9053 Project:

[jira] [Updated] (KAFKA-9053) AssignmentInfo#encode hardcodes the LATEST_SUPPORTED_VERSION

[ https://issues.apache.org/jira/browse/KAFKA-9053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9053: --- Component/s: streams > AssignmentInfo#encode hardcodes the LATEST_SUPPORTED_VERSION

[jira] [Updated] (KAFKA-8603) Document upgrade path

[ https://issues.apache.org/jira/browse/KAFKA-8603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8603: --- Priority: Blocker (was: Major) > Document upgrade path > - > >

[jira] [Updated] (KAFKA-8603) Document upgrade path

[ https://issues.apache.org/jira/browse/KAFKA-8603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8603: --- Fix Version/s: 2.4.0 > Document upgrade path > - > >

[jira] [Updated] (KAFKA-8575) Investigate removing EAGER protocol & cleaning up task suspension in Streams rebalancing

[ https://issues.apache.org/jira/browse/KAFKA-8575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8575: --- Summary: Investigate removing EAGER protocol & cleaning up task suspension in

[jira] [Updated] (KAFKA-8575) Investigate removing EAGER & cleaning up task suspension (part 8)

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

[jira] [Updated] (KAFKA-8767) Optimize StickyAssignor for Cooperative mode

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

[jira] [Commented] (KAFKA-8767) Optimize StickyAssignor for Cooperative mode

[ https://issues.apache.org/jira/browse/KAFKA-8767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16951431#comment-16951431 ] Sophie Blee-Goldman commented on KAFKA-8767: see related: flaky test PR 

[jira] [Updated] (KAFKA-8767) Optimize StickyAssignor for Cooperative mode

[ https://issues.apache.org/jira/browse/KAFKA-8767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8767: --- Affects Version/s: 2.4.0 > Optimize StickyAssignor for Cooperative mode >

[jira] [Updated] (KAFKA-8575) Investigate removing EAGER & cleaning up task suspension (part 8)

[ https://issues.apache.org/jira/browse/KAFKA-8575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8575: --- Affects Version/s: (was: 3.0.0) 2.4.0 > Investigate

[jira] [Updated] (KAFKA-8575) Investigate removing EAGER & cleaning up task suspension (part 8)

[ https://issues.apache.org/jira/browse/KAFKA-8575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8575: --- Fix Version/s: 3.0.0 > Investigate removing EAGER & cleaning up task suspension

[jira] [Commented] (KAFKA-4969) State-store workload-aware StreamsPartitionAssignor

[ https://issues.apache.org/jira/browse/KAFKA-4969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16959306#comment-16959306 ] Sophie Blee-Goldman commented on KAFKA-4969: Bill's proposal has already been merged, so you

[jira] [Comment Edited] (KAFKA-9088) Consolidate InternalMockProcessorContext and MockInternalProcessorContext

[ https://issues.apache.org/jira/browse/KAFKA-9088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16961475#comment-16961475 ] Sophie Blee-Goldman edited comment on KAFKA-9088 at 10/28/19 9:35 PM:

[jira] [Commented] (KAFKA-9088) Consolidate InternalMockProcessorContext and MockInternalProcessorContext

[ https://issues.apache.org/jira/browse/KAFKA-9088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16961475#comment-16961475 ] Sophie Blee-Goldman commented on KAFKA-9088: Here's a thought: what if we moved the new

[jira] [Updated] (KAFKA-7271) Fix ignored test in streams_upgrade_test.py: test_upgrade_downgrade_brokers

[ https://issues.apache.org/jira/browse/KAFKA-7271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-7271: --- Priority: Blocker (was: Major) > Fix ignored test in streams_upgrade_test.py:

[jira] [Updated] (KAFKA-7271) Fix ignored test in streams_upgrade_test.py: test_upgrade_downgrade_brokers

[ https://issues.apache.org/jira/browse/KAFKA-7271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-7271: --- Fix Version/s: 2.5.0 > Fix ignored test in streams_upgrade_test.py:

[jira] [Commented] (KAFKA-7271) Fix ignored test in streams_upgrade_test.py: test_upgrade_downgrade_brokers

[ https://issues.apache.org/jira/browse/KAFKA-7271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16961373#comment-16961373 ] Sophie Blee-Goldman commented on KAFKA-7271: Reopening this as a blocker for 2.5 as we should

[jira] [Commented] (KAFKA-9088) Consolidate InternalMockProcessorContext and MockInternalProcessorContext

[ https://issues.apache.org/jira/browse/KAFKA-9088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16962360#comment-16962360 ] Sophie Blee-Goldman commented on KAFKA-9088: Whoops, thanks for pointing that out. Went back

[jira] [Assigned] (KAFKA-8630) Unit testing a streams processor with a WindowStore throws a ClassCastException

[ https://issues.apache.org/jira/browse/KAFKA-8630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman reassigned KAFKA-8630: -- Assignee: Sophie Blee-Goldman > Unit testing a streams processor with a

[jira] [Assigned] (KAFKA-8630) Unit testing a streams processor with a WindowStore throws a ClassCastException

[ https://issues.apache.org/jira/browse/KAFKA-8630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman reassigned KAFKA-8630: -- Assignee: (was: Sophie Blee-Goldman) > Unit testing a streams processor

[jira] [Comment Edited] (KAFKA-9088) Consolidate InternalMockProcessorContext and MockInternalProcessorContext

[ https://issues.apache.org/jira/browse/KAFKA-9088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16961475#comment-16961475 ] Sophie Blee-Goldman edited comment on KAFKA-9088 at 10/29/19 7:55 PM:

[jira] [Commented] (KAFKA-8630) Unit testing a streams processor with a WindowStore throws a ClassCastException

[ https://issues.apache.org/jira/browse/KAFKA-8630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16962413#comment-16962413 ] Sophie Blee-Goldman commented on KAFKA-8630: That's fair, I agree that would be the ideal

[jira] [Commented] (KAFKA-9112) Combine streams `onAssignment` with `partitionsAssigned` task creation

[ https://issues.apache.org/jira/browse/KAFKA-9112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16962498#comment-16962498 ] Sophie Blee-Goldman commented on KAFKA-9112: I agree with this ticket 100% and had the same

[jira] [Created] (KAFKA-9113) Clean up task management

Sophie Blee-Goldman created KAFKA-9113: -- Summary: Clean up task management Key: KAFKA-9113 URL: https://issues.apache.org/jira/browse/KAFKA-9113 Project: Kafka Issue Type: Improvement

[jira] [Resolved] (KAFKA-8603) Document upgrade path

[ https://issues.apache.org/jira/browse/KAFKA-8603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman resolved KAFKA-8603. Resolution: Fixed > Document upgrade path > - > >

[jira] [Commented] (KAFKA-8967) Flaky test kafka.api.SaslSslAdminClientIntegrationTest.testCreateTopicsResponseMetadataAndConfig

[ https://issues.apache.org/jira/browse/KAFKA-8967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16953379#comment-16953379 ] Sophie Blee-Goldman commented on KAFKA-8967: h3. Error Message

[jira] [Commented] (KAFKA-8059) Flaky Test DynamicConnectionQuotaTest #testDynamicConnectionQuota

[ https://issues.apache.org/jira/browse/KAFKA-8059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16953377#comment-16953377 ] Sophie Blee-Goldman commented on KAFKA-8059: h3. Error Message

[jira] [Commented] (KAFKA-4996) Fix findbugs multithreaded correctness warnings for streams

[ https://issues.apache.org/jira/browse/KAFKA-4996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16954877#comment-16954877 ] Sophie Blee-Goldman commented on KAFKA-4996: [~mjsax] I was actually looking at the spotbugs

[jira] [Commented] (KAFKA-8994) Streams should expose standby replication information & allow stale reads of state store

[ https://issues.apache.org/jira/browse/KAFKA-8994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16954962#comment-16954962 ] Sophie Blee-Goldman commented on KAFKA-8994: [~vinoth] This should be closed as a duplicate

[jira] [Commented] (KAFKA-9062) Handle stalled writes to RocksDB

[ https://issues.apache.org/jira/browse/KAFKA-9062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16954994#comment-16954994 ] Sophie Blee-Goldman commented on KAFKA-9062: I think this is challenging to solve in a

[jira] [Updated] (KAFKA-9053) AssignmentInfo#encode hardcodes the LATEST_SUPPORTED_VERSION

[ https://issues.apache.org/jira/browse/KAFKA-9053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9053: --- Fix Version/s: 2.1.2 > AssignmentInfo#encode hardcodes the LATEST_SUPPORTED_VERSION

[jira] [Created] (KAFKA-9062) RocksDB writes may stall after bulk loading lots of state

Sophie Blee-Goldman created KAFKA-9062: -- Summary: RocksDB writes may stall after bulk loading lots of state Key: KAFKA-9062 URL: https://issues.apache.org/jira/browse/KAFKA-9062 Project: Kafka

[jira] [Updated] (KAFKA-4593) Task migration during rebalance callback process could lead the obsoleted task's IllegalStateException

[ https://issues.apache.org/jira/browse/KAFKA-4593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-4593: --- Labels: (was: infrastructure) > Task migration during rebalance callback process

[jira] [Updated] (KAFKA-9062) Handle stalled writes to RocksDB

[ https://issues.apache.org/jira/browse/KAFKA-9062?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9062: --- Summary: Handle stalled writes to RocksDB (was: RocksDB writes may stall after bulk

[jira] [Commented] (KAFKA-9062) Handle stalled writes to RocksDB

[ https://issues.apache.org/jira/browse/KAFKA-9062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16957266#comment-16957266 ] Sophie Blee-Goldman commented on KAFKA-9062: My understand is that a lot of what compaction

[jira] [Reopened] (KAFKA-9208) Flaky Test SslAdminClientIntegrationTest.testCreatePartitions

[ https://issues.apache.org/jira/browse/KAFKA-9208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman reopened KAFKA-9208: Note that this test is distinct from the similar flaky test

[jira] [Commented] (KAFKA-9225) kafka fail to run on linux-aarch64

[ https://issues.apache.org/jira/browse/KAFKA-9225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16983176#comment-16983176 ] Sophie Blee-Goldman commented on KAFKA-9225: Ok that makes sense (I agree, but didn't

[jira] [Commented] (KAFKA-9225) kafka fail to run on linux-aarch64

[ https://issues.apache.org/jira/browse/KAFKA-9225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16983064#comment-16983064 ] Sophie Blee-Goldman commented on KAFKA-9225: Thanks for generating the compatibility report!

[jira] [Commented] (KAFKA-7663) Custom Processor supplied on addGlobalStore is not used when restoring state from topic

[ https://issues.apache.org/jira/browse/KAFKA-7663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16983835#comment-16983835 ] Sophie Blee-Goldman commented on KAFKA-7663: [~twbecker] Those javadocs were added _because_

[jira] [Updated] (KAFKA-9112) Combine streams `onAssignment` with `partitionsAssigned` task creation

[ https://issues.apache.org/jira/browse/KAFKA-9112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9112: --- Component/s: (was: consumer) > Combine streams `onAssignment` with

[jira] [Updated] (KAFKA-9112) Combine streams `onAssignment` with `partitionsAssigned` task creation

[ https://issues.apache.org/jira/browse/KAFKA-9112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9112: --- Component/s: consumer > Combine streams `onAssignment` with `partitionsAssigned`

[jira] [Comment Edited] (KAFKA-9112) Combine streams `onAssignment` with `partitionsAssigned` task creation

[ https://issues.apache.org/jira/browse/KAFKA-9112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16962498#comment-16962498 ] Sophie Blee-Goldman edited comment on KAFKA-9112 at 10/30/19 3:59 AM:

[jira] [Commented] (KAFKA-9112) Combine streams `onAssignment` with `partitionsAssigned` task creation

[ https://issues.apache.org/jira/browse/KAFKA-9112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16962667#comment-16962667 ] Sophie Blee-Goldman commented on KAFKA-9112: The thoughts above are obviously way beyond the

[jira] [Commented] (KAFKA-8939) Flaky test ReassignPartitionsClusterTest#shouldTriggerReassignmentWithZnodePrecedenceOnControllerStartup

[ https://issues.apache.org/jira/browse/KAFKA-8939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16962668#comment-16962668 ] Sophie Blee-Goldman commented on KAFKA-8939: h3. Stacktrace java.lang.AssertionError:

[jira] [Updated] (KAFKA-9113) Clean up task management

[ https://issues.apache.org/jira/browse/KAFKA-9113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9113: --- Component/s: streams > Clean up task management > > >

[jira] [Resolved] (KAFKA-8972) KafkaConsumer.unsubscribe could leave inconsistent user rebalance callback state

[ https://issues.apache.org/jira/browse/KAFKA-8972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman resolved KAFKA-8972. Resolution: Fixed Nice work guys! > KafkaConsumer.unsubscribe could leave

[jira] [Commented] (KAFKA-8972) Toggle bulkloading hit NPE

[ https://issues.apache.org/jira/browse/KAFKA-8972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16946262#comment-16946262 ] Sophie Blee-Goldman commented on KAFKA-8972: [~bchen225242] I've also seen this fail with a

[jira] [Updated] (KAFKA-8951) Avoid unnecessary rebalances and downtime for "safe" partitions

[ https://issues.apache.org/jira/browse/KAFKA-8951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8951: --- Affects Version/s: 2.4.0 > Avoid unnecessary rebalances and downtime for "safe"

[jira] [Updated] (KAFKA-8940) Flaky Test SmokeTestDriverIntegrationTest.shouldWorkWithRebalance

[ https://issues.apache.org/jira/browse/KAFKA-8940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8940: --- Summary: Flaky Test SmokeTestDriverIntegrationTest.shouldWorkWithRebalance (was:

[jira] [Updated] (KAFKA-8510) Update StreamsPartitionAssignor to use the built-in owned partitions to achieve stickiness (part 7)

[ https://issues.apache.org/jira/browse/KAFKA-8510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8510: --- Component/s: (was: consumer) > Update StreamsPartitionAssignor to use the

[jira] [Updated] (KAFKA-8575) Investigate removing EAGER & cleaning up task suspension (part 8)

[ https://issues.apache.org/jira/browse/KAFKA-8575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8575: --- Description: With KIP-429 the suspend/resume of tasks may have minimal gains while

[jira] [Updated] (KAFKA-8575) Investigate removing EAGER & cleaning up task suspension (part 8)

[ https://issues.apache.org/jira/browse/KAFKA-8575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8575: --- Summary: Investigate removing EAGER & cleaning up task suspension (part 8) (was:

[jira] [Updated] (KAFKA-8575) Investigate removing EAGER & cleaning up task suspension (part 8)

[ https://issues.apache.org/jira/browse/KAFKA-8575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8575: --- Affects Version/s: 3.0.0 > Investigate removing EAGER & cleaning up task suspension

[jira] [Updated] (KAFKA-8575) Investigate removing EAGER & cleaning up task suspension (part 8)

[ https://issues.apache.org/jira/browse/KAFKA-8575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8575: --- Description: With KIP-429 the suspend/resume of tasks may have minimal gains while

[jira] [Resolved] (KAFKA-8948) Flaky Test StreamsEosTest#test_rebalance_complex is broken for multiple runs

[ https://issues.apache.org/jira/browse/KAFKA-8948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman resolved KAFKA-8948. Resolution: Cannot Reproduce Not sure if this was somehow fixed as a side effect

[jira] [Assigned] (KAFKA-8742) Flaky Test RepartitionWithMergeOptimizingIntegrationTest#shouldSendCorrectResults_NO_OPTIMIZATION

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

[jira] [Assigned] (KAFKA-9020) Streams sub-topologies should be sorted by sink -> source relationship

[ https://issues.apache.org/jira/browse/KAFKA-9020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman reassigned KAFKA-9020: -- Assignee: Sophie Blee-Goldman > Streams sub-topologies should be sorted by

[jira] [Commented] (KAFKA-9000) Flaky Test KTableKTableForeignKeyJoinIntegrationTest.doLeftJoinFromRightThenDeleteRightEntity

[ https://issues.apache.org/jira/browse/KAFKA-9000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16949079#comment-16949079 ] Sophie Blee-Goldman commented on KAFKA-9000: Failed locally:  java.lang.AssertionError:

[jira] [Created] (KAFKA-9022) Flaky Test KTableKTableForeignKeyJoinIntegrationTest. doInnerJoinFilterOutRapidlyChangingForeignKeyValues

Sophie Blee-Goldman created KAFKA-9022: -- Summary: Flaky Test KTableKTableForeignKeyJoinIntegrationTest. doInnerJoinFilterOutRapidlyChangingForeignKeyValues Key: KAFKA-9022 URL:

[jira] [Created] (KAFKA-9003) Flaky Test RepartitionOptimizingIntegrationTest#shouldSendCorrectRecords_OPTIMIZED

Sophie Blee-Goldman created KAFKA-9003: -- Summary: Flaky Test RepartitionOptimizingIntegrationTest#shouldSendCorrectRecords_OPTIMIZED Key: KAFKA-9003 URL: https://issues.apache.org/jira/browse/KAFKA-9003

[jira] [Created] (KAFKA-9001) Flaky Test KStreamAggregationIntegrationTest#shouldReduceSessionWindows

Sophie Blee-Goldman created KAFKA-9001: -- Summary: Flaky Test KStreamAggregationIntegrationTest#shouldReduceSessionWindows Key: KAFKA-9001 URL: https://issues.apache.org/jira/browse/KAFKA-9001

[jira] [Commented] (KAFKA-4696) Streams standby task assignment should be state-store aware

[ https://issues.apache.org/jira/browse/KAFKA-4696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16947190#comment-16947190 ] Sophie Blee-Goldman commented on KAFKA-4696: I don't think they were actually merged, just

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