[jira] [Created] (KAFKA-8184) Update IQ docs to include session stores

2019-04-02 Thread Sophie Blee-Goldman (JIRA)
Sophie Blee-Goldman created KAFKA-8184: -- Summary: Update IQ docs to include session stores Key: KAFKA-8184 URL: https://issues.apache.org/jira/browse/KAFKA-8184 Project: Kafka Issue

[jira] [Created] (KAFKA-8174) Can't call arbitrary SimpleBenchmarks tests from streams_simple_benchmark_test.py

2019-03-28 Thread Sophie Blee-Goldman (JIRA)
Sophie Blee-Goldman created KAFKA-8174: -- Summary: Can't call arbitrary SimpleBenchmarks tests from streams_simple_benchmark_test.py Key: KAFKA-8174 URL: https://issues.apache.org/jira/browse/KAFKA-8174

[jira] [Created] (KAFKA-8159) Multi-key range queries with negative keyFrom results in unexpected behavior

2019-03-26 Thread Sophie Blee-Goldman (JIRA)
Sophie Blee-Goldman created KAFKA-8159: -- Summary: Multi-key range queries with negative keyFrom results in unexpected behavior Key: KAFKA-8159 URL: https://issues.apache.org/jira/browse/KAFKA-8159

[jira] [Resolved] (KAFKA-7918) Streams store cleanup: inline byte-store generic parameters

2019-03-01 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman resolved KAFKA-7918. Resolution: Fixed > Streams store cleanup: inline byte-store generic parameters >

[jira] [Resolved] (KAFKA-7912) In-memory key-value store does not support concurrent access

2019-03-01 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman resolved KAFKA-7912. Resolution: Fixed > In-memory key-value store does not support concurrent access

[jira] [Created] (KAFKA-7963) Extract hard-coded strings to centralized place

2019-02-20 Thread Sophie Blee-Goldman (JIRA)
Sophie Blee-Goldman created KAFKA-7963: -- Summary: Extract hard-coded strings to centralized place Key: KAFKA-7963 URL: https://issues.apache.org/jira/browse/KAFKA-7963 Project: Kafka

[jira] [Created] (KAFKA-8007) In-memory window store copies on fetch

2019-02-26 Thread Sophie Blee-Goldman (JIRA)
Sophie Blee-Goldman created KAFKA-8007: -- Summary: In-memory window store copies on fetch Key: KAFKA-8007 URL: https://issues.apache.org/jira/browse/KAFKA-8007 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-7929) RocksDB Window Store allows segments to expire out from under iterator

2019-02-13 Thread Sophie Blee-Goldman (JIRA)
Sophie Blee-Goldman created KAFKA-7929: -- Summary: RocksDB Window Store allows segments to expire out from under iterator Key: KAFKA-7929 URL: https://issues.apache.org/jira/browse/KAFKA-7929

[jira] [Created] (KAFKA-7912) In-memory key-value store does not support concurrent access

2019-02-08 Thread Sophie Blee-Goldman (JIRA)
Sophie Blee-Goldman created KAFKA-7912: -- Summary: In-memory key-value store does not support concurrent access Key: KAFKA-7912 URL: https://issues.apache.org/jira/browse/KAFKA-7912 Project:

[jira] [Created] (KAFKA-8215) Limit memory usage of RocksDB

2019-04-10 Thread Sophie Blee-Goldman (JIRA)
Sophie Blee-Goldman created KAFKA-8215: -- Summary: Limit memory usage of RocksDB Key: KAFKA-8215 URL: https://issues.apache.org/jira/browse/KAFKA-8215 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-8094) Iterating over cache with get(key) is inefficient

2019-03-11 Thread Sophie Blee-Goldman (JIRA)
Sophie Blee-Goldman created KAFKA-8094: -- Summary: Iterating over cache with get(key) is inefficient Key: KAFKA-8094 URL: https://issues.apache.org/jira/browse/KAFKA-8094 Project: Kafka

[jira] [Created] (KAFKA-8372) Remove deprecated RocksDB#compactRange API

