[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=17225073#comment-17225073 ] A. Sophie Blee-Goldman commented on KAFKA-10643: Can you be a little more specific about

[jira] [Created] (KAFKA-10665) Flaky Test StreamTableJoinTopologyOptimizationIntegrationTest.shouldDoStreamTableJoinWithDifferentNumberOfPartitions[Optimization = all]

A. Sophie Blee-Goldman created KAFKA-10665: -- Summary: Flaky Test StreamTableJoinTopologyOptimizationIntegrationTest.shouldDoStreamTableJoinWithDifferentNumberOfPartitions[Optimization = all] Key: KAFKA-10665

[jira] [Created] (KAFKA-10664) Streams fails to overwrite corrupted offsets leading to infinite OffsetOutOfRangeException loop

A. Sophie Blee-Goldman created KAFKA-10664: -- Summary: Streams fails to overwrite corrupted offsets leading to infinite OffsetOutOfRangeException loop Key: KAFKA-10664 URL:

[jira] [Updated] (KAFKA-10651) Assignor reports offsets from uninitialized task

[ https://issues.apache.org/jira/browse/KAFKA-10651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-10651: --- Description: In KIP-441, the new HA assignor makes an informed decision

[jira] [Assigned] (KAFKA-10651) Assignor reports offsets from uninitialized task

[ https://issues.apache.org/jira/browse/KAFKA-10651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman reassigned KAFKA-10651: -- Assignee: A. Sophie Blee-Goldman > Assignor reports offsets from

[jira] [Created] (KAFKA-10651) Assignor reports offsets from uninitialized task

A. Sophie Blee-Goldman created KAFKA-10651: -- Summary: Assignor reports offsets from uninitialized task Key: KAFKA-10651 URL: https://issues.apache.org/jira/browse/KAFKA-10651 Project: Kafka

[jira] [Commented] (KAFKA-10633) Constant probing rebalances in Streams 2.6

[ https://issues.apache.org/jira/browse/KAFKA-10633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17219963#comment-17219963 ] A. Sophie Blee-Goldman commented on KAFKA-10633: The issue with directory contents being

[jira] [Commented] (KAFKA-10633) Constant probing rebalances in Streams 2.6

[ https://issues.apache.org/jira/browse/KAFKA-10633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17219861#comment-17219861 ] A. Sophie Blee-Goldman commented on KAFKA-10633: A thread should always reset its

[jira] [Commented] (KAFKA-10633) Constant probing rebalances in Streams 2.6

[ https://issues.apache.org/jira/browse/KAFKA-10633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17219859#comment-17219859 ] A. Sophie Blee-Goldman commented on KAFKA-10633: I'm like 99% sure this will turn out to

[jira] [Commented] (KAFKA-10616) StreamThread killed by "IllegalStateException: The processor is already closed"

[ https://issues.apache.org/jira/browse/KAFKA-10616?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17217261#comment-17217261 ] A. Sophie Blee-Goldman commented on KAFKA-10616: By the way, we should actually fix this

[jira] [Commented] (KAFKA-10616) StreamThread killed by "IllegalStateException: The processor is already closed"

[ https://issues.apache.org/jira/browse/KAFKA-10616?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17217258#comment-17217258 ] A. Sophie Blee-Goldman commented on KAFKA-10616: I spoke with [~guozhang]  earlier and

[jira] [Assigned] (KAFKA-10616) StreamThread killed by "IllegalStateException: The processor is already closed"

[ https://issues.apache.org/jira/browse/KAFKA-10616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman reassigned KAFKA-10616: -- Assignee: Guozhang Wang > StreamThread killed by

[jira] [Created] (KAFKA-10616) StreamThread killed by "IllegalStateException: The processor is already closed"

Sophie Blee-Goldman created KAFKA-10616: --- Summary: StreamThread killed by "IllegalStateException: The processor is already closed" Key: KAFKA-10616 URL: https://issues.apache.org/jira/browse/KAFKA-10616

[jira] [Assigned] (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 ] Sophie Blee-Goldman reassigned KAFKA-6687: -- Assignee: Sophie Blee-Goldman > Allow to read a topic multiple times >

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

[ https://issues.apache.org/jira/browse/KAFKA-8940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman reopened KAFKA-8940: Assignee: (was: Guozhang Wang) This failed again with {code:java} min fail:

[jira] [Updated] (KAFKA-9126) Extend `StreamJoined` to allow more store configs

[ https://issues.apache.org/jira/browse/KAFKA-9126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9126: --- Labels: needs-kip newbie newbie++ (was: needs-kip) > Extend `StreamJoined` to allow

[jira] [Commented] (KAFKA-10200) MockProcessorContext doesn't work with WindowStores

[ https://issues.apache.org/jira/browse/KAFKA-10200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17211347#comment-17211347 ] Sophie Blee-Goldman commented on KAFKA-10200: - [~vvcephei] can we resolve this ticket or was

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

[ https://issues.apache.org/jira/browse/KAFKA-7271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17211295#comment-17211295 ] Sophie Blee-Goldman commented on KAFKA-7271: Realistically, no. Downgraded to critical and

[jira] [Commented] (KAFKA-10417) suppress() with cogroup() throws ClassCastException

[ https://issues.apache.org/jira/browse/KAFKA-10417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17211293#comment-17211293 ] Sophie Blee-Goldman commented on KAFKA-10417: - [~RensGroothuijsen] would you be interested

[jira] [Commented] (KAFKA-10559) Don't shutdown the entire app upon TimeoutException during internal topic validation

[ https://issues.apache.org/jira/browse/KAFKA-10559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17211285#comment-17211285 ] Sophie Blee-Goldman commented on KAFKA-10559: - Ah thanks Bill, yeah please open it against

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

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

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

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

[jira] [Commented] (KAFKA-10555) Improve client state machine

[ https://issues.apache.org/jira/browse/KAFKA-10555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17210606#comment-17210606 ] Sophie Blee-Goldman commented on KAFKA-10555: - > This, it won't be possible to add new

[jira] [Commented] (KAFKA-10559) Don't shutdown the entire app upon TimeoutException during internal topic validation

[ https://issues.apache.org/jira/browse/KAFKA-10559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17209929#comment-17209929 ] Sophie Blee-Goldman commented on KAFKA-10559: - Exactly, just rethrow the TimeoutException.

[jira] [Updated] (KAFKA-10579) Flaky test connect.integration.InternalTopicsIntegrationTest.testStartWhenInternalTopicsCreatedManuallyWithCompactForBrokersDefaultCleanupPolicy

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

[jira] [Created] (KAFKA-10579) Flaky test connect.integration.InternalTopicsIntegrationTest.testStartWhenInternalTopicsCreatedManuallyWithCompactForBrokersDefaultCleanupPolicy

Sophie Blee-Goldman created KAFKA-10579: --- Summary: Flaky test connect.integration.InternalTopicsIntegrationTest.testStartWhenInternalTopicsCreatedManuallyWithCompactForBrokersDefaultCleanupPolicy Key: KAFKA-10579

[jira] [Commented] (KAFKA-9831) Failing test: EosIntegrationTest.shouldNotViolateEosIfOneTaskFailsWithState[exactly_once_beta]

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

[jira] [Commented] (KAFKA-5998) /.checkpoint.tmp Not found exception

[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17209006#comment-17209006 ] Sophie Blee-Goldman commented on KAFKA-5998: Yeah I think both of those (running with shared

[jira] [Commented] (KAFKA-10520) InitProducerId may be blocked if least loaded node is not ready to send

[ https://issues.apache.org/jira/browse/KAFKA-10520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17208995#comment-17208995 ] Sophie Blee-Goldman commented on KAFKA-10520: - Hey [~rsivaram], is this something we can get

[jira] [Commented] (KAFKA-5998) /.checkpoint.tmp Not found exception

[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17208316#comment-17208316 ] Sophie Blee-Goldman commented on KAFKA-5998: [~sandeep.lakdaw...@gmail.com] are you running

[jira] [Assigned] (KAFKA-10559) Don't shutdown the entire app upon TimeoutException during internal topic validation

[ https://issues.apache.org/jira/browse/KAFKA-10559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman reassigned KAFKA-10559: --- Assignee: Sagar Rao > Don't shutdown the entire app upon TimeoutException

[jira] [Commented] (KAFKA-10559) Don't shutdown the entire app upon TimeoutException during internal topic validation

[ https://issues.apache.org/jira/browse/KAFKA-10559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17208257#comment-17208257 ] Sophie Blee-Goldman commented on KAFKA-10559: - [~sagarrao] Yeah, go ahead! This should be a

[jira] [Commented] (KAFKA-10555) Improve client state machine

[ https://issues.apache.org/jira/browse/KAFKA-10555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17208231#comment-17208231 ] Sophie Blee-Goldman commented on KAFKA-10555: - Just to clarify, I do agree with Matthias

[jira] [Updated] (KAFKA-7334) Suggest changing config for state.dir in case of FileNotFoundException

[ https://issues.apache.org/jira/browse/KAFKA-7334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-7334: --- Labels: newbie (was: ) > Suggest changing config for state.dir in case of

[jira] [Updated] (KAFKA-10564) Continuous logging about deleting obsolete state directories

[ https://issues.apache.org/jira/browse/KAFKA-10564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-10564: Fix Version/s: 2.6.1 2.7.0 > Continuous logging about deleting

[jira] [Commented] (KAFKA-10555) Improve client state machine

[ https://issues.apache.org/jira/browse/KAFKA-10555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17205740#comment-17205740 ] Sophie Blee-Goldman commented on KAFKA-10555: - I was also thinking we should not transit to

[jira] [Commented] (KAFKA-10563) Make sure task directories don't remain locked by dead threads

[ https://issues.apache.org/jira/browse/KAFKA-10563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17205723#comment-17205723 ] Sophie Blee-Goldman commented on KAFKA-10563: - Listed the Fix Version as 2.7, but I think

[jira] [Created] (KAFKA-10563) Make sure task directories don't remain locked by dead threads

Sophie Blee-Goldman created KAFKA-10563: --- Summary: Make sure task directories don't remain locked by dead threads Key: KAFKA-10563 URL: https://issues.apache.org/jira/browse/KAFKA-10563

[jira] [Created] (KAFKA-10559) Don't shutdown the entire app upon TimeoutException during internal topic validation

Sophie Blee-Goldman created KAFKA-10559: --- Summary: Don't shutdown the entire app upon TimeoutException during internal topic validation Key: KAFKA-10559 URL:

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

[ https://issues.apache.org/jira/browse/KAFKA-10455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman reassigned KAFKA-10455: --- Assignee: Leah Thomas > Probing rebalances are not guaranteed to be

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

[ https://issues.apache.org/jira/browse/KAFKA-9846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9846: --- Fix Version/s: (was: 2.7.0) 2.6.0 > Race condition can lead

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

[ 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] [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=17196553#comment-17196553 ] Sophie Blee-Goldman commented on KAFKA-10405: - Same error as above – 

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

[ https://issues.apache.org/jira/browse/KAFKA-10264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17196428#comment-17196428 ] Sophie Blee-Goldman commented on KAFKA-10264: - Go for it > Flaky Test

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

[ https://issues.apache.org/jira/browse/KAFKA-6127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17194565#comment-17194565 ] Sophie Blee-Goldman edited comment on KAFKA-6127 at 9/11/20, 11:47 PM:

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

[ https://issues.apache.org/jira/browse/KAFKA-6127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17194565#comment-17194565 ] Sophie Blee-Goldman commented on KAFKA-6127: [~guozhang] any thoughts on this? You probably

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

[ https://issues.apache.org/jira/browse/KAFKA-6127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17194543#comment-17194543 ] Sophie Blee-Goldman commented on KAFKA-6127: [~mjsax] is this ticket still relevant? I didn't

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

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

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

[ https://issues.apache.org/jira/browse/KAFKA-10455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17194469#comment-17194469 ] Sophie Blee-Goldman commented on KAFKA-10455: - Yeah, I think you're touching on a related

[jira] [Commented] (KAFKA-10134) High CPU issue during rebalance in Kafka consumer after upgrading to 2.5

[ https://issues.apache.org/jira/browse/KAFKA-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17192513#comment-17192513 ] Sophie Blee-Goldman commented on KAFKA-10134: - Hey [~davispw], It looks like you might have

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

[ https://issues.apache.org/jira/browse/KAFKA-10455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17190338#comment-17190338 ] Sophie Blee-Goldman commented on KAFKA-10455: - [~guozhang] if the triggering member has only

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

[ https://issues.apache.org/jira/browse/KAFKA-10455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17188864#comment-17188864 ] Sophie Blee-Goldman commented on KAFKA-10455: - Yeah ok, that sounds reasonable. Initially I

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

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] [Commented] (KAFKA-10366) TimeWindowedDeserializer doesn't allow users to set a custom window size

[ https://issues.apache.org/jira/browse/KAFKA-10366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17188115#comment-17188115 ] Sophie Blee-Goldman commented on KAFKA-10366: - Yeah thanks for tracking that down [~mjsax].

[jira] [Commented] (KAFKA-10410) OnRestoreStart disappeared from StateRestoreCallback in 2.6.0 and reappeared in a useless place

[ https://issues.apache.org/jira/browse/KAFKA-10410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17185511#comment-17185511 ] Sophie Blee-Goldman commented on KAFKA-10410: - It's hard to say without knowing specifically

[jira] [Comment Edited] (KAFKA-10434) Remove deprecated methods on WindowStore

[ https://issues.apache.org/jira/browse/KAFKA-10434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17184804#comment-17184804 ] Sophie Blee-Goldman edited comment on KAFKA-10434 at 8/26/20, 12:20 AM:

[jira] [Commented] (KAFKA-10434) Remove deprecated methods on WindowStore

[ https://issues.apache.org/jira/browse/KAFKA-10434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17184804#comment-17184804 ] Sophie Blee-Goldman commented on KAFKA-10434: - Also, if there are performance concerns with

[jira] [Commented] (KAFKA-10434) Remove deprecated methods on WindowStore

[ https://issues.apache.org/jira/browse/KAFKA-10434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17184778#comment-17184778 ] Sophie Blee-Goldman commented on KAFKA-10434: - Gotcha. Then can we at least put this

[jira] [Commented] (KAFKA-10357) Handle accidental deletion of repartition-topics as exceptional failure

[ https://issues.apache.org/jira/browse/KAFKA-10357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17183630#comment-17183630 ] Sophie Blee-Goldman commented on KAFKA-10357: - Cool. I agree, KAFKA-3370 would (and still

[jira] [Commented] (KAFKA-10357) Handle accidental deletion of repartition-topics as exceptional failure

[ https://issues.apache.org/jira/browse/KAFKA-10357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17182142#comment-17182142 ] Sophie Blee-Goldman commented on KAFKA-10357: - I'm a little less concerned about exposing

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

[ 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

[jira] [Updated] (KAFKA-10409) Refactor Kafka Streams RocksDb iterators

[ https://issues.apache.org/jira/browse/KAFKA-10409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-10409: Component/s: streams > Refactor Kafka Streams RocksDb iterators >

[jira] [Commented] (KAFKA-10406) Table data doesn't wrap around in fixed-width columns and gets hidden

[ https://issues.apache.org/jira/browse/KAFKA-10406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17179154#comment-17179154 ] Sophie Blee-Goldman commented on KAFKA-10406: - I think the link in the ticket description

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

[ https://issues.apache.org/jira/browse/KAFKA-10395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman reassigned KAFKA-10395: --- Assignee: Sophie Blee-Goldman > TopologyTestDriver does not work with

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

[ https://issues.apache.org/jira/browse/KAFKA-10395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17176675#comment-17176675 ] Sophie Blee-Goldman commented on KAFKA-10395: - The only really holistic solution I can think

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

[ https://issues.apache.org/jira/browse/KAFKA-10395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17176665#comment-17176665 ] Sophie Blee-Goldman edited comment on KAFKA-10395 at 8/13/20, 12:41 AM:

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

[ https://issues.apache.org/jira/browse/KAFKA-10395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17176665#comment-17176665 ] Sophie Blee-Goldman edited comment on KAFKA-10395 at 8/13/20, 12:36 AM:

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

[ https://issues.apache.org/jira/browse/KAFKA-10395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-10395: Labels: test-framework (was: needs-kip test-framework) > TopologyTestDriver does

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

[ https://issues.apache.org/jira/browse/KAFKA-10395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17176665#comment-17176665 ] Sophie Blee-Goldman commented on KAFKA-10395: - I think we could just modify the

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

[ https://issues.apache.org/jira/browse/KAFKA-10395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-10395: Labels: needs-kip test-framework (was: test-framework) > TopologyTestDriver does

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

[ https://issues.apache.org/jira/browse/KAFKA-10395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-10395: Labels: test-framework (was: ) > TopologyTestDriver does not work with dynamic

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

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:

[jira] [Updated] (KAFKA-10284) Group membership update due to static member rejoin should be persisted

[ https://issues.apache.org/jira/browse/KAFKA-10284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-10284: Priority: Critical (was: Major) > Group membership update due to static member

[jira] [Updated] (KAFKA-10284) Group membership update due to static member rejoin should be persisted

[ https://issues.apache.org/jira/browse/KAFKA-10284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-10284: Fix Version/s: (was: 2.6.1) > Group membership update due to static member

[jira] [Commented] (KAFKA-10357) Handle accidental deletion of repartition-topics as exceptional failure

[ https://issues.apache.org/jira/browse/KAFKA-10357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17176535#comment-17176535 ] Sophie Blee-Goldman commented on KAFKA-10357: - I think the elegant way to shutdown the whole

[jira] [Commented] (KAFKA-10284) Group membership update due to static member rejoin should be persisted

[ https://issues.apache.org/jira/browse/KAFKA-10284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17175905#comment-17175905 ] Sophie Blee-Goldman commented on KAFKA-10284: - [~bchen225242] [~hachikuji] Is this a

[jira] [Commented] (KAFKA-10357) Handle accidental deletion of repartition-topics as exceptional failure

[ https://issues.apache.org/jira/browse/KAFKA-10357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17174986#comment-17174986 ] Sophie Blee-Goldman commented on KAFKA-10357: - How are we going to handle

[jira] [Commented] (KAFKA-10366) TimeWindowedDeserializer doesn't allow users to set a custom window size

[ https://issues.apache.org/jira/browse/KAFKA-10366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17172633#comment-17172633 ] Sophie Blee-Goldman commented on KAFKA-10366: - Yeah, there are two related problems. The

[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 ] Sophie Blee-Goldman updated KAFKA-10362: Affects Version/s: 2.6.0 > When resuming Streams active task with EOS, the

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

[ https://issues.apache.org/jira/browse/KAFKA-10186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17171078#comment-17171078 ] Sophie Blee-Goldman commented on KAFKA-10186: - [~nym3r0s] You need to send an email to the

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

[ https://issues.apache.org/jira/browse/KAFKA-10186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17171026#comment-17171026 ] Sophie Blee-Goldman commented on KAFKA-10186: - I was suggesting to throw a new exception,

[jira] [Commented] (KAFKA-8159) Built-in serdes for signed numbers do not obey lexicographical ordering

[ https://issues.apache.org/jira/browse/KAFKA-8159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17169187#comment-17169187 ] Sophie Blee-Goldman commented on KAFKA-8159: A related bummer is that you can't do fetches

[jira] [Commented] (KAFKA-10137) Clean-up retain Duplicate logic in Window Stores

[ https://issues.apache.org/jira/browse/KAFKA-10137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17169045#comment-17169045 ] Sophie Blee-Goldman commented on KAFKA-10137: - Yeah I thought that might be the case,

[jira] [Commented] (KAFKA-10336) Rolling upgrade with Suppression AND Standbys may throw exceptions

[ https://issues.apache.org/jira/browse/KAFKA-10336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17169038#comment-17169038 ] Sophie Blee-Goldman commented on KAFKA-10336: - Thanks for the detailed bug report. Quick

[jira] [Commented] (KAFKA-10322) InMemoryWindowStore restore keys format incompatibility (lack of sequenceNumber in keys on topic)

[ https://issues.apache.org/jira/browse/KAFKA-10322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17168374#comment-17168374 ] Sophie Blee-Goldman commented on KAFKA-10322: - Oh you're referring to the global store, not

[jira] [Commented] (KAFKA-10137) Clean-up retain Duplicate logic in Window Stores

[ https://issues.apache.org/jira/browse/KAFKA-10137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17168234#comment-17168234 ] Sophie Blee-Goldman commented on KAFKA-10137: - I think there's actually a real bug lurking

[jira] [Commented] (KAFKA-10322) InMemoryWindowStore restore keys format incompatibility (lack of sequenceNumber in keys on topic)

[ https://issues.apache.org/jira/browse/KAFKA-10322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17168231#comment-17168231 ] Sophie Blee-Goldman commented on KAFKA-10322: - Ok, I dug into this a big further and found

[jira] [Commented] (KAFKA-10322) InMemoryWindowStore restore keys format incompatibility (lack of sequenceNumber in keys on topic)

[ https://issues.apache.org/jira/browse/KAFKA-10322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17168155#comment-17168155 ] Sophie Blee-Goldman commented on KAFKA-10322: - Hey [~tbradlo] Thanks for the bug report. I

[jira] [Commented] (KAFKA-10284) Group membership update due to static member rejoin should be persisted

[ https://issues.apache.org/jira/browse/KAFKA-10284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17164531#comment-17164531 ] Sophie Blee-Goldman commented on KAFKA-10284: - Nope, it just spun in a loop where it would

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

[ https://issues.apache.org/jira/browse/KAFKA-9161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9161: --- Fix Version/s: 2.6.0 > Close gaps in Streams configs documentation >

[jira] [Commented] (KAFKA-10284) Group membership update due to static member rejoin should be persisted

[ https://issues.apache.org/jira/browse/KAFKA-10284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17163796#comment-17163796 ] Sophie Blee-Goldman commented on KAFKA-10284: - You know, I think we actually hit this too,

[jira] [Comment Edited] (KAFKA-8037) KTable restore may load bad data

[ https://issues.apache.org/jira/browse/KAFKA-8037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17163142#comment-17163142 ] Sophie Blee-Goldman edited comment on KAFKA-8037 at 7/22/20, 11:54 PM:

[jira] [Comment Edited] (KAFKA-8037) KTable restore may load bad data

[ https://issues.apache.org/jira/browse/KAFKA-8037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17163142#comment-17163142 ] Sophie Blee-Goldman edited comment on KAFKA-8037 at 7/22/20, 11:52 PM:

[jira] [Comment Edited] (KAFKA-8037) KTable restore may load bad data

[ https://issues.apache.org/jira/browse/KAFKA-8037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17163142#comment-17163142 ] Sophie Blee-Goldman edited comment on KAFKA-8037 at 7/22/20, 11:52 PM:

[jira] [Commented] (KAFKA-8037) KTable restore may load bad data

[ https://issues.apache.org/jira/browse/KAFKA-8037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17163142#comment-17163142 ] Sophie Blee-Goldman commented on KAFKA-8037: Ah, thanks for bringing us back to the question

[jira] [Commented] (KAFKA-8037) KTable restore may load bad data

[ https://issues.apache.org/jira/browse/KAFKA-8037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17163096#comment-17163096 ] Sophie Blee-Goldman commented on KAFKA-8037: By the way, I'm not trying to advocate strongly

[jira] [Commented] (KAFKA-8037) KTable restore may load bad data

[ https://issues.apache.org/jira/browse/KAFKA-8037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17163090#comment-17163090 ] Sophie Blee-Goldman commented on KAFKA-8037: [~vvcephei]I think you're referring to the

[jira] [Commented] (KAFKA-8037) KTable restore may load bad data

[ https://issues.apache.org/jira/browse/KAFKA-8037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17163085#comment-17163085 ] Sophie Blee-Goldman commented on KAFKA-8037: > many users might not even know if their serde

[jira] [Comment Edited] (KAFKA-8037) KTable restore may load bad data

[ https://issues.apache.org/jira/browse/KAFKA-8037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17163011#comment-17163011 ] Sophie Blee-Goldman edited comment on KAFKA-8037 at 7/22/20, 6:57 PM:

[jira] [Commented] (KAFKA-8037) KTable restore may load bad data

[ https://issues.apache.org/jira/browse/KAFKA-8037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17163011#comment-17163011 ] Sophie Blee-Goldman commented on KAFKA-8037: I'm tempted to agree with Matthias that

<    6   7   8   9   10   11   12   13   14   15   >