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

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

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

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

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

[ https://issues.apache.org/jira/browse/KAFKA-12375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17291331#comment-17291331 ] A. Sophie Blee-Goldman commented on KAFKA-12375: Regarding the javax.man

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

[ https://issues.apache.org/jira/browse/KAFKA-12375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17291329#comment-17291329 ] A. Sophie Blee-Goldman commented on KAFKA-12375: Ah, good catch Bruno. W

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

[ https://issues.apache.org/jira/browse/KAFKA-12375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman reassigned KAFKA-12375: -- Assignee: Tomasz Nguyen > ReplaceStreamThread creates a new consumer

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

[ https://issues.apache.org/jira/browse/KAFKA-12375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17291178#comment-17291178 ] A. Sophie Blee-Goldman commented on KAFKA-12375: Possible blocker for 2.

[jira] [Resolved] (KAFKA-12211) NoSuchFileException will be thrown if hasPersistentStores is false when creating stateDir

[ https://issues.apache.org/jira/browse/KAFKA-12211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman resolved KAFKA-12211. Resolution: Fixed > NoSuchFileException will be thrown if hasPersistentSto

[jira] [Reopened] (KAFKA-12211) NoSuchFileException will be thrown if hasPersistentStores is false when creating stateDir

[ https://issues.apache.org/jira/browse/KAFKA-12211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman reopened KAFKA-12211: Just re-opening this ticket while we get the fix merged to 2.6 for the 2.6.2

[jira] [Updated] (KAFKA-12211) NoSuchFileException will be thrown if hasPersistentStores is false when creating stateDir

[ https://issues.apache.org/jira/browse/KAFKA-12211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12211: --- Priority: Minor (was: Major) > NoSuchFileException will be thrown if hasPer

[jira] [Updated] (KAFKA-12211) NoSuchFileException will be thrown if hasPersistentStores is false when creating stateDir

[ https://issues.apache.org/jira/browse/KAFKA-12211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12211: --- Affects Version/s: 2.6.1 > NoSuchFileException will be thrown if hasPersiste

[jira] [Updated] (KAFKA-12211) NoSuchFileException will be thrown if hasPersistentStores is false when creating stateDir

[ https://issues.apache.org/jira/browse/KAFKA-12211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12211: --- Fix Version/s: 2.6.2 > NoSuchFileException will be thrown if hasPersistentSt

[jira] [Commented] (KAFKA-12323) Record timestamps not populated in event

[ https://issues.apache.org/jira/browse/KAFKA-12323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17283378#comment-17283378 ] A. Sophie Blee-Goldman commented on KAFKA-12323: Hey [~abellemare], than

[jira] [Commented] (KAFKA-5146) Kafka Streams: remove compile dependency on connect-json

[ https://issues.apache.org/jira/browse/KAFKA-5146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17282729#comment-17282729 ] A. Sophie Blee-Goldman commented on KAFKA-5146: --- I guess I would lean towar

[jira] [Commented] (KAFKA-12314) Leverage custom comparator for optimized range scans on RocksDB

[ https://issues.apache.org/jira/browse/KAFKA-12314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17282165#comment-17282165 ] A. Sophie Blee-Goldman commented on KAFKA-12314: Hey Sagar, one thing I

[jira] [Commented] (KAFKA-5146) Kafka Streams: remove compile dependency on connect-json

[ https://issues.apache.org/jira/browse/KAFKA-5146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17282162#comment-17282162 ] A. Sophie Blee-Goldman commented on KAFKA-5146: --- I agree, let's definitely

[jira] [Commented] (KAFKA-12314) Leverage custom comparator for optimized range scans on RocksDB

[ https://issues.apache.org/jira/browse/KAFKA-12314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17281502#comment-17281502 ] A. Sophie Blee-Goldman commented on KAFKA-12314: rocksdb has recently me

[jira] [Created] (KAFKA-12314) Leverage custom comparator for optimized range scans on RocksDB

A. Sophie Blee-Goldman created KAFKA-12314: -- Summary: Leverage custom comparator for optimized range scans on RocksDB Key: KAFKA-12314 URL: https://issues.apache.org/jira/browse/KAFKA-12314 P

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

A. Sophie Blee-Goldman created KAFKA-12313: -- Summary: Consider deprecating the default.windowed.serde.inner.class configs Key: KAFKA-12313 URL: https://issues.apache.org/jira/browse/KAFKA-12313

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

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

[jira] [Resolved] (KAFKA-10678) Re-deploying Streams app causes rebalance and task migration

[ https://issues.apache.org/jira/browse/KAFKA-10678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman resolved KAFKA-10678. Assignee: A. Sophie Blee-Goldman Resolution: Fixed Resolved via [htt

[jira] [Updated] (KAFKA-10678) Re-deploying Streams app causes rebalance and task migration

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

[jira] [Closed] (KAFKA-10716) Streams processId is unstable across restarts resulting in task mass migration

[ https://issues.apache.org/jira/browse/KAFKA-10716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman closed KAFKA-10716. -- > Streams processId is unstable across restarts resulting in task mass migration >

[jira] [Resolved] (KAFKA-12279) Kafka 2.7 stream app issue

[ https://issues.apache.org/jira/browse/KAFKA-12279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman resolved KAFKA-12279. Resolution: Not A Bug > Kafka 2.7 stream app issue > -

[jira] [Commented] (KAFKA-12279) Kafka 2.7 stream app issue

[ https://issues.apache.org/jira/browse/KAFKA-12279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17279938#comment-17279938 ] A. Sophie Blee-Goldman commented on KAFKA-12279: Root cause: the source

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

A. Sophie Blee-Goldman created KAFKA-12288: -- Summary: Remove task-level filesystem locks Key: KAFKA-12288 URL: https://issues.apache.org/jira/browse/KAFKA-12288 Project: Kafka Issue

[jira] [Updated] (KAFKA-12279) Kafka 2.7 stream app issue

[ https://issues.apache.org/jira/browse/KAFKA-12279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12279: --- Affects Version/s: 2.7.0 > Kafka 2.7 stream app issue >

[jira] [Updated] (KAFKA-12279) Kafka 2.7 stream app issue

[ https://issues.apache.org/jira/browse/KAFKA-12279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12279: --- Fix Version/s: (was: 2.7.0) > Kafka 2.7 stream app issue > -

[jira] [Updated] (KAFKA-12279) Kafka 2.7 stream app issue

[ https://issues.apache.org/jira/browse/KAFKA-12279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12279: --- Priority: Critical (was: Major) > Kafka 2.7 stream app issue >

[jira] [Commented] (KAFKA-12279) Kafka 2.7 stream app issue

[ https://issues.apache.org/jira/browse/KAFKA-12279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17277604#comment-17277604 ] A. Sophie Blee-Goldman commented on KAFKA-12279: Hi [~pbiradar], thanks

[jira] [Updated] (KAFKA-12279) Kafka 2.7 stream app issue

[ https://issues.apache.org/jira/browse/KAFKA-12279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12279: --- Component/s: streams > Kafka 2.7 stream app issue >

[jira] [Updated] (KAFKA-10362) When resuming Streams active task with EOS, the checkpoint file should be deleted

[ https://issues.apache.org/jira/browse/KAFKA-10362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-10362: --- Fix Version/s: 2.6.2 > When resuming Streams active task with EOS, the check

[jira] [Closed] (KAFKA-10867) Implement improved semantics using the ConsumerRecords meta

[ https://issues.apache.org/jira/browse/KAFKA-10867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman closed KAFKA-10867. -- > Implement improved semantics using the ConsumerRecords meta > --

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

[ https://issues.apache.org/jira/browse/KAFKA-9176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman closed KAFKA-9176. - > Flaky test failure: > OptimizedKTableIntegrationTest.shouldApplyUpdatesToStandbyS

[jira] [Closed] (KAFKA-12190) Failure on Windows due to an UnsupportedOperationException when StateDirectory sets file permissions

[ https://issues.apache.org/jira/browse/KAFKA-12190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman closed KAFKA-12190. -- > Failure on Windows due to an UnsupportedOperationException when > StateDirector

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

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

[jira] [Updated] (KAFKA-10391) Streams should overwrite checkpoint excluding corrupted partitions

[ https://issues.apache.org/jira/browse/KAFKA-10391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-10391: --- Affects Version/s: 2.7.0 > Streams should overwrite checkpoint excluding cor

[jira] [Updated] (KAFKA-10793) Race condition in FindCoordinatorFuture permanently severs connection to group coordinator

[ https://issues.apache.org/jira/browse/KAFKA-10793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-10793: --- Fix Version/s: 2.6.2 > Race condition in FindCoordinatorFuture permanently s

[jira] [Updated] (KAFKA-8930) MM2 documentation

[ https://issues.apache.org/jira/browse/KAFKA-8930?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-8930: -- Fix Version/s: (was: 2.6.0) 2.6.2 > MM2 documentation >

[jira] [Commented] (KAFKA-8930) MM2 documentation

[ https://issues.apache.org/jira/browse/KAFKA-8930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17275292#comment-17275292 ] A. Sophie Blee-Goldman commented on KAFKA-8930: --- Hey [~miguno] I changed th

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

[ https://issues.apache.org/jira/browse/KAFKA-8940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-8940: -- Description: The test does not properly account for windowing. See this comment

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

[ https://issues.apache.org/jira/browse/KAFKA-8940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-8940: -- Description: The test does not properly account for windowing. See [this commen

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

[ https://issues.apache.org/jira/browse/KAFKA-8940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-8940: -- Description: The test does not properly account for windowing. See (was: I los

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

[ https://issues.apache.org/jira/browse/KAFKA-8940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-8940: -- Labels: flaky-test newbie++ (was: flaky-test) > Flaky Test SmokeTestDriverInte

[jira] [Commented] (KAFKA-12169) Consumer can not know paritions chage when client leader restart with static membership protocol

[ https://issues.apache.org/jira/browse/KAFKA-12169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17273158#comment-17273158 ] A. Sophie Blee-Goldman commented on KAFKA-12169: hey [~boyang] any thoug

[jira] [Updated] (KAFKA-10716) Streams processId is unstable across restarts resulting in task mass migration

[ https://issues.apache.org/jira/browse/KAFKA-10716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-10716: --- Priority: Critical (was: Major) > Streams processId is unstable across rest

[jira] [Updated] (KAFKA-10716) Streams processId is unstable across restarts resulting in task mass migration

[ https://issues.apache.org/jira/browse/KAFKA-10716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-10716: --- Fix Version/s: 2.6.2 > Streams processId is unstable across restarts resulti

[jira] [Resolved] (KAFKA-10793) Race condition in FindCoordinatorFuture permanently severs connection to group coordinator

[ https://issues.apache.org/jira/browse/KAFKA-10793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman resolved KAFKA-10793. Fix Version/s: 2.7.1 Resolution: Fixed > Race condition in FindCoor

[jira] [Updated] (KAFKA-10716) Streams processId is unstable across restarts resulting in task mass migration

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

[jira] [Assigned] (KAFKA-10716) Streams processId is unstable across restarts resulting in task mass migration

[ https://issues.apache.org/jira/browse/KAFKA-10716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman reassigned KAFKA-10716: -- Assignee: A. Sophie Blee-Goldman > Streams processId is unstable acro

[jira] [Updated] (KAFKA-12190) Failure on Windows due to an UnsupportedOperationException when StateDirectory sets file permissions

[ https://issues.apache.org/jira/browse/KAFKA-12190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12190: --- Fix Version/s: 2.6.2 > Failure on Windows due to an UnsupportedOperationExce

[jira] [Commented] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17272388#comment-17272388 ] A. Sophie Blee-Goldman commented on KAFKA-8803: --- Ah, yeah, then it sounds l

[jira] [Commented] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17271767#comment-17271767 ] A. Sophie Blee-Goldman commented on KAFKA-8803: --- Hey [~nvolynets] thanks fo

[jira] [Commented] (KAFKA-10847) Avoid spurious left/outer join results in stream-stream join

[ https://issues.apache.org/jira/browse/KAFKA-10847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17271698#comment-17271698 ] A. Sophie Blee-Goldman commented on KAFKA-10847: Hey [~spena] – to answe

[jira] [Updated] (KAFKA-12190) Failure on Windows due to an UnsupportedOperationException when StateDirectory sets file permissions

[ https://issues.apache.org/jira/browse/KAFKA-12190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12190: --- Affects Version/s: (was: 2.7.1) 2.7.0 > Failure o

[jira] [Updated] (KAFKA-12219) Potential race condition in InMemoryKeyValueStore

[ https://issues.apache.org/jira/browse/KAFKA-12219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12219: --- Fix Version/s: 2.7.1 > Potential race condition in InMemoryKeyValueStore > -

[jira] [Updated] (KAFKA-12219) Potential race condition in InMemoryKeyValueStore

[ https://issues.apache.org/jira/browse/KAFKA-12219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12219: --- Description: With KAFKA-8802 (included in [2.4.0 release|https://downloads.a

[jira] [Updated] (KAFKA-12219) Potential race condition in InMemoryKeyValueStore

[ https://issues.apache.org/jira/browse/KAFKA-12219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12219: --- Affects Version/s: 2.7.0 > Potential race condition in InMemoryKeyValueStore

[jira] [Updated] (KAFKA-12190) Failure on Windows due to an UnsupportedOperationException when StateDirectory sets file permissions

[ https://issues.apache.org/jira/browse/KAFKA-12190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12190: --- Fix Version/s: 2.8.0 > Failure on Windows due to an UnsupportedOperationExce

[jira] [Commented] (KAFKA-12190) Failure on Windows due to an UnsupportedOperationException when StateDirectory sets file permissions

[ https://issues.apache.org/jira/browse/KAFKA-12190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17264398#comment-17264398 ] A. Sophie Blee-Goldman commented on KAFKA-12190: Hey [~awilkinson], than

[jira] [Updated] (KAFKA-12190) Failure on Windows due to an UnsupportedOperationException when StateDirectory sets file permissions

[ https://issues.apache.org/jira/browse/KAFKA-12190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12190: --- Priority: Critical (was: Major) > Failure on Windows due to an UnsupportedO

[jira] [Updated] (KAFKA-12190) Failure on Windows due to an UnsupportedOperationException when StateDirectory sets file permissions

[ https://issues.apache.org/jira/browse/KAFKA-12190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12190: --- Component/s: streams > Failure on Windows due to an UnsupportedOperationExce

[jira] [Commented] (KAFKA-12184) Once the Error Classification is better update the default streams uncaught exception handler to replace threads

[ https://issues.apache.org/jira/browse/KAFKA-12184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17263776#comment-17263776 ] A. Sophie Blee-Goldman commented on KAFKA-12184: Should we mark the "Fix

[jira] [Commented] (KAFKA-10862) kafak stream consume from the earliest by default

[ https://issues.apache.org/jira/browse/KAFKA-10862?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17250720#comment-17250720 ] A. Sophie Blee-Goldman commented on KAFKA-10862: Hey [~rebekkaxi], you'r

[jira] [Commented] (KAFKA-10772) java.lang.IllegalStateException: There are insufficient bytes available to read assignment from the sync-group response (actual byte size 0)

[ https://issues.apache.org/jira/browse/KAFKA-10772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17245587#comment-17245587 ] A. Sophie Blee-Goldman commented on KAFKA-10772: Specifically, I'm looki

[jira] [Commented] (KAFKA-10772) java.lang.IllegalStateException: There are insufficient bytes available to read assignment from the sync-group response (actual byte size 0)

[ https://issues.apache.org/jira/browse/KAFKA-10772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17245586#comment-17245586 ] A. Sophie Blee-Goldman commented on KAFKA-10772: Hey [~lkokhreidze] and/

[jira] [Commented] (KAFKA-10772) java.lang.IllegalStateException: There are insufficient bytes available to read assignment from the sync-group response (actual byte size 0)

[ https://issues.apache.org/jira/browse/KAFKA-10772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17242025#comment-17242025 ] A. Sophie Blee-Goldman commented on KAFKA-10772: Hm, the leadership chan

[jira] [Comment Edited] (KAFKA-10793) Race condition in FindCoordinatorFuture permanently severs connection to group coordinator

[ https://issues.apache.org/jira/browse/KAFKA-10793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17241976#comment-17241976 ] A. Sophie Blee-Goldman edited comment on KAFKA-10793 at 12/2/20, 2:30 AM:

[jira] [Comment Edited] (KAFKA-10793) Race condition in FindCoordinatorFuture permanently severs connection to group coordinator

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

[jira] [Commented] (KAFKA-10793) Race condition in FindCoordinatorFuture permanently severs connection to group coordinator

[ https://issues.apache.org/jira/browse/KAFKA-10793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17241987#comment-17241987 ] A. Sophie Blee-Goldman commented on KAFKA-10793: So that's our best gues

[jira] [Comment Edited] (KAFKA-10793) Race condition in FindCoordinatorFuture permanently severs connection to group coordinator

[ https://issues.apache.org/jira/browse/KAFKA-10793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17241976#comment-17241976 ] A. Sophie Blee-Goldman edited comment on KAFKA-10793 at 12/2/20, 1:37 AM:

[jira] [Comment Edited] (KAFKA-10793) Race condition in FindCoordinatorFuture permanently severs connection to group coordinator

[ https://issues.apache.org/jira/browse/KAFKA-10793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17241976#comment-17241976 ] A. Sophie Blee-Goldman edited comment on KAFKA-10793 at 12/2/20, 1:37 AM:

[jira] [Comment Edited] (KAFKA-10793) Race condition in FindCoordinatorFuture permanently severs connection to group coordinator

[ https://issues.apache.org/jira/browse/KAFKA-10793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17241976#comment-17241976 ] A. Sophie Blee-Goldman edited comment on KAFKA-10793 at 12/2/20, 1:37 AM:

[jira] [Commented] (KAFKA-10793) Race condition in FindCoordinatorFuture permanently severs connection to group coordinator

[ https://issues.apache.org/jira/browse/KAFKA-10793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17241976#comment-17241976 ] A. Sophie Blee-Goldman commented on KAFKA-10793: At this point we can on

[jira] [Created] (KAFKA-10793) Race condition in FindCoordinatorFuture permanently severs connection to group coordinator

A. Sophie Blee-Goldman created KAFKA-10793: -- Summary: Race condition in FindCoordinatorFuture permanently severs connection to group coordinator Key: KAFKA-10793 URL: https://issues.apache.org/jira/browse

[jira] [Commented] (KAFKA-10772) java.lang.IllegalStateException: There are insufficient bytes available to read assignment from the sync-group response (actual byte size 0)

[ https://issues.apache.org/jira/browse/KAFKA-10772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17241814#comment-17241814 ] A. Sophie Blee-Goldman commented on KAFKA-10772: Hey [~lkokhreidze], tha

[jira] [Updated] (KAFKA-10758) Kafka Streams consuming from a pattern goes to PENDING_SHUTDOWN when adding a new topic

[ https://issues.apache.org/jira/browse/KAFKA-10758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-10758: --- Fix Version/s: 2.6.1 2.7.0 > Kafka Streams consuming from

[jira] [Updated] (KAFKA-10758) Kafka Streams consuming from a pattern goes to PENDING_SHUTDOWN when adding a new topic

[ https://issues.apache.org/jira/browse/KAFKA-10758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-10758: --- Priority: Blocker (was: Major) > Kafka Streams consuming from a pattern goe

[jira] [Commented] (KAFKA-10758) Kafka Streams consuming from a pattern goes to PENDING_SHUTDOWN when adding a new topic

[ https://issues.apache.org/jira/browse/KAFKA-10758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17237778#comment-17237778 ] A. Sophie Blee-Goldman commented on KAFKA-10758: Hey [~davideicardi], th

[jira] [Assigned] (KAFKA-10758) Kafka Streams consuming from a pattern goes to PENDING_SHUTDOWN when adding a new topic

[ https://issues.apache.org/jira/browse/KAFKA-10758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman reassigned KAFKA-10758: -- Assignee: A. Sophie Blee-Goldman > Kafka Streams consuming from a pat

[jira] [Commented] (KAFKA-10643) Static membership - repetitive PreparingRebalance with updating metadata for member reason

[ https://issues.apache.org/jira/browse/KAFKA-10643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17237660#comment-17237660 ] A. Sophie Blee-Goldman commented on KAFKA-10643: Sorry yeah I meant debu

[jira] [Commented] (KAFKA-10643) Static membership - repetitive PreparingRebalance with updating metadata for member reason

[ https://issues.apache.org/jira/browse/KAFKA-10643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17236547#comment-17236547 ] A. Sophie Blee-Goldman commented on KAFKA-10643: Hey [~eran-levy] Thank

[jira] [Resolved] (KAFKA-4748) Need a way to shutdown all workers in a Streams application at the same time

[ https://issues.apache.org/jira/browse/KAFKA-4748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman resolved KAFKA-4748. --- Resolution: Fixed > Need a way to shutdown all workers in a Streams applicati

[jira] [Reopened] (KAFKA-10500) Add API to Start and Stop Stream Threads

[ https://issues.apache.org/jira/browse/KAFKA-10500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman reopened KAFKA-10500: > Add API to Start and Stop Stream Threads > -

[jira] [Updated] (KAFKA-4748) Need a way to shutdown all workers in a Streams application at the same time

[ https://issues.apache.org/jira/browse/KAFKA-4748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-4748: -- Fix Version/s: 2.8.0 > Need a way to shutdown all workers in a Streams applicat

[jira] [Commented] (KAFKA-6943) Have option to shutdown KS cleanly if any threads crashes, or if all threads crash

[ https://issues.apache.org/jira/browse/KAFKA-6943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235069#comment-17235069 ] A. Sophie Blee-Goldman commented on KAFKA-6943: --- Resolved via https://githu

[jira] [Updated] (KAFKA-6943) Have option to shutdown KS cleanly if any threads crashes, or if all threads crash

[ https://issues.apache.org/jira/browse/KAFKA-6943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-6943: -- Fix Version/s: 2.8.0 > Have option to shutdown KS cleanly if any threads crashe

[jira] [Resolved] (KAFKA-6943) Have option to shutdown KS cleanly if any threads crashes, or if all threads crash

[ https://issues.apache.org/jira/browse/KAFKA-6943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman resolved KAFKA-6943. --- Resolution: Fixed > Have option to shutdown KS cleanly if any threads crashes

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

[ https://issues.apache.org/jira/browse/KAFKA-10721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17231904#comment-17231904 ] A. Sophie Blee-Goldman commented on KAFKA-10721: I agree. However, there

[jira] [Resolved] (KAFKA-7107) Ability to configure state store for JoinWindows in KStream-KStream join

[ https://issues.apache.org/jira/browse/KAFKA-7107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman resolved KAFKA-7107. --- Resolution: Duplicate > Ability to configure state store for JoinWindows in K

[jira] [Updated] (KAFKA-6687) Allow to read a topic multiple times

[ https://issues.apache.org/jira/browse/KAFKA-6687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-6687: -- Fix Version/s: 2.8.0 > Allow to read a topic multiple times > -

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

A. Sophie Blee-Goldman created KAFKA-10721: -- Summary: Rewrite topology to allow for overlapping unequal topic subscriptions Key: KAFKA-10721 URL: https://issues.apache.org/jira/browse/KAFKA-10721

[jira] [Updated] (KAFKA-10705) Avoid World Readable RocksDB

[ https://issues.apache.org/jira/browse/KAFKA-10705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-10705: --- Fix Version/s: 2.6.2 > Avoid World Readable RocksDB > --

[jira] [Resolved] (KAFKA-10705) Avoid World Readable RocksDB

[ https://issues.apache.org/jira/browse/KAFKA-10705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman resolved KAFKA-10705. Resolution: Fixed > Avoid World Readable RocksDB > ---

[jira] [Updated] (KAFKA-10705) Avoid World Readable RocksDB

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

[jira] [Commented] (KAFKA-10405) Flaky Test org.apache.kafka.streams.integration.PurgeRepartitionTopicIntegrationTest.shouldRestoreState

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

[jira] [Commented] (KAFKA-10716) Streams processId is unstable across restarts resulting in task mass migration

[ https://issues.apache.org/jira/browse/KAFKA-10716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17231116#comment-17231116 ] A. Sophie Blee-Goldman commented on KAFKA-10716: There are a few possibl

[jira] [Commented] (KAFKA-10678) Re-deploying Streams app causes rebalance and task migration

[ https://issues.apache.org/jira/browse/KAFKA-10678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17231084#comment-17231084 ] A. Sophie Blee-Goldman commented on KAFKA-10678: Yeah, it seems like any

[jira] [Created] (KAFKA-10716) Streams processId is unstable across restarts resulting in task mass migration

A. Sophie Blee-Goldman created KAFKA-10716: -- Summary: Streams processId is unstable across restarts resulting in task mass migration Key: KAFKA-10716 URL: https://issues.apache.org/jira/browse/KAFKA-10716

[jira] [Commented] (KAFKA-10643) Static membership - repetitive PreparingRebalance with updating metadata for member reason

[ https://issues.apache.org/jira/browse/KAFKA-10643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17229574#comment-17229574 ] A. Sophie Blee-Goldman commented on KAFKA-10643: Ok, it sounds like mayb

[jira] [Commented] (KAFKA-10689) Assignor can't determine number of partitions on FJK with upstream windowed repartition

[ https://issues.apache.org/jira/browse/KAFKA-10689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17227077#comment-17227077 ] A. Sophie Blee-Goldman commented on KAFKA-10689: It's a pretty obnoxious

<    5   6   7   8   9   10   11   >