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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

[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-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-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-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-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: https://issues.apache.org/j

[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: https://issues.apache.org/jira/browse/KAFKA-876

[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-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: https://issues.apache.org/jira/bro

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

[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: https://issues.apache

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

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

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

[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: https://issues.apache.org/jira/bro

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

[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: https://issues.apache.org/jira/b

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

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

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

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

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

[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: https://issues.apache.org/jira/

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

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

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

[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: https://issues.apache.org/jira/browse/KAFKA-9

[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: https://issues.apache.org/jira/browse

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

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

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

[jira] [Resolved] (KAFKA-10119) StreamsResetter fails with TimeoutException for older Brokers

2020-06-10 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman resolved KAFKA-10119. - Resolution: Duplicate Closing this as a duplicate, the issue is tracked by KAFKA

[jira] [Created] (KAFKA-10144) Corrupted standby tasks are not always cleaned up

2020-06-10 Thread Sophie Blee-Goldman (Jira)
Sophie Blee-Goldman created KAFKA-10144: --- Summary: Corrupted standby tasks are not always cleaned up Key: KAFKA-10144 URL: https://issues.apache.org/jira/browse/KAFKA-10144 Project: Kafka

[jira] [Created] (KAFKA-10150) IllegalStateException when revoking task in CREATED state

2020-06-11 Thread Sophie Blee-Goldman (Jira)
Sophie Blee-Goldman created KAFKA-10150: --- Summary: IllegalStateException when revoking task in CREATED state Key: KAFKA-10150 URL: https://issues.apache.org/jira/browse/KAFKA-10150 Project: Kafka

[jira] [Created] (KAFKA-10151) Flaky Test StoreUpgradeIntegrationTest.shouldMigratePersistentKeyValueStoreToTimestampedKeyValueStoreUsingPapiStoreUpgradeIntegrationTest.shouldMigratePersistentKeyValue

2020-06-11 Thread Sophie Blee-Goldman (Jira)
Sophie Blee-Goldman created KAFKA-10151: --- Summary: Flaky Test StoreUpgradeIntegrationTest.shouldMigratePersistentKeyValueStoreToTimestampedKeyValueStoreUsingPapiStoreUpgradeIntegrationTest.shouldMigratePersistentKeyValueStoreToTimestampedKey

[jira] [Created] (KAFKA-10152) Attempt to write checkpoint without first committing during recycle

2020-06-11 Thread Sophie Blee-Goldman (Jira)
Sophie Blee-Goldman created KAFKA-10152: --- Summary: Attempt to write checkpoint without first committing during recycle Key: KAFKA-10152 URL: https://issues.apache.org/jira/browse/KAFKA-10152 Pro

[jira] [Created] (KAFKA-10155) Flaky Test ReassignPartitionsUnitTest.testModifyBrokerThrottles

2020-06-11 Thread Sophie Blee-Goldman (Jira)
Sophie Blee-Goldman created KAFKA-10155: --- Summary: Flaky Test ReassignPartitionsUnitTest.testModifyBrokerThrottles Key: KAFKA-10155 URL: https://issues.apache.org/jira/browse/KAFKA-10155 Project

[jira] [Created] (KAFKA-10156) Flaky Test SslSelectorTest.testCloseOldestConnection

2020-06-11 Thread Sophie Blee-Goldman (Jira)
Sophie Blee-Goldman created KAFKA-10156: --- Summary: Flaky Test SslSelectorTest.testCloseOldestConnection Key: KAFKA-10156 URL: https://issues.apache.org/jira/browse/KAFKA-10156 Project: Kafka

[jira] [Created] (KAFKA-10165) Percentiles metric leaking memory

2020-06-15 Thread Sophie Blee-Goldman (Jira)
Sophie Blee-Goldman created KAFKA-10165: --- Summary: Percentiles metric leaking memory Key: KAFKA-10165 URL: https://issues.apache.org/jira/browse/KAFKA-10165 Project: Kafka Issue Type: B

[jira] [Created] (KAFKA-10166) Excessive TaskCorruptedException seen in soak

2020-06-15 Thread Sophie Blee-Goldman (Jira)
Sophie Blee-Goldman created KAFKA-10166: --- Summary: Excessive TaskCorruptedException seen in soak Key: KAFKA-10166 URL: https://issues.apache.org/jira/browse/KAFKA-10166 Project: Kafka I

[jira] [Created] (KAFKA-10169) KafkaException: Failing batch since transaction was aborted

2020-06-15 Thread Sophie Blee-Goldman (Jira)
Sophie Blee-Goldman created KAFKA-10169: --- Summary: KafkaException: Failing batch since transaction was aborted Key: KAFKA-10169 URL: https://issues.apache.org/jira/browse/KAFKA-10169 Project: Ka

[jira] [Reopened] (KAFKA-9896) Flaky Test StandbyTaskEOSIntegrationTest#surviveWithOneTaskAsStandby[exactly_once_beta]

2020-06-16 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman reopened KAFKA-9896: Assignee: Sophie Blee-Goldman (was: Matthias J. Sax) Saw this fail again locally

[jira] [Created] (KAFKA-10177) Replace/improve/remove Percentiles metric

2020-06-16 Thread Sophie Blee-Goldman (Jira)
Sophie Blee-Goldman created KAFKA-10177: --- Summary: Replace/improve/remove Percentiles metric Key: KAFKA-10177 URL: https://issues.apache.org/jira/browse/KAFKA-10177 Project: Kafka Issue

[jira] [Reopened] (KAFKA-9974) Flaky Test OptimizedKTableIntegrationTest#shouldApplyUpdatesToStandbyStore

2020-06-17 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman reopened KAFKA-9974: Unfortunately this just failed again, at a different place: h3. Stacktrace java.lang.A

[jira] [Resolved] (KAFKA-10151) Flaky Test StoreUpgradeIntegrationTest.shouldMigratePersistentKeyValueStoreToTimestampedKeyValueStoreUsingPapi

2020-06-17 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman resolved KAFKA-10151. - Fix Version/s: 2.6.0 Resolution: Fixed > Flaky Test > StoreUpgradeIntegr

[jira] [Reopened] (KAFKA-9509) Fix flaky test MirrorConnectorsIntegrationTest.testReplication

2020-06-17 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman reopened KAFKA-9509: Saw this fail again on a PR build: h3. Stacktrace java.lang.RuntimeException: Could no

[jira] [Created] (KAFKA-10186) Aborting transaction with pending data should throw non-fatal exception

2020-06-18 Thread Sophie Blee-Goldman (Jira)
Sophie Blee-Goldman created KAFKA-10186: --- Summary: Aborting transaction with pending data should throw non-fatal exception Key: KAFKA-10186 URL: https://issues.apache.org/jira/browse/KAFKA-10186

[jira] [Created] (KAFKA-10198) Dirty tasks may be recycled instead of closed

2020-06-24 Thread Sophie Blee-Goldman (Jira)
Sophie Blee-Goldman created KAFKA-10198: --- Summary: Dirty tasks may be recycled instead of closed Key: KAFKA-10198 URL: https://issues.apache.org/jira/browse/KAFKA-10198 Project: Kafka I

[jira] [Reopened] (KAFKA-8197) Flaky Test kafka.server.DynamicBrokerConfigTest > testPasswordConfigEncoderSecretChange

2020-06-24 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman reopened KAFKA-8197: Saw this fail again:  kafka.server.DynamicBrokerConfigTest > testPasswordConfigEncoderS

[jira] [Resolved] (KAFKA-10166) Excessive TaskCorruptedException seen in testing

2020-06-26 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman resolved KAFKA-10166. - Resolution: Fixed > Excessive TaskCorruptedException seen in testing > -

[jira] [Resolved] (KAFKA-6508) Look into optimizing StreamPartitionAssignor StandbyTask Assignment

2020-06-29 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman resolved KAFKA-6508. Resolution: Fixed This should be addressed via KIP-441 > Look into optimizing Stre

[jira] [Reopened] (KAFKA-10166) Excessive TaskCorruptedException seen in testing

2020-06-30 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman reopened KAFKA-10166: - Assignee: (was: Bruno Cadonna) Found two edge cases we missed earlier so I

[jira] [Resolved] (KAFKA-10191) fix flaky StreamsOptimizedTest

2020-07-07 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman resolved KAFKA-10191. - Resolution: Fixed > fix flaky StreamsOptimizedTest > ---

[jira] [Created] (KAFKA-10249) In-memory stores are skipped when checkpointing but not skipped when reading the checkpoint

2020-07-08 Thread Sophie Blee-Goldman (Jira)
Sophie Blee-Goldman created KAFKA-10249: --- Summary: In-memory stores are skipped when checkpointing but not skipped when reading the checkpoint Key: KAFKA-10249 URL: https://issues.apache.org/jira/browse/KAFK

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

2020-07-08 Thread Sophie Blee-Goldman (Jira)
Sophie Blee-Goldman created KAFKA-10251: --- Summary: Flaky Test kafka.api.TransactionsBounceTest.testWithGroupMetadata Key: KAFKA-10251 URL: https://issues.apache.org/jira/browse/KAFKA-10251 Proje

[jira] [Created] (KAFKA-10262) StateDirectory is not thread-safe

2020-07-09 Thread Sophie Blee-Goldman (Jira)
Sophie Blee-Goldman created KAFKA-10262: --- Summary: StateDirectory is not thread-safe Key: KAFKA-10262 URL: https://issues.apache.org/jira/browse/KAFKA-10262 Project: Kafka Issue Type: B

[jira] [Created] (KAFKA-10264) Flaky Test TransactionsTest.testBumpTransactionalEpoch

2020-07-09 Thread Sophie Blee-Goldman (Jira)
Sophie Blee-Goldman created KAFKA-10264: --- Summary: Flaky Test TransactionsTest.testBumpTransactionalEpoch Key: KAFKA-10264 URL: https://issues.apache.org/jira/browse/KAFKA-10264 Project: Kafka

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

2020-07-15 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman reopened KAFKA-9161: > Close gaps in Streams configs documentation > ---

[jira] [Created] (KAFKA-10395) TopologyTestDriver does not work with dynamic topic routing

2020-08-12 Thread Sophie Blee-Goldman (Jira)
Sophie Blee-Goldman created KAFKA-10395: --- Summary: TopologyTestDriver does not work with dynamic topic routing Key: KAFKA-10395 URL: https://issues.apache.org/jira/browse/KAFKA-10395 Project: Ka

[jira] [Resolved] (KAFKA-10395) TopologyTestDriver does not work with dynamic topic routing

2020-08-18 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman resolved KAFKA-10395. - Fix Version/s: 2.7.0 Resolution: Fixed > TopologyTestDriver does not work

[jira] [Created] (KAFKA-10455) Probing rebalances are not guaranteed to be triggered by non-leader members

2020-09-01 Thread Sophie Blee-Goldman (Jira)
Sophie Blee-Goldman created KAFKA-10455: --- Summary: Probing rebalances are not guaranteed to be triggered by non-leader members Key: KAFKA-10455 URL: https://issues.apache.org/jira/browse/KAFKA-10455

[jira] [Resolved] (KAFKA-7970) Missing topic causes service shutdown without exception

2020-09-11 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman resolved KAFKA-7970. Fix Version/s: 2.7.0 Assignee: Bruno Cadonna Resolution: Fixed > Mi

[jira] [Resolved] (KAFKA-6127) Streams should never block infinitely

2020-09-18 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman resolved KAFKA-6127. Resolution: Fixed > Streams should never block infinitely > ---

[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-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: https://issues.apac

  1   2   3   4   >