[jira] [Commented] (KAFKA-5578) Streams Task Assignor should consider the staleness of state directories when allocating tasks

[ https://issues.apache.org/jira/browse/KAFKA-5578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107862#comment-17107862 ] Sophie Blee-Goldman commented on KAFKA-5578: Yup, this pretty much sums up what we've

[jira] [Commented] (KAFKA-7174) Improve version probing of subscription info

[ https://issues.apache.org/jira/browse/KAFKA-7174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107880#comment-17107880 ] Sophie Blee-Goldman commented on KAFKA-7174: Technically w.r.t version probing we still just

[jira] [Commented] (KAFKA-7041) Using RocksDB bulk loading for StandbyTasks

[ https://issues.apache.org/jira/browse/KAFKA-7041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107885#comment-17107885 ] Sophie Blee-Goldman commented on KAFKA-7041: > we should also be careful here: just calling

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

[ https://issues.apache.org/jira/browse/KAFKA-7912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107884#comment-17107884 ] Sophie Blee-Goldman commented on KAFKA-7912: I think I actually did end up fixing this in a

[jira] [Commented] (KAFKA-9972) Corrupted standby task could be committed

[ https://issues.apache.org/jira/browse/KAFKA-9972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17104732#comment-17104732 ] Sophie Blee-Goldman commented on KAFKA-9972: Fair enough. Then would you propose that the

[jira] [Commented] (KAFKA-8858) Kafka Streams - Failed to Rebalance Error and stream consumer stuck for some reason

[ https://issues.apache.org/jira/browse/KAFKA-8858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17062181#comment-17062181 ] Sophie Blee-Goldman commented on KAFKA-8858: I thought they were different exceptions due to

[jira] [Updated] (KAFKA-9568) Kstreams APPLICATION_SERVER_CONFIG is not updated with static membership

[ https://issues.apache.org/jira/browse/KAFKA-9568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9568: --- Affects Version/s: 2.5.0 > Kstreams APPLICATION_SERVER_CONFIG is not updated with

[jira] [Updated] (KAFKA-9568) Kstreams APPLICATION_SERVER_CONFIG is not updated with static membership

[ https://issues.apache.org/jira/browse/KAFKA-9568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9568: --- Fix Version/s: 2.6.0 > Kstreams APPLICATION_SERVER_CONFIG is not updated with static

[jira] [Commented] (KAFKA-8266) Improve `testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup`

[ https://issues.apache.org/jira/browse/KAFKA-8266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17063562#comment-17063562 ] Sophie Blee-Goldman commented on KAFKA-8266: Can we close this as a duplicate? > Improve >

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

[ https://issues.apache.org/jira/browse/KAFKA-7965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17063563#comment-17063563 ] Sophie Blee-Goldman commented on KAFKA-7965: Failed on both builds of this PR:

[jira] [Commented] (KAFKA-8897) Increase Version of RocksDB

[ https://issues.apache.org/jira/browse/KAFKA-8897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17066025#comment-17066025 ] Sophie Blee-Goldman commented on KAFKA-8897: A user actually generated a compatibility report

[jira] [Commented] (KAFKA-9921) Caching is not working properly with WindowStateStore when retaining duplicates

[ https://issues.apache.org/jira/browse/KAFKA-9921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17102168#comment-17102168 ] Sophie Blee-Goldman commented on KAFKA-9921: No need to explain, I actually agree with you in

[jira] [Commented] (KAFKA-9921) Caching is not working properly with WindowStateStore when retaining duplicates

[ https://issues.apache.org/jira/browse/KAFKA-9921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17102963#comment-17102963 ] Sophie Blee-Goldman commented on KAFKA-9921: Ah, it's a bit hidden but there actually is a

[jira] [Commented] (KAFKA-9972) Corrupted standby task could be committed

[ https://issues.apache.org/jira/browse/KAFKA-9972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17102926#comment-17102926 ] Sophie Blee-Goldman commented on KAFKA-9972: I see that we already committed a fix for this,

[jira] [Commented] (KAFKA-9921) Caching is not working properly with WindowStateStore when retaining duplicates

[ https://issues.apache.org/jira/browse/KAFKA-9921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17102953#comment-17102953 ] Sophie Blee-Goldman commented on KAFKA-9921: I just meant deprecating the

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

[ https://issues.apache.org/jira/browse/KAFKA-9923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17102911#comment-17102911 ] Sophie Blee-Goldman commented on KAFKA-9923: This might be a good opportunity to clean up the

[jira] [Updated] (KAFKA-9127) Needless group coordination overhead for GlobalKTables

[ https://issues.apache.org/jira/browse/KAFKA-9127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9127: --- Fix Version/s: 2.4.2 > Needless group coordination overhead for GlobalKTables >

[jira] [Commented] (KAFKA-9921) Caching is not working properly with WindowStateStore when retaining duplicates

[ https://issues.apache.org/jira/browse/KAFKA-9921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17102908#comment-17102908 ] Sophie Blee-Goldman commented on KAFKA-9921: Fair enough. I added the clarification to

[jira] [Commented] (KAFKA-9949) Flaky Test GlobalKTableIntegrationTest#shouldKStreamGlobalKTableLeftJoin

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

[jira] [Commented] (KAFKA-9949) Flaky Test GlobalKTableIntegrationTest#shouldKStreamGlobalKTableLeftJoin

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

[jira] [Commented] (KAFKA-9987) Improve sticky partition assignor algorithm

[ https://issues.apache.org/jira/browse/KAFKA-9987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17112535#comment-17112535 ] Sophie Blee-Goldman commented on KAFKA-9987: [~hai_lin] I put this on pause to try and get

[jira] [Created] (KAFKA-10025) Segfault in RocksDB Statistics

Sophie Blee-Goldman created KAFKA-10025: --- Summary: Segfault in RocksDB Statistics Key: KAFKA-10025 URL: https://issues.apache.org/jira/browse/KAFKA-10025 Project: Kafka Issue Type: Bug

[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] [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-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-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] [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-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] [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] [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-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] [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] [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] [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] [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] [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] [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] [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-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-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] [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] [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] [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] [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-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] [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] [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] [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=17209006#comment-17209006 ] Sophie Blee-Goldman commented on KAFKA-5998: Yeah I think both of those (running with shared

[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-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] [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] [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] [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] [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] [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] [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] [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] [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] [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] [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] [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] [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] [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] [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] [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] [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] [Created] (KAFKA-10052) Flaky Test InternalTopicsIntegrationTest.testCreateInternalTopicsWithFewerReplicasThanBrokers

Sophie Blee-Goldman created KAFKA-10052: --- Summary: Flaky Test InternalTopicsIntegrationTest.testCreateInternalTopicsWithFewerReplicasThanBrokers Key: KAFKA-10052 URL:

[jira] [Resolved] (KAFKA-6145) Warm up new KS instances before migrating tasks - potentially a two phase rebalance

[ https://issues.apache.org/jira/browse/KAFKA-6145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman resolved KAFKA-6145. Fix Version/s: 2.6.0 Resolution: Fixed > Warm up new KS instances before

[jira] [Updated] (KAFKA-8011) Flaky Test RegexSourceIntegrationTest#testRegexMatchesTopicsAWhenCreated

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

[jira] [Commented] (KAFKA-8011) Flaky Test RegexSourceIntegrationTest#testRegexMatchesTopicsAWhenCreated

[ https://issues.apache.org/jira/browse/KAFKA-8011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17118222#comment-17118222 ] Sophie Blee-Goldman commented on KAFKA-8011: [~mjsax] should we create a separate ticket for

[jira] [Updated] (KAFKA-8011) Flaky Test RegexSourceIntegrationTest#testRegexMatchesTopicsAWhenCreated

[ https://issues.apache.org/jira/browse/KAFKA-8011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8011: --- Fix Version/s: 2.6.0 > Flaky Test

[jira] [Updated] (KAFKA-8011) Flaky Test RegexSourceIntegrationTest#testRegexMatchesTopicsAWhenCreated

[ https://issues.apache.org/jira/browse/KAFKA-8011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8011: --- Attachment: org.apache.kafka.streams.integration.RegexSourceIntegrationTest.html >

[jira] [Commented] (KAFKA-8011) Flaky Test RegexSourceIntegrationTest#testRegexMatchesTopicsAWhenCreated

[ https://issues.apache.org/jira/browse/KAFKA-8011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17118245#comment-17118245 ] Sophie Blee-Goldman commented on KAFKA-8011: Attaching the output from local testing: 

[jira] [Updated] (KAFKA-9983) Add INFO-level end-to-end latency metrics to Streams

[ https://issues.apache.org/jira/browse/KAFKA-9983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9983: --- Summary: Add INFO-level end-to-end latency metrics to Streams (was: Add end-to-end

[jira] [Created] (KAFKA-10054) Add TRACE-level end-to-end latency metrics to Streams

Sophie Blee-Goldman created KAFKA-10054: --- Summary: Add TRACE-level end-to-end latency metrics to Streams Key: KAFKA-10054 URL: https://issues.apache.org/jira/browse/KAFKA-10054 Project: Kafka

[jira] [Commented] (KAFKA-9987) Improve sticky partition assignor algorithm

[ https://issues.apache.org/jira/browse/KAFKA-9987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17119261#comment-17119261 ] Sophie Blee-Goldman commented on KAFKA-9987: Hey [~hai_lin] and [~twmb], I finally finished

[jira] [Commented] (KAFKA-10068) Verify HighAvailabilityTaskAssignor performance with large clusters and topologies

[ https://issues.apache.org/jira/browse/KAFKA-10068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17120041#comment-17120041 ] Sophie Blee-Goldman commented on KAFKA-10068: - I don't think he means to apply a timeout to

[jira] [Commented] (KAFKA-10068) Verify HighAvailabilityTaskAssignor performance with large clusters and topologies

[ https://issues.apache.org/jira/browse/KAFKA-10068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17120042#comment-17120042 ] Sophie Blee-Goldman commented on KAFKA-10068: - For example I added a scale test for the

[jira] [Updated] (KAFKA-9821) Partition may skip assignment with static members and incremental rebalances

[ https://issues.apache.org/jira/browse/KAFKA-9821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9821: --- Description: When static membership (KIP-345) and incremental rebalancing (KIP-429)

[jira] [Created] (KAFKA-10078) Partition may skip assignment with static members and incremental rebalances

Sophie Blee-Goldman created KAFKA-10078: --- Summary: Partition may skip assignment with static members and incremental rebalances Key: KAFKA-10078 URL: https://issues.apache.org/jira/browse/KAFKA-10078

[jira] [Updated] (KAFKA-10078) Stream tasks may skip assignment with static members and incremental rebalances

[ https://issues.apache.org/jira/browse/KAFKA-10078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-10078: Summary: Stream tasks may skip assignment with static members and incremental

[jira] [Updated] (KAFKA-10079) Improve thread-level stickiness of stateful tasks

[ https://issues.apache.org/jira/browse/KAFKA-10079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-10079: Description: Now that KAFKA-9501 is fixed, we should make sure that KIP-441 will

[jira] [Updated] (KAFKA-10079) Improve thread-level stickiness of stateful tasks

[ https://issues.apache.org/jira/browse/KAFKA-10079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-10079: Summary: Improve thread-level stickiness of stateful tasks (was: Support high

[jira] [Created] (KAFKA-10079) Support high availability for in-memory stores

Sophie Blee-Goldman created KAFKA-10079: --- Summary: Support high availability for in-memory stores Key: KAFKA-10079 URL: https://issues.apache.org/jira/browse/KAFKA-10079 Project: Kafka

[jira] [Updated] (KAFKA-9821) Partition may skip assignment with static members and incremental rebalances

[ https://issues.apache.org/jira/browse/KAFKA-9821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9821: --- Component/s: (was: streams) > Partition may skip assignment with static members

[jira] [Resolved] (KAFKA-9821) Stream task may skip assignment with static members and incremental rebalances

[ https://issues.apache.org/jira/browse/KAFKA-9821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman resolved KAFKA-9821. Resolution: Fixed > Stream task may skip assignment with static members and

[jira] [Updated] (KAFKA-10078) Partition may skip assignment with static members and incremental rebalances

[ https://issues.apache.org/jira/browse/KAFKA-10078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-10078: Description: When static membership (KIP-345) and incremental rebalancing

[jira] [Assigned] (KAFKA-10078) Partition may skip assignment with static members and incremental rebalances

[ https://issues.apache.org/jira/browse/KAFKA-10078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman reassigned KAFKA-10078: --- Assignee: (was: Sophie Blee-Goldman) > Partition may skip assignment

[jira] [Updated] (KAFKA-9821) Stream task may skip assignment with static members and incremental rebalances

[ https://issues.apache.org/jira/browse/KAFKA-9821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9821: --- Description: When static membership (KIP-345) and incremental rebalancing (KIP-429)

[jira] [Updated] (KAFKA-10078) Stream tasks may skip assignment with static members and incremental rebalances

[ https://issues.apache.org/jira/browse/KAFKA-10078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-10078: Fix Version/s: (was: 2.6.0) > Stream tasks may skip assignment with static

<    1   2   3   4   5   6   7   8   9   10   >