[jira] [Commented] (KAFKA-8924) Default grace period (-1) of TimeWindows causes suppress to emit events after 24h

2021-04-05 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17315217#comment-17315217 ] A. Sophie Blee-Goldman commented on KAFKA-8924: --- Can we close this as a dup

[jira] [Assigned] (KAFKA-8613) Set default grace period to 0

2021-04-05 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman reassigned KAFKA-8613: - Assignee: A. Sophie Blee-Goldman > Set default grace period to 0 > -

[jira] [Resolved] (KAFKA-6603) Kafka streams off heap memory usage does not match expected values from configuration

2021-04-05 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman resolved KAFKA-6603. --- Resolution: Fixed > Kafka streams off heap memory usage does not match expect

[jira] [Resolved] (KAFKA-8165) Streams task causes Out Of Memory after connection issues and store restoration

2021-04-05 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman resolved KAFKA-8165. --- Resolution: Fixed > Streams task causes Out Of Memory after connection issues

[jira] [Commented] (KAFKA-12419) Remove Deprecated APIs of Kafka Streams in 3.0

2021-04-05 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17315209#comment-17315209 ] A. Sophie Blee-Goldman commented on KAFKA-12419: Thanks -- wanted to mak

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

2021-04-05 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17315186#comment-17315186 ] A. Sophie Blee-Goldman commented on KAFKA-12492: Yeah, you need to check

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

2021-04-05 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17315183#comment-17315183 ] A. Sophie Blee-Goldman commented on KAFKA-12492: Thanks, I'll take a loo

[jira] [Commented] (KAFKA-12574) Deprecate eos-alpha

2021-04-05 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17315142#comment-17315142 ] A. Sophie Blee-Goldman commented on KAFKA-12574: > This is well document

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

2021-04-05 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17315140#comment-17315140 ] A. Sophie Blee-Goldman commented on KAFKA-12492: The kafka-site repo is

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

2021-04-02 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12283: --- Fix Version/s: 3.0.0 > Flaky Test > RebalanceSourceConnectorsIntegrationTes

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

2021-04-02 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17314098#comment-17314098 ] A. Sophie Blee-Goldman commented on KAFKA-12283: Ok I merged the PR to i

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

2021-04-02 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12283: --- Priority: Blocker (was: Critical) > Flaky Test > RebalanceSourceConnectors

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

2021-04-02 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17314022#comment-17314022 ] A. Sophie Blee-Goldman commented on KAFKA-9559: --- Definitely +1 to refactori

[jira] [Created] (KAFKA-12595) New Consumer metric for records/bytes committed

2021-03-31 Thread A. Sophie Blee-Goldman (Jira)
A. Sophie Blee-Goldman created KAFKA-12595: -- Summary: New Consumer metric for records/bytes committed Key: KAFKA-12595 URL: https://issues.apache.org/jira/browse/KAFKA-12595 Project: Kafka

[jira] [Commented] (KAFKA-12593) The Streams-Scala contains the wrong license header

2021-03-31 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17312614#comment-17312614 ] A. Sophie Blee-Goldman commented on KAFKA-12593: Hey [~vvcephei], thanks

[jira] [Commented] (KAFKA-9897) Flaky Test StoreQueryIntegrationTest#shouldQuerySpecificActivePartitionStores

2021-03-31 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17312590#comment-17312590 ] A. Sophie Blee-Goldman commented on KAFKA-9897: --- Failed again: {code:java}

[jira] [Reopened] (KAFKA-9897) Flaky Test StoreQueryIntegrationTest#shouldQuerySpecificActivePartitionStores

2021-03-31 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman reopened KAFKA-9897: --- > Flaky Test StoreQueryIntegrationTest#shouldQuerySpecificActivePartitionStores >

[jira] [Commented] (KAFKA-12574) Deprecate eos-alpha

2021-03-31 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17312563#comment-17312563 ] A. Sophie Blee-Goldman commented on KAFKA-12574: I think maybe we weren'

[jira] [Commented] (KAFKA-12574) Deprecate eos-alpha

2021-03-30 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17312027#comment-17312027 ] A. Sophie Blee-Goldman commented on KAFKA-12574: I would expect users wh

[jira] [Commented] (KAFKA-8529) Flakey test ConsumerBounceTest#testCloseDuringRebalance

2021-03-30 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17311962#comment-17311962 ] A. Sophie Blee-Goldman commented on KAFKA-8529: --- {code:java} org.opentest4j

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