2019-05-15 Thread Sophie Blee-Goldman (JIRA)
Sophie Blee-Goldman created KAFKA-8372: -- Summary: Remove deprecated RocksDB#compactRange API Key: KAFKA-8372 URL: https://issues.apache.org/jira/browse/KAFKA-8372 Project: Kafka Issue

[jira] [Resolved] (KAFKA-8215) Limit memory usage of RocksDB

2019-05-17 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman resolved KAFKA-8215. Resolution: Fixed > Limit memory usage of RocksDB > -

[jira] [Resolved] (KAFKA-8491) Bump up Consumer Protocol to v2 (part 1)

2019-06-18 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman resolved KAFKA-8491. Resolution: Fixed > Bump up Consumer Protocol to v2 (part 1) >

[jira] [Created] (KAFKA-8575) Investigate cleaning up task suspension

2019-06-20 Thread Sophie Blee-Goldman (JIRA)
Sophie Blee-Goldman created KAFKA-8575: -- Summary: Investigate cleaning up task suspension Key: KAFKA-8575 URL: https://issues.apache.org/jira/browse/KAFKA-8575 Project: Kafka Issue

[jira] [Created] (KAFKA-8347) Choose next record to process by timestamp

2019-05-09 Thread Sophie Blee-Goldman (JIRA)
Sophie Blee-Goldman created KAFKA-8347: -- Summary: Choose next record to process by timestamp Key: KAFKA-8347 URL: https://issues.apache.org/jira/browse/KAFKA-8347 Project: Kafka Issue

[jira] [Created] (KAFKA-8323) Memory leak of BloomFilter Rocks object

2019-05-03 Thread Sophie Blee-Goldman (JIRA)
Sophie Blee-Goldman created KAFKA-8323: -- Summary: Memory leak of BloomFilter Rocks object Key: KAFKA-8323 URL: https://issues.apache.org/jira/browse/KAFKA-8323 Project: Kafka Issue

[jira] [Created] (KAFKA-8324) User constructed RocksObjects leak memory

2019-05-03 Thread Sophie Blee-Goldman (JIRA)
Sophie Blee-Goldman created KAFKA-8324: -- Summary: User constructed RocksObjects leak memory Key: KAFKA-8324 URL: https://issues.apache.org/jira/browse/KAFKA-8324 Project: Kafka Issue

[jira] [Created] (KAFKA-8295) Optimize count() using RocksDB merge operator

2019-04-26 Thread Sophie Blee-Goldman (JIRA)
Sophie Blee-Goldman created KAFKA-8295: -- Summary: Optimize count() using RocksDB merge operator Key: KAFKA-8295 URL: https://issues.apache.org/jira/browse/KAFKA-8295 Project: Kafka

[jira] [Created] (KAFKA-8609) Add consumer metrics for rebalances

2019-06-27 Thread Sophie Blee-Goldman (JIRA)
Sophie Blee-Goldman created KAFKA-8609: -- Summary: Add consumer metrics for rebalances Key: KAFKA-8609 URL: https://issues.apache.org/jira/browse/KAFKA-8609 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-8627) Investigate batching on state restore

2019-07-03 Thread Sophie Blee-Goldman (JIRA)
Sophie Blee-Goldman created KAFKA-8627: -- Summary: Investigate batching on state restore Key: KAFKA-8627 URL: https://issues.apache.org/jira/browse/KAFKA-8627 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-8637) WriteBatch objects leak off-heap memory

2019-07-08 Thread Sophie Blee-Goldman (JIRA)
Sophie Blee-Goldman created KAFKA-8637: -- Summary: WriteBatch objects leak off-heap memory Key: KAFKA-8637 URL: https://issues.apache.org/jira/browse/KAFKA-8637 Project: Kafka Issue

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

2019-06-25 Thread Sophie Blee-Goldman (JIRA)
Sophie Blee-Goldman created KAFKA-8603: -- Summary: Document upgrade path Key: KAFKA-8603 URL: https://issues.apache.org/jira/browse/KAFKA-8603 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-8807) Flaky Test GlobalThreadShutDownOrderTest.shouldFinishGlobalStoreOperationOnShutDown