2021-03-30 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17311954#comment-17311954 ] A. Sophie Blee-Goldman commented on KAFKA-9559: --- I don't think we can just

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

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

[jira] [Commented] (KAFKA-12574) Deprecate eos-alpha

2021-03-30 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17311787#comment-17311787 ] A. Sophie Blee-Goldman commented on KAFKA-12574: > I think this is sligh

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

2021-03-30 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12509: --- Fix Version/s: 3.0.0 > Tighten up StateDirectory thread locking > --

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

2021-03-30 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman resolved KAFKA-12509. Resolution: Fixed > Tighten up StateDirectory thread locking > ---

[jira] [Updated] (KAFKA-12574) Deprecate eos-alpha

2021-03-30 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12574: --- Priority: Blocker (was: Major) > Deprecate eos-alpha > ---

[jira] [Updated] (KAFKA-12574) Deprecate eos-alpha

2021-03-30 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12574: --- Labels: needs-kip (was: ) > Deprecate eos-alpha > --- > >

[jira] [Commented] (KAFKA-12574) Deprecate eos-alpha

2021-03-30 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17311717#comment-17311717 ] A. Sophie Blee-Goldman commented on KAFKA-12574: That SGTM -- if users b

[jira] [Commented] (KAFKA-12574) Deprecate eos-alpha

2021-03-30 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17311685#comment-17311685 ] A. Sophie Blee-Goldman commented on KAFKA-12574: Yes, something like tha

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

2021-03-29 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17311065#comment-17311065 ] A. Sophie Blee-Goldman commented on KAFKA-9559: --- Adding a check for NPE eve

[jira] [Commented] (KAFKA-9552) Stream should handle OutOfSequence exception thrown from Producer

2021-03-29 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17311054#comment-17311054 ] A. Sophie Blee-Goldman commented on KAFKA-9552: --- Ok, so it sounds like catc

[jira] [Updated] (KAFKA-12550) Introduce RESTORING state to the KafkaStreams FSM

2021-03-29 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12550: --- Labels: needs-kip (was: ) > Introduce RESTORING state to the KafkaStreams F

[jira] [Commented] (KAFKA-12574) Deprecate eos-alpha

2021-03-29 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17310993#comment-17310993 ] A. Sophie Blee-Goldman commented on KAFKA-12574: Given the current name,

[jira] [Created] (KAFKA-12574) Deprecate eos-alpha

2021-03-29 Thread A. Sophie Blee-Goldman (Jira)
A. Sophie Blee-Goldman created KAFKA-12574: -- Summary: Deprecate eos-alpha Key: KAFKA-12574 URL: https://issues.apache.org/jira/browse/KAFKA-12574 Project: Kafka Issue Type: Improveme

[jira] [Commented] (KAFKA-12419) Remove Deprecated APIs of Kafka Streams in 3.0

2021-03-29 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17310948#comment-17310948 ] A. Sophie Blee-Goldman commented on KAFKA-12419: [~mjsax] Do you also re

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

2021-03-29 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17304537#comment-17304537 ] A. Sophie Blee-Goldman edited comment on KAFKA-12499 at 3/29/21, 7:39 PM:

[jira] [Updated] (KAFKA-12559) Add a top-level Streams config for bounding off-heap memory

2021-03-29 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12559: --- Labels: needs-kip newbie newbie++ (was: needs-kip) > Add a top-level Stream

[jira] [Updated] (KAFKA-12569) Clean up usage of commit flags in StateMachineTask

2021-03-28 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12569: --- Description: The TaskManagerTest uses the StateMachineTask which extends Abs

[jira] [Created] (KAFKA-12569) Clean up usage of commit flags in StateMachineTask

2021-03-28 Thread A. Sophie Blee-Goldman (Jira)
A. Sophie Blee-Goldman created KAFKA-12569: -- Summary: Clean up usage of commit flags in StateMachineTask Key: KAFKA-12569 URL: https://issues.apache.org/jira/browse/KAFKA-12569 Project: Kafka

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

2021-03-28 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17310300#comment-17310300 ] A. Sophie Blee-Goldman commented on KAFKA-12453: You literally wrote a t

[jira] [Updated] (KAFKA-12537) Single Threaded applications will not work with SHUTDOWN_APPLICATION

2021-03-26 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12537: --- Affects Version/s: (was: 3.0.0) > Single Threaded applications will not

[jira] [Updated] (KAFKA-12537) Single Threaded applications will not work with SHUTDOWN_APPLICATION