2019-08-15 Thread Sophie Blee-Goldman (JIRA)
Sophie Blee-Goldman created KAFKA-8807: -- Summary: Flaky Test GlobalThreadShutDownOrderTest.shouldFinishGlobalStoreOperationOnShutDown Key: KAFKA-8807 URL: https://issues.apache.org/jira/browse/KAFKA-8807

[jira] [Reopened] (KAFKA-7912) In-memory key-value store does not support concurrent access

2019-08-14 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman reopened KAFKA-7912: The fix for this caused a performance regression and is being rolled back. We should

[jira] [Created] (KAFKA-8802) ConcurrentSkipListMap shows performance regression in cache and in-memory store

2019-08-14 Thread Sophie Blee-Goldman (JIRA)
Sophie Blee-Goldman created KAFKA-8802: -- Summary: ConcurrentSkipListMap shows performance regression in cache and in-memory store Key: KAFKA-8802 URL: https://issues.apache.org/jira/browse/KAFKA-8802

[jira] [Resolved] (KAFKA-8494) Refactor Consumer#StickyAssignor and add CooperativeStickyAssignor (part 4)

2019-08-27 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman resolved KAFKA-8494. Resolution: Fixed > Refactor Consumer#StickyAssignor and add

[jira] [Created] (KAFKA-8902) Benchmark cooperative vs eager rebalancing

2019-09-12 Thread Sophie Blee-Goldman (Jira)
Sophie Blee-Goldman created KAFKA-8902: -- Summary: Benchmark cooperative vs eager rebalancing Key: KAFKA-8902 URL: https://issues.apache.org/jira/browse/KAFKA-8902 Project: Kafka Issue

[jira] [Created] (KAFKA-8734) Remove PartitionAssignorAdapter and deprecated PartitionAssignor interface

2019-07-30 Thread Sophie Blee-Goldman (JIRA)
Sophie Blee-Goldman created KAFKA-8734: -- Summary: Remove PartitionAssignorAdapter and deprecated PartitionAssignor interface Key: KAFKA-8734 URL: https://issues.apache.org/jira/browse/KAFKA-8734

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

2019-08-07 Thread Sophie Blee-Goldman (JIRA)
Sophie Blee-Goldman created KAFKA-8767: -- Summary: Optimize StickyAssignor for Cooperative mode Key: KAFKA-8767 URL: https://issues.apache.org/jira/browse/KAFKA-8767 Project: Kafka Issue

[jira] [Created] (KAFKA-8761) Flaky Test AdminClientIntegrationTest.testIncrementalAlterConfigsForLog4jLogLevels

2019-08-06 Thread Sophie Blee-Goldman (JIRA)
Sophie Blee-Goldman created KAFKA-8761: -- Summary: Flaky Test AdminClientIntegrationTest.testIncrementalAlterConfigsForLog4jLogLevels Key: KAFKA-8761 URL: https://issues.apache.org/jira/browse/KAFKA-8761

[jira] [Created] (KAFKA-8763) Flaky Test SaslSslAdminClientIntegrationTest.testIncrementalAlterConfigsForLog4jLogLevels

2019-08-06 Thread Sophie Blee-Goldman (JIRA)
Sophie Blee-Goldman created KAFKA-8763: -- Summary: Flaky Test SaslSslAdminClientIntegrationTest.testIncrementalAlterConfigsForLog4jLogLevels Key: KAFKA-8763 URL:

[jira] [Created] (KAFKA-8762) Flaky Test AdminClientIntegrationTest.testIncrementalAlterConfigsForLog4jLogLevelsCanResetLoggerToCurrentRoot

2019-08-06 Thread Sophie Blee-Goldman (JIRA)
Sophie Blee-Goldman created KAFKA-8762: -- Summary: Flaky Test AdminClientIntegrationTest.testIncrementalAlterConfigsForLog4jLogLevelsCanResetLoggerToCurrentRoot Key: KAFKA-8762 URL:

[jira] [Resolved] (KAFKA-8763) Flaky Test SaslSslAdminClientIntegrationTest.testIncrementalAlterConfigsForLog4jLogLevels

2019-08-08 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman resolved KAFKA-8763. Resolution: Duplicate duplicate of 8756 > Flaky Test >

[jira] [Created] (KAFKA-8771) Flaky Test SaslClientsWithInvalidCredentialsTest.testManualAssignmentConsumerWithAuthenticationFailure

2019-08-08 Thread Sophie Blee-Goldman (JIRA)
Sophie Blee-Goldman created KAFKA-8771: -- Summary: Flaky Test SaslClientsWithInvalidCredentialsTest.testManualAssignmentConsumerWithAuthenticationFailure Key: KAFKA-8771 URL:

[jira] [Created] (KAFKA-8772) Flaky Test kafka.api.DelegationTokenEndToEndAuthorizationTest.testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl

2019-08-08 Thread Sophie Blee-Goldman (JIRA)
Sophie Blee-Goldman created KAFKA-8772: -- Summary: Flaky Test kafka.api.DelegationTokenEndToEndAuthorizationTest.testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl Key: KAFKA-8772 URL:

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

2019-08-09 Thread Sophie Blee-Goldman (JIRA)
Sophie Blee-Goldman created KAFKA-8784: -- Summary: Remove default implementation of RocksDBConfigSetter#close Key: KAFKA-8784 URL: https://issues.apache.org/jira/browse/KAFKA-8784 Project: Kafka

[jira] [Created] (KAFKA-8703) Move PartitionAssignor to public API

2019-07-23 Thread Sophie Blee-Goldman (JIRA)
Sophie Blee-Goldman created KAFKA-8703: -- Summary: Move PartitionAssignor to public API Key: KAFKA-8703 URL: https://issues.apache.org/jira/browse/KAFKA-8703 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-8704) Add PartitionAssignor adapter for backwards compatibility

2019-07-23 Thread Sophie Blee-Goldman (JIRA)
Sophie Blee-Goldman created KAFKA-8704: -- Summary: Add PartitionAssignor adapter for backwards compatibility Key: KAFKA-8704 URL: https://issues.apache.org/jira/browse/KAFKA-8704 Project: Kafka

[jira] [Resolved] (KAFKA-8637) WriteBatch objects leak off-heap memory

2019-07-15 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman resolved KAFKA-8637. Resolution: Fixed > WriteBatch objects leak off-heap memory >

[jira] [Resolved] (KAFKA-8703) Move PartitionAssignor to public API

2019-07-25 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman resolved KAFKA-8703. Resolution: Fixed > Move PartitionAssignor to public API >

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

2019-09-26 Thread Sophie Blee-Goldman (Jira)
Sophie Blee-Goldman created KAFKA-8948: -- Summary: StreamsEosTest#test_rebalance_complex is broken for multiple runs Key: KAFKA-8948 URL: https://issues.apache.org/jira/browse/KAFKA-8948 Project:

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

2019-09-26 Thread Sophie Blee-Goldman (Jira)
Sophie Blee-Goldman created KAFKA-8951: -- Summary: Avoid unnecessary rebalances and downtime for "safe" partitions Key: KAFKA-8951 URL: https://issues.apache.org/jira/browse/KAFKA-8951 Project:

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

2019-09-24 Thread Sophie Blee-Goldman (Jira)
Sophie Blee-Goldman created KAFKA-8939: -- Summary: Flaky test ReassignPartitionsClusterTest#shouldTriggerReassignmentWithZnodePrecedenceOnControllerStartup Key: KAFKA-8939 URL:

[jira] [Created] (KAFKA-8937) Flaky Test SaslPlainSslEndToEndAuthorizationTest#testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl

2019-09-24 Thread Sophie Blee-Goldman (Jira)
Sophie Blee-Goldman created KAFKA-8937: -- Summary: Flaky Test SaslPlainSslEndToEndAuthorizationTest#testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl Key: KAFKA-8937 URL:

[jira] [Reopened] (KAFKA-7965) Flaky Test ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

2019-09-24 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman reopened KAFKA-7965: Assignee: (was: Jason Gustafson) Saw another failure in PR builder (2.4) >

[jira] [Resolved] (KAFKA-8495) Make Round-robin / RangeAssignor to be "sticky" (part 5)