2021-03-26 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12537: --- Summary: Single Threaded applications will not work with SHUTDOWN_APPLICATIO

[jira] [Resolved] (KAFKA-12537) Single Threaded EOS applications will not work with SHUTDOWN_APPLICATION

2021-03-26 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman resolved KAFKA-12537. Fix Version/s: 2.8.0 Resolution: Fixed > Single Threaded EOS applic

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

2021-03-26 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman resolved KAFKA-10396. Resolution: Fixed > Overall memory of container keep on growing due to kaf

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

2021-03-26 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-8784: -- Description: In 2.3 we added a new method to RocksDBConfigSetter that will be c

[jira] [Assigned] (KAFKA-7606) Remove deprecated options from StreamsResetter

2021-03-25 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman reassigned KAFKA-7606: - Assignee: A. Sophie Blee-Goldman > Remove deprecated options from Stream

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

2021-03-25 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman reassigned KAFKA-8784: - Assignee: Walker Carlson (was: sats) > Remove default implementation of

[jira] [Commented] (KAFKA-12419) Remove Deprecated APIs of Kafka Streams in 3.0

2021-03-25 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17309167#comment-17309167 ] A. Sophie Blee-Goldman commented on KAFKA-12419: Ok I'm just gonna go fo

[jira] [Commented] (KAFKA-7606) Remove deprecated options from StreamsResetter

2021-03-25 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17309166#comment-17309166 ] A. Sophie Blee-Goldman commented on KAFKA-7606: --- Hey [~mjsax], you still pl

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