2019-06-13 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman resolved KAFKA-8495. Resolution: Won't Do Round-robin/range assignors will deliberately not support

[jira] [Created] (KAFKA-9132) Refactor StreamThread to take advantage of new ConsumerRebalanceListener exception handling

2019-11-01 Thread Sophie Blee-Goldman (Jira)
Sophie Blee-Goldman created KAFKA-9132: -- Summary: Refactor StreamThread to take advantage of new ConsumerRebalanceListener exception handling Key: KAFKA-9132 URL:

[jira] [Created] (KAFKA-9134) Refactor the StreamsPartitionAssignor for more code sharing with the FutureStreamsPartitionAssignor

2019-11-02 Thread Sophie Blee-Goldman (Jira)
Sophie Blee-Goldman created KAFKA-9134: -- Summary: Refactor the StreamsPartitionAssignor for more code sharing with the FutureStreamsPartitionAssignor Key: KAFKA-9134 URL:

[jira] [Created] (KAFKA-9140) Consumer gets stuck rejoining the group indefinitely

2019-11-04 Thread Sophie Blee-Goldman (Jira)
Sophie Blee-Goldman created KAFKA-9140: -- Summary: Consumer gets stuck rejoining the group indefinitely Key: KAFKA-9140 URL: https://issues.apache.org/jira/browse/KAFKA-9140 Project: Kafka

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

2019-11-05 Thread Sophie Blee-Goldman (Jira)
Sophie Blee-Goldman created KAFKA-9148: -- Summary: Consider forking RocksDB for Streams Key: KAFKA-9148 URL: https://issues.apache.org/jira/browse/KAFKA-9148 Project: Kafka Issue Type:

[jira] [Resolved] (KAFKA-8367) Non-heap memory leak in Kafka Streams

2019-11-05 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman resolved KAFKA-8367. Resolution: Fixed > Non-heap memory leak in Kafka Streams >

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

2019-11-07 Thread Sophie Blee-Goldman (Jira)
Sophie Blee-Goldman created KAFKA-9161: -- Summary: Close gaps in Streams configs documentation Key: KAFKA-9161 URL: https://issues.apache.org/jira/browse/KAFKA-9161 Project: Kafka Issue

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

2019-11-12 Thread Sophie Blee-Goldman (Jira)
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] [Created] (KAFKA-9208) Flaky Test SslAdminClientIntegrationTest.testCreatePartitions

2019-11-18 Thread Sophie Blee-Goldman (Jira)
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] [Resolved] (KAFKA-9281) Consider more flexible node grouping for Pattern subscription

2019-12-06 Thread Sophie Blee-Goldman (Jira)
[ 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] [Created] (KAFKA-9281) Consider more flexible node grouping for Pattern subscription

2019-12-06 Thread Sophie Blee-Goldman (Jira)
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

2019-12-06 Thread Sophie Blee-Goldman (Jira)
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] [Created] (KAFKA-9053) AssignmentInfo#encode hardcodes the LATEST_SUPPORTED_VERSION

2019-10-16 Thread Sophie Blee-Goldman (Jira)
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] [Created] (KAFKA-9113) Clean up task management

2019-10-29 Thread Sophie Blee-Goldman (Jira)
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

2019-10-16 Thread Sophie Blee-Goldman (Jira)
[ 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] [Created] (KAFKA-9062) RocksDB writes may stall after bulk loading lots of state

2019-10-17 Thread Sophie Blee-Goldman (Jira)
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] [Reopened] (KAFKA-9208) Flaky Test SslAdminClientIntegrationTest.testCreatePartitions

2019-11-19 Thread Sophie Blee-Goldman (Jira)
[ 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] [Resolved] (KAFKA-8972) KafkaConsumer.unsubscribe could leave inconsistent user rebalance callback state

2019-10-29 Thread Sophie Blee-Goldman (Jira)
[ 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] [Resolved] (KAFKA-8948) Flaky Test StreamsEosTest#test_rebalance_complex is broken for multiple runs

2019-10-09 Thread Sophie Blee-Goldman (Jira)
[ 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] [Created] (KAFKA-9022) Flaky Test KTableKTableForeignKeyJoinIntegrationTest. doInnerJoinFilterOutRapidlyChangingForeignKeyValues

2019-10-10 Thread Sophie Blee-Goldman (Jira)
Sophie Blee-Goldman created KAFKA-9022: -- Summary: Flaky Test KTableKTableForeignKeyJoinIntegrationTest. doInnerJoinFilterOutRapidlyChangingForeignKeyValues Key: KAFKA-9022 URL:

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

2019-10-08 Thread Sophie Blee-Goldman (Jira)
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

2019-10-08 Thread Sophie Blee-Goldman (Jira)
Sophie Blee-Goldman created KAFKA-9001: -- Summary: Flaky Test KStreamAggregationIntegrationTest#shouldReduceSessionWindows Key: KAFKA-9001 URL: https://issues.apache.org/jira/browse/KAFKA-9001

[jira] [Resolved] (KAFKA-8649) Error while rolling update from Kafka Streams 2.0.0 -> Kafka Streams 2.1.0

2019-10-04 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman resolved KAFKA-8649. Fix Version/s: 2.3.1 2.4.0 Resolution: Fixed > Error

[jira] [Created] (KAFKA-8987) Allow IQ on restored state stores while others are still restoring

2019-10-04 Thread Sophie Blee-Goldman (Jira)
Sophie Blee-Goldman created KAFKA-8987: -- Summary: Allow IQ on restored state stores while others are still restoring Key: KAFKA-8987 URL: https://issues.apache.org/jira/browse/KAFKA-8987

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

2019-10-14 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman resolved KAFKA-9020. Fix Version/s: 2.4.0 Resolution: Fixed > Streams sub-topologies should be

[jira] [Created] (KAFKA-9323) Refactor Streams' upgrade system tests

2019-12-20 Thread Sophie Blee-Goldman (Jira)
Sophie Blee-Goldman created KAFKA-9323: -- Summary: Refactor Streams' upgrade system tests Key: KAFKA-9323 URL: https://issues.apache.org/jira/browse/KAFKA-9323 Project: Kafka Issue

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

2020-03-05 Thread Sophie Blee-Goldman (Jira)
Sophie Blee-Goldman created KAFKA-9664: -- Summary: Flaky Test KafkaStreamsTest#testStateThreadClose Key: KAFKA-9664 URL: https://issues.apache.org/jira/browse/KAFKA-9664 Project: Kafka

[jira] [Created] (KAFKA-9467) Multiple wallclock punctuators may be scheduled after a rebalance

2020-01-22 Thread Sophie Blee-Goldman (Jira)
Sophie Blee-Goldman created KAFKA-9467: -- Summary: Multiple wallclock punctuators may be scheduled after a rebalance Key: KAFKA-9467 URL: https://issues.apache.org/jira/browse/KAFKA-9467 Project:

[jira] [Resolved] (KAFKA-5868) Kafka Consumer Rebalancing takes too long

2020-02-04 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-5868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman resolved KAFKA-5868. Fix Version/s: 2.5.0 Resolution: Fixed > Kafka Consumer Rebalancing takes

[jira] [Created] (KAFKA-9521) Flaky Test DeleteConsumerGroupsTest#testDeleteCmdEmptyGroup

2020-02-06 Thread Sophie Blee-Goldman (Jira)
Sophie Blee-Goldman created KAFKA-9521: -- Summary: Flaky Test DeleteConsumerGroupsTest#testDeleteCmdEmptyGroup Key: KAFKA-9521 URL: https://issues.apache.org/jira/browse/KAFKA-9521 Project: Kafka

[jira] [Created] (KAFKA-9525) Allow explicit rebalance triggering on the Consumer

2020-02-07 Thread Sophie Blee-Goldman (Jira)
Sophie Blee-Goldman created KAFKA-9525: -- Summary: Allow explicit rebalance triggering on the Consumer Key: KAFKA-9525 URL: https://issues.apache.org/jira/browse/KAFKA-9525 Project: Kafka

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