2021-03-25 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12485: --- Comment: was deleted (was: Side note: if we get this optimization in then we

[jira] [Commented] (KAFKA-12559) Add a top-level Streams config for bounding off-heap memory

2021-03-25 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17309052#comment-17309052 ] A. Sophie Blee-Goldman commented on KAFKA-12559: We can also consider wh

[jira] [Created] (KAFKA-12559) Add a top-level Streams config for bounding off-heap memory

2021-03-25 Thread A. Sophie Blee-Goldman (Jira)
A. Sophie Blee-Goldman created KAFKA-12559: -- Summary: Add a top-level Streams config for bounding off-heap memory Key: KAFKA-12559 URL: https://issues.apache.org/jira/browse/KAFKA-12559 Proje

[jira] [Commented] (KAFKA-6603) Kafka streams off heap memory usage does not match expected values from configuration

2021-03-25 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17309033#comment-17309033 ] A. Sophie Blee-Goldman commented on KAFKA-6603: --- Hey [~igor.calabria] can w

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

2021-03-25 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17309030#comment-17309030 ] A. Sophie Blee-Goldman commented on KAFKA-10396: Hey [~vmathapati] can w

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

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

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

2021-03-25 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-8575: -- Priority: Blocker (was: Major) > Investigate removing EAGER protocol & cleani

[jira] [Commented] (KAFKA-10575) StateRestoreListener#onRestoreEnd should always be triggered

2021-03-25 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17308931#comment-17308931 ] A. Sophie Blee-Goldman commented on KAFKA-10575: [~high.lee] this ticket

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

2021-03-25 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17308917#comment-17308917 ] A. Sophie Blee-Goldman commented on KAFKA-12283: Hey [~showuon] what's t

[jira] [Resolved] (KAFKA-12540) Sub-key support to avoid unnecessary rekey operations with new key is a compound key of the original key + sub-field

2021-03-24 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman resolved KAFKA-12540. Resolution: Duplicate > Sub-key support to avoid unnecessary rekey operati

[jira] [Created] (KAFKA-12550) Introduce RESTORING state to the KafkaStreams FSM

2021-03-24 Thread A. Sophie Blee-Goldman (Jira)
A. Sophie Blee-Goldman created KAFKA-12550: -- Summary: Introduce RESTORING state to the KafkaStreams FSM Key: KAFKA-12550 URL: https://issues.apache.org/jira/browse/KAFKA-12550 Project: Kafka

[jira] [Commented] (KAFKA-9430) Tighten up lag estimates when source topic optimization is on

2021-03-24 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17308310#comment-17308310 ] A. Sophie Blee-Goldman commented on KAFKA-9430: --- Hey [~vinoth] are you stil

[jira] [Commented] (KAFKA-10575) StateRestoreListener#onRestoreEnd should always be triggered

2021-03-24 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17308309#comment-17308309 ] A. Sophie Blee-Goldman commented on KAFKA-10575: [~high.lee] have you be

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

2021-03-24 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman resolved KAFKA-9846. --- Resolution: Fixed Resolving since this is fixed in 2.6 > Race condition can

[jira] [Updated] (KAFKA-10532) Do not wipe state store under EOS when closing-dirty a RESTORING active or RUNNING standby task

2021-03-24 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-10532: --- Labels: newbie++ (was: ) > Do not wipe state store under EOS when closing-d

[jira] [Commented] (KAFKA-8165) Streams task causes Out Of Memory after connection issues and store restoration

2021-03-24 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17308302#comment-17308302 ] A. Sophie Blee-Goldman commented on KAFKA-8165: --- [~xmar] IIRC there actuall

[jira] [Resolved] (KAFKA-8042) Kafka Streams creates many segment stores on state restore

2021-03-24 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman resolved KAFKA-8042. --- Fix Version/s: 2.6.0 Resolution: Fixed I believe this issue should be

[jira] [Resolved] (KAFKA-7213) NullPointerException during state restoration in kafka streams

2021-03-24 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman resolved KAFKA-7213. --- Resolution: Fixed I think we can close this as the version is quite old now a

[jira] [Resolved] (KAFKA-5256) Non-checkpointed state stores should be deleted before restore

2021-03-24 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-5256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman resolved KAFKA-5256. --- Resolution: Fixed Closing this since the described behavior is now implemente

[jira] [Commented] (KAFKA-12538) Global Threads should be able to be replaced like stream threads

2021-03-24 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17308289#comment-17308289 ] A. Sophie Blee-Goldman commented on KAFKA-12538: Note that this will be

[jira] [Commented] (KAFKA-12540) Sub-key support to avoid unnecessary rekey operations with new key is a compound key of the original key + sub-field

2021-03-24 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17308284#comment-17308284 ] A. Sophie Blee-Goldman commented on KAFKA-12540: Can we close this as a

[jira] [Assigned] (KAFKA-7606) Remove deprecated options from StreamsResetter

2021-03-24 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman reassigned KAFKA-7606: - Assignee: (was: Srinivas Reddy) > Remove deprecated options from Str

[jira] [Commented] (KAFKA-12419) Remove Deprecated APIs of Kafka Streams in 3.0

2021-03-24 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17308274#comment-17308274 ] A. Sophie Blee-Goldman commented on KAFKA-12419: [~guozhang] there are a

[jira] [Commented] (KAFKA-12526) Remove deprecated long ms overloads

2021-03-24 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17308251#comment-17308251 ] A. Sophie Blee-Goldman commented on KAFKA-12526: Cool thanks. I've pinge

[jira] [Commented] (KAFKA-10493) Ktable out-of-order updates are not being ignored

2021-03-24 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17308240#comment-17308240 ] A. Sophie Blee-Goldman commented on KAFKA-10493: What's the status here,

[jira] [Commented] (KAFKA-8531) Change default replication factor config

2021-03-24 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17308238#comment-17308238 ] A. Sophie Blee-Goldman commented on KAFKA-8531: --- Hey [~mjsax], are you plan

[jira] [Commented] (KAFKA-12527) Remove deprecated "PartitionGrouper" interface

2021-03-24 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17308234#comment-17308234 ] A. Sophie Blee-Goldman commented on KAFKA-12527: Seems like a duplicate

[jira] [Assigned] (KAFKA-12527) Remove deprecated "PartitionGrouper" interface

2021-03-24 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman reassigned KAFKA-12527: -- Assignee: Guozhang Wang > Remove deprecated "PartitionGrouper" interf

[jira] [Commented] (KAFKA-12526) Remove deprecated long ms overloads

2021-03-24 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17308233#comment-17308233 ] A. Sophie Blee-Goldman commented on KAFKA-12526: [~guozhang] To clarify,

[jira] [Assigned] (KAFKA-7106) Remove segment/segmentInterval from Window definition

2021-03-24 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman reassigned KAFKA-7106: - Assignee: Guozhang Wang > Remove segment/segmentInterval from Window def

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

2021-03-24 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8784?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17308198#comment-17308198 ] A. Sophie Blee-Goldman commented on KAFKA-8784: --- Hey [~sbellapu], are you s

[jira] [Comment Edited] (KAFKA-10046) Deprecated PartitionGrouper config is ignored

2021-03-24 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17308197#comment-17308197 ] A. Sophie Blee-Goldman edited comment on KAFKA-10046 at 3/24/21, 9:52 PM:

[jira] [Updated] (KAFKA-10046) Deprecated PartitionGrouper config is ignored

2021-03-24 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-10046: --- Fix Version/s: 3.0.0 > Deprecated PartitionGrouper config is ignored > -

[jira] [Commented] (KAFKA-10046) Deprecated PartitionGrouper config is ignored

2021-03-24 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17308197#comment-17308197 ] A. Sophie Blee-Goldman commented on KAFKA-10046: We're removing this con

[jira] [Created] (KAFKA-12547) Drop idempotent updates for repartition operations

2021-03-24 Thread A. Sophie Blee-Goldman (Jira)
A. Sophie Blee-Goldman created KAFKA-12547: -- Summary: Drop idempotent updates for repartition operations Key: KAFKA-12547 URL: https://issues.apache.org/jira/browse/KAFKA-12547 Project: Kafka

[jira] [Created] (KAFKA-12546) Drop idempotent updates for aggregations

2021-03-24 Thread A. Sophie Blee-Goldman (Jira)
A. Sophie Blee-Goldman created KAFKA-12546: -- Summary: Drop idempotent updates for aggregations Key: KAFKA-12546 URL: https://issues.apache.org/jira/browse/KAFKA-12546 Project: Kafka

[jira] [Commented] (KAFKA-9552) Stream should handle OutOfSequence exception thrown from Producer

2021-03-24 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17308175#comment-17308175 ] A. Sophie Blee-Goldman commented on KAFKA-9552: --- Hey guys, what's the curre

[jira] [Assigned] (KAFKA-4327) Move Reset Tool from core to streams

2021-03-24 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-4327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman reassigned KAFKA-4327: - Assignee: (was: Jorge Esteban Quilcate Otoya) > Move Reset Tool from

[jira] [Updated] (KAFKA-9168) Integrate JNI direct buffer support to RocksDBStore

2021-03-23 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-9168: -- Priority: Major (was: Blocker) > Integrate JNI direct buffer support to RocksD

[jira] [Updated] (KAFKA-9168) Integrate JNI direct buffer support to RocksDBStore

2021-03-23 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-9168: -- Issue Type: Improvement (was: Task) > Integrate JNI direct buffer support to R

[jira] [Updated] (KAFKA-9168) Integrate JNI direct buffer support to RocksDBStore

2021-03-23 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-9168: -- Fix Version/s: (was: 3.0.0) > Integrate JNI direct buffer support to RocksD

[jira] [Assigned] (KAFKA-12523) Need to improve handling of TimeoutException when committing offsets

2021-03-22 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman reassigned KAFKA-12523: -- Assignee: A. Sophie Blee-Goldman > Need to improve handling of Timeou

[jira] [Created] (KAFKA-12523) Need to improve handling of TimeoutException when committing offsets

2021-03-22 Thread A. Sophie Blee-Goldman (Jira)
A. Sophie Blee-Goldman created KAFKA-12523: -- Summary: Need to improve handling of TimeoutException when committing offsets Key: KAFKA-12523 URL: https://issues.apache.org/jira/browse/KAFKA-12523

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

2021-03-22 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman resolved KAFKA-8372. --- Resolution: Fixed We can just close this since we removed bulk loading, and t

[jira] [Comment Edited] (KAFKA-12506) Expand AdjustStreamThreadCountTest

2021-03-22 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17306700#comment-17306700 ] A. Sophie Blee-Goldman edited comment on KAFKA-12506 at 3/23/21, 2:29 AM:

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

2021-03-22 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17306700#comment-17306700 ] A. Sophie Blee-Goldman commented on KAFKA-12506: Go for it! Note that I

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

2021-03-22 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman reassigned KAFKA-12506: -- Assignee: Aviral Srivastava > Expand AdjustStreamThreadCountTest > --

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

2021-03-22 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17306698#comment-17306698 ] A. Sophie Blee-Goldman commented on KAFKA-12521: I'll try to poke around

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

2021-03-22 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12521: --- Labels: integration-tests newbie++ (was: integration-tests) > Expand covera

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

2021-03-22 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17306664#comment-17306664 ] A. Sophie Blee-Goldman commented on KAFKA-12472: [~guozhang] what do you

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

2021-03-22 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17306626#comment-17306626 ] A. Sophie Blee-Goldman commented on KAFKA-12472: That sounds good to me!

<    3   4   5   6   7   8   9   10   11   12   >