2020-02-20 Thread Sophie Blee-Goldman (Jira)
Sophie Blee-Goldman created KAFKA-9585: -- Summary: Flaky Test: LagFetchIntegrationTest#shouldFetchLagsDuringRebalancingWithOptimization Key: KAFKA-9585 URL: https://issues.apache.org/jira/browse/KAFKA-9585

[jira] [Created] (KAFKA-9559) Change the default "default serde" from ByteArraySerde to null

2020-02-14 Thread Sophie Blee-Goldman (Jira)
Sophie Blee-Goldman created KAFKA-9559: -- Summary: Change the default "default serde" from ByteArraySerde to null Key: KAFKA-9559 URL: https://issues.apache.org/jira/browse/KAFKA-9559 Project:

[jira] [Resolved] (KAFKA-9540) Application getting "Could not find the standby task 0_4 while closing it" error

2020-02-18 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman resolved KAFKA-9540. Fix Version/s: 2.6.0 Resolution: Fixed > Application getting "Could not

[jira] [Resolved] (KAFKA-3596) Kafka Streams: Window expiration needs to consider more than event time

2020-01-15 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-3596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman resolved KAFKA-3596. Resolution: Not A Problem > Kafka Streams: Window expiration needs to consider

[jira] [Created] (KAFKA-9450) Decouple inner state flushing from committing with EOS

2020-01-17 Thread Sophie Blee-Goldman (Jira)
Sophie Blee-Goldman created KAFKA-9450: -- Summary: Decouple inner state flushing from committing with EOS Key: KAFKA-9450 URL: https://issues.apache.org/jira/browse/KAFKA-9450 Project: Kafka

[jira] [Resolved] (KAFKA-9356) Potential data loss in InMemoryWindowStore and InMemorySessionStore

2020-01-16 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman resolved KAFKA-9356. Resolution: Not A Problem > Potential data loss in InMemoryWindowStore and

[jira] [Created] (KAFKA-9349) Investigate new member timeout for dynamic v4 JoinGroup

2019-12-30 Thread Sophie Blee-Goldman (Jira)
Sophie Blee-Goldman created KAFKA-9349: -- Summary: Investigate new member timeout for dynamic v4 JoinGroup Key: KAFKA-9349 URL: https://issues.apache.org/jira/browse/KAFKA-9349 Project: Kafka

[jira] [Reopened] (KAFKA-7994) Improve Stream-Time for rebalances and restarts

2019-12-30 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman reopened KAFKA-7994: Assignee: (was: Richard Yu) I'm not sure we should close this yet, it seems

[jira] [Created] (KAFKA-9368) Preserve stream-time across rebalances/restarts

2020-01-06 Thread Sophie Blee-Goldman (Jira)
Sophie Blee-Goldman created KAFKA-9368: -- Summary: Preserve stream-time across rebalances/restarts Key: KAFKA-9368 URL: https://issues.apache.org/jira/browse/KAFKA-9368 Project: Kafka

[jira] [Created] (KAFKA-9846) Race condition can lead to severe lag underestimate for active tasks

2020-04-09 Thread Sophie Blee-Goldman (Jira)
Sophie Blee-Goldman created KAFKA-9846: -- Summary: Race condition can lead to severe lag underestimate for active tasks Key: KAFKA-9846 URL: https://issues.apache.org/jira/browse/KAFKA-9846

[jira] [Created] (KAFKA-9868) Flaky Test EOSUncleanShutdownIntegrationTest.shouldWorkWithUncleanShutdownWipeOutStateStore

2020-04-14 Thread Sophie Blee-Goldman (Jira)
Sophie Blee-Goldman created KAFKA-9868: -- Summary: Flaky Test EOSUncleanShutdownIntegrationTest.shouldWorkWithUncleanShutdownWipeOutStateStore Key: KAFKA-9868 URL:

[jira] [Created] (KAFKA-9792) Improve sticky task assignment for previous active tasks

2020-03-31 Thread Sophie Blee-Goldman (Jira)
Sophie Blee-Goldman created KAFKA-9792: -- Summary: Improve sticky task assignment for previous active tasks Key: KAFKA-9792 URL: https://issues.apache.org/jira/browse/KAFKA-9792 Project: Kafka

[jira] [Created] (KAFKA-9819) Flaky Test StoreChangelogReaderTest#shouldNotThrowOnUnknownRevokedPartition[0]

2020-04-03 Thread Sophie Blee-Goldman (Jira)
Sophie Blee-Goldman created KAFKA-9819: -- Summary: Flaky Test StoreChangelogReaderTest#shouldNotThrowOnUnknownRevokedPartition[0] Key: KAFKA-9819 URL: https://issues.apache.org/jira/browse/KAFKA-9819

[jira] [Created] (KAFKA-9818) Flaky Test RecordCollectorTest.shouldNotThrowStreamsExceptionOnSubsequentCallIfASendFailsWithContinueExceptionHandler

2020-04-03 Thread Sophie Blee-Goldman (Jira)
Sophie Blee-Goldman created KAFKA-9818: -- Summary: Flaky Test RecordCollectorTest.shouldNotThrowStreamsExceptionOnSubsequentCallIfASendFailsWithContinueExceptionHandler Key: KAFKA-9818 URL:

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

2020-04-27 Thread Sophie Blee-Goldman (Jira)
Sophie Blee-Goldman created KAFKA-9923: -- Summary: Join window store duplicates can be compacted in changelog Key: KAFKA-9923 URL: https://issues.apache.org/jira/browse/KAFKA-9923 Project: Kafka

[jira] [Reopened] (KAFKA-9798) Flaky test: org.apache.kafka.streams.integration.QueryableStateIntegrationTest.shouldAllowConcurrentAccesses

2020-04-27 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman reopened KAFKA-9798: Assignee: (was: Guozhang Wang) > Flaky test: >

[jira] [Reopened] (KAFKA-9176) Flaky test failure: OptimizedKTableIntegrationTest.shouldApplyUpdatesToStandbyStore

2020-04-27 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman reopened KAFKA-9176: Saw this fail again on a PR with h3. Stacktrace

[jira] [Created] (KAFKA-9898) Flaky Test StoreQueryIntegrationTest.shouldQueryAllStalePartitionStores

2020-04-21 Thread Sophie Blee-Goldman (Jira)
Sophie Blee-Goldman created KAFKA-9898: -- Summary: Flaky Test StoreQueryIntegrationTest.shouldQueryAllStalePartitionStores Key: KAFKA-9898 URL: https://issues.apache.org/jira/browse/KAFKA-9898

[jira] [Reopened] (KAFKA-7484) Fix test SuppressionDurabilityIntegrationTest.shouldRecoverBufferAfterShutdown()

2020-04-15 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman reopened KAFKA-7484: failed on a PR with h3. Stacktrace java.lang.RuntimeException:

[jira] [Resolved] (KAFKA-7484) Fix test SuppressionDurabilityIntegrationTest.shouldRecoverBufferAfterShutdown()

2020-04-15 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman resolved KAFKA-7484. Resolution: Fixed > Fix test >

[jira] [Created] (KAFKA-9875) Flaky Test SuppressionDurabilityIntegrationTest.shouldRecoverBufferAfterShutdown[exactly_once]

2020-04-15 Thread Sophie Blee-Goldman (Jira)
Sophie Blee-Goldman created KAFKA-9875: -- Summary: Flaky Test SuppressionDurabilityIntegrationTest.shouldRecoverBufferAfterShutdown[exactly_once] Key: KAFKA-9875 URL:

[jira] [Created] (KAFKA-9983) Add end-to-end latency metrics to Streams

2020-05-12 Thread Sophie Blee-Goldman (Jira)
Sophie Blee-Goldman created KAFKA-9983: -- Summary: Add end-to-end latency metrics to Streams Key: KAFKA-9983 URL: https://issues.apache.org/jira/browse/KAFKA-9983 Project: Kafka Issue

[jira] [Created] (KAFKA-9987) Add new cooperative assignor optimized for constant-subscription. group

2020-05-13 Thread Sophie Blee-Goldman (Jira)
Sophie Blee-Goldman created KAFKA-9987: -- Summary: Add new cooperative assignor optimized for constant-subscription. group Key: KAFKA-9987 URL: https://issues.apache.org/jira/browse/KAFKA-9987

  1   2   >