[jira] [Commented] (KAFKA-10173) BufferUnderflowException during Kafka Streams Upgrade

[ https://issues.apache.org/jira/browse/KAFKA-10173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17152259#comment-17152259 ] John Roesler commented on KAFKA-10173: -- Hey all, I'm resolving this ticket to unblo

[jira] [Updated] (KAFKA-10173) BufferUnderflowException during Kafka Streams Upgrade

[ https://issues.apache.org/jira/browse/KAFKA-10173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10173: - Fix Version/s: 2.5.1 2.4.2 > BufferUnderflowException during Kafka Streams Up

[jira] [Resolved] (KAFKA-10173) BufferUnderflowException during Kafka Streams Upgrade

[ https://issues.apache.org/jira/browse/KAFKA-10173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-10173. -- Fix Version/s: (was: 2.5.1) (was: 2.4.2) Resolution: Fixed >

[jira] [Commented] (KAFKA-9062) Handle stalled writes to RocksDB

[ https://issues.apache.org/jira/browse/KAFKA-9062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17151399#comment-17151399 ] John Roesler commented on KAFKA-9062: - Hi all, I would like to see KAFKA-10122 fixed

[jira] [Commented] (KAFKA-10194) run the reset tool between stopping StreamsOptimizedTest and starting the new one

[ https://issues.apache.org/jira/browse/KAFKA-10194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17148030#comment-17148030 ] John Roesler commented on KAFKA-10194: -- Hey [~chia7712] , can we just include this

[jira] [Assigned] (KAFKA-10205) NullPointerException in StreamTask (Kafka Streams 2.5.0)

[ https://issues.apache.org/jira/browse/KAFKA-10205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-10205: Assignee: John Roesler > NullPointerException in StreamTask (Kafka Streams 2.5.0) > -

[jira] [Updated] (KAFKA-10217) Move nodeLevelSensor and storeLevelSensor methods from StreamsMetricsImpl to StreamsMetrics

[ https://issues.apache.org/jira/browse/KAFKA-10217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10217: - Description: StreamsMetricsImpl contains several convenience methods for safely registering sen

[jira] [Updated] (KAFKA-10217) Move nodeLevelSensor and storeLevelSensor methods from StreamsMetricsImpl to StreamsMetrics

[ https://issues.apache.org/jira/browse/KAFKA-10217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10217: - Labels: kip-required newbie (was: newbie,) > Move nodeLevelSensor and storeLevelSensor methods

[jira] [Created] (KAFKA-10217) Move nodeLevelSensor and storeLevelSensor methods from StreamsMetricsImpl to StreamsMetrics

John Roesler created KAFKA-10217: Summary: Move nodeLevelSensor and storeLevelSensor methods from StreamsMetricsImpl to StreamsMetrics Key: KAFKA-10217 URL: https://issues.apache.org/jira/browse/KAFKA-10217

[jira] [Updated] (KAFKA-10215) MockProcessorContext doesn't work with SessionStores

[ https://issues.apache.org/jira/browse/KAFKA-10215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10215: - Description: The recommended pattern for testing custom Processor implementations is to use the

[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&focusedCommentId=17147885#comment-17147885 ] John Roesler commented on KAFKA-10200: -- Created and linked https://issues.apache.or

[jira] [Updated] (KAFKA-10215) MockProcessorContext doesn't work with SessionStores

[ https://issues.apache.org/jira/browse/KAFKA-10215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10215: - Description: The recommended pattern for testing custom Processor implementations is to use the

[jira] [Created] (KAFKA-10215) MockProcessorContext doesn't work with SessionStores

John Roesler created KAFKA-10215: Summary: MockProcessorContext doesn't work with SessionStores Key: KAFKA-10215 URL: https://issues.apache.org/jira/browse/KAFKA-10215 Project: Kafka Issue Ty

[jira] [Commented] (KAFKA-10205) NullPointerException in StreamTask (Kafka Streams 2.5.0)

[ https://issues.apache.org/jira/browse/KAFKA-10205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17147171#comment-17147171 ] John Roesler commented on KAFKA-10205: -- Hi Brian, I’m sorry to hear that. I’ll try

[jira] [Commented] (KAFKA-10173) BufferUnderflowException during Kafka Streams Upgrade

[ https://issues.apache.org/jira/browse/KAFKA-10173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17147049#comment-17147049 ] John Roesler commented on KAFKA-10173: -- Here's the system test PR: https://github.c

[jira] [Commented] (KAFKA-10173) BufferUnderflowException during Kafka Streams Upgrade

[ https://issues.apache.org/jira/browse/KAFKA-10173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17146758#comment-17146758 ] John Roesler commented on KAFKA-10173: -- Ok, the fix is now backported all the way b

[jira] [Commented] (KAFKA-10173) BufferUnderflowException during Kafka Streams Upgrade

[ https://issues.apache.org/jira/browse/KAFKA-10173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17146749#comment-17146749 ] John Roesler commented on KAFKA-10173: -- Ok, I've just merged the fix ([https://gith

[jira] [Commented] (KAFKA-8630) Unit testing a streams processor with a WindowStore throws a ClassCastException

[ https://issues.apache.org/jira/browse/KAFKA-8630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17146747#comment-17146747 ] John Roesler commented on KAFKA-8630: - Hey, all, I inadvertently started a new ticket

[jira] [Assigned] (KAFKA-8630) Unit testing a streams processor with a WindowStore throws a ClassCastException

[ https://issues.apache.org/jira/browse/KAFKA-8630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-8630: --- Assignee: John Roesler > Unit testing a streams processor with a WindowStore throws a > Cla

[jira] [Resolved] (KAFKA-10185) Streams should log summarized restoration information at info level

[ https://issues.apache.org/jira/browse/KAFKA-10185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-10185. -- Resolution: Fixed > Streams should log summarized restoration information at info level >

[jira] [Commented] (KAFKA-10185) Streams should log summarized restoration information at info level

[ https://issues.apache.org/jira/browse/KAFKA-10185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17146739#comment-17146739 ] John Roesler commented on KAFKA-10185: -- Hey [~rhauch] , Sorry, I should have email

[jira] [Updated] (KAFKA-10185) Streams should log summarized restoration information at info level

[ https://issues.apache.org/jira/browse/KAFKA-10185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10185: - Fix Version/s: (was: 2.7.0) 2.5.1 2.6.0 > Streams shou

[jira] [Updated] (KAFKA-10203) Streams: rolling upgrade from 2.1.1 to trunk (2.7.x) doesn't work

[ https://issues.apache.org/jira/browse/KAFKA-10203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10203: - Labels: (was: streams) > Streams: rolling upgrade from 2.1.1 to trunk (2.7.x) doesn't work > -

[jira] [Updated] (KAFKA-10203) Streams: rolling upgrade from 2.1.1 to trunk (2.7.x) doesn't work

[ https://issues.apache.org/jira/browse/KAFKA-10203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10203: - Component/s: streams > Streams: rolling upgrade from 2.1.1 to trunk (2.7.x) doesn't work > -

[jira] [Updated] (KAFKA-10203) Streams: rolling upgrade from 2.1.1 to trunk (2.7.x) doesn't work

[ https://issues.apache.org/jira/browse/KAFKA-10203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10203: - Description: This *ONLY* refers to Kafka Streams. The brokers, connect, etc. are not affected.

[jira] [Updated] (KAFKA-10203) Streams: rolling upgrade from 2.1.1 to trunk (2.7.x) doesn't work

[ https://issues.apache.org/jira/browse/KAFKA-10203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10203: - Summary: Streams: rolling upgrade from 2.1.1 to trunk (2.7.x) doesn't work (was: Rolling upgrad

[jira] [Updated] (KAFKA-10203) Rolling upgrade from 2.1.1 to trunk (2.7.x) doesn't work

[ https://issues.apache.org/jira/browse/KAFKA-10203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10203: - Labels: streams (was: ) > Rolling upgrade from 2.1.1 to trunk (2.7.x) doesn't work > --

[jira] [Commented] (KAFKA-10203) Rolling upgrade from 2.1.1 to trunk (2.7.x) doesn't work

[ https://issues.apache.org/jira/browse/KAFKA-10203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17145985#comment-17145985 ] John Roesler commented on KAFKA-10203: -- I'm not marking it as a blocker because thi

[jira] [Updated] (KAFKA-10203) Rolling upgrade from 2.1.1 to trunk (2.7.x) doesn't work

[ https://issues.apache.org/jira/browse/KAFKA-10203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10203: - Affects Version/s: 2.6.0 > Rolling upgrade from 2.1.1 to trunk (2.7.x) doesn't work > --

[jira] [Created] (KAFKA-10203) Rolling upgrade from 2.1.1 to trunk (2.7.x) doesn't work

John Roesler created KAFKA-10203: Summary: Rolling upgrade from 2.1.1 to trunk (2.7.x) doesn't work Key: KAFKA-10203 URL: https://issues.apache.org/jira/browse/KAFKA-10203 Project: Kafka Issu

[jira] [Created] (KAFKA-10202) SmokeTest should provide a machanism to generate continuously AND verify the result

John Roesler created KAFKA-10202: Summary: SmokeTest should provide a machanism to generate continuously AND verify the result Key: KAFKA-10202 URL: https://issues.apache.org/jira/browse/KAFKA-10202 P

[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&focusedCommentId=17145126#comment-17145126 ] John Roesler commented on KAFKA-10200: -- Submitted a fix: https://github.com/apache/

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

John Roesler created KAFKA-10200: Summary: MockProcessorContext doesn't work with WindowStores Key: KAFKA-10200 URL: https://issues.apache.org/jira/browse/KAFKA-10200 Project: Kafka Issue Typ

[jira] [Commented] (KAFKA-10173) BufferUnderflowException during Kafka Streams Upgrade

[ https://issues.apache.org/jira/browse/KAFKA-10173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17145112#comment-17145112 ] John Roesler commented on KAFKA-10173: -- Thanks for that information, [~karsten.schn

[jira] [Commented] (KAFKA-10173) BufferUnderflowException during Kafka Streams Upgrade

[ https://issues.apache.org/jira/browse/KAFKA-10173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17144485#comment-17144485 ] John Roesler commented on KAFKA-10173: -- Ok, I'm horrified and embarrassed to report

[jira] [Updated] (KAFKA-10173) BufferUnderflowException during Kafka Streams Upgrade

[ https://issues.apache.org/jira/browse/KAFKA-10173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10173: - Fix Version/s: 2.4.2 2.6.0 > BufferUnderflowException during Kafka Streams Up

[jira] [Updated] (KAFKA-10173) BufferUnderflowException during Kafka Streams Upgrade

[ https://issues.apache.org/jira/browse/KAFKA-10173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10173: - Priority: Blocker (was: Major) > BufferUnderflowException during Kafka Streams Upgrade > --

[jira] [Commented] (KAFKA-10173) BufferUnderflowException during Kafka Streams Upgrade

[ https://issues.apache.org/jira/browse/KAFKA-10173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17143917#comment-17143917 ] John Roesler commented on KAFKA-10173: -- Hi [~karsten.schnitter] , I have "good" ne

[jira] [Commented] (KAFKA-10173) BufferUnderflowException during Kafka Streams Upgrade

[ https://issues.apache.org/jira/browse/KAFKA-10173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17143075#comment-17143075 ] John Roesler commented on KAFKA-10173: -- Hi [~karsten.schnitter] , Thanks for your

[jira] [Commented] (KAFKA-10173) BufferUnderflowException during Kafka Streams Upgrade

[ https://issues.apache.org/jira/browse/KAFKA-10173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17142460#comment-17142460 ] John Roesler commented on KAFKA-10173: -- Wow, thanks for that great information, [~k

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

[ https://issues.apache.org/jira/browse/KAFKA-10191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10191: - Priority: Blocker (was: Major) > fix flaky StreamsOptimizedTest > -

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

[ https://issues.apache.org/jira/browse/KAFKA-10191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10191: - Fix Version/s: 2.6.0 > fix flaky StreamsOptimizedTest > -- > >

[jira] [Assigned] (KAFKA-10184) Flaky HighAvailabilityTaskAssignorIntegrationTest.shouldScaleOutWithWarmupTasksAndPersistentStores

[ https://issues.apache.org/jira/browse/KAFKA-10184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-10184: Assignee: John Roesler > Flaky > HighAvailabilityTaskAssignorIntegrationTest.shouldScale

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

[ https://issues.apache.org/jira/browse/KAFKA-9974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-9974: --- Assignee: Guozhang Wang > Flaky Test OptimizedKTableIntegrationTest#shouldApplyUpdatesToStan

[jira] [Updated] (KAFKA-10185) Streams should log summarized restoration information at info level

[ https://issues.apache.org/jira/browse/KAFKA-10185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10185: - Fix Version/s: 2.6.0 > Streams should log summarized restoration information at info level > ---

[jira] [Updated] (KAFKA-10173) BufferUnderflowException during Kafka Streams Upgrade

[ https://issues.apache.org/jira/browse/KAFKA-10173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10173: - Priority: Major (was: Blocker) > BufferUnderflowException during Kafka Streams Upgrade > --

[jira] [Comment Edited] (KAFKA-10173) BufferUnderflowException during Kafka Streams Upgrade

[ https://issues.apache.org/jira/browse/KAFKA-10173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17140865#comment-17140865 ] John Roesler edited comment on KAFKA-10173 at 6/19/20, 10:29 PM: -

[jira] [Commented] (KAFKA-10173) BufferUnderflowException during Kafka Streams Upgrade

[ https://issues.apache.org/jira/browse/KAFKA-10173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17140865#comment-17140865 ] John Roesler commented on KAFKA-10173: -- [~rhauch]and [~mjsax] , you can consider my

[jira] [Commented] (KAFKA-10173) BufferUnderflowException during Kafka Streams Upgrade

[ https://issues.apache.org/jira/browse/KAFKA-10173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17140863#comment-17140863 ] John Roesler commented on KAFKA-10173: -- Hi [~karsten.schnitter] , I've had a chanc

[jira] [Updated] (KAFKA-10185) Streams should log summarized restoration information at info level

[ https://issues.apache.org/jira/browse/KAFKA-10185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10185: - Fix Version/s: 2.7.0 > Streams should log summarized restoration information at info level > ---

[jira] [Updated] (KAFKA-10185) Streams should log summarized restoration information at info level

[ https://issues.apache.org/jira/browse/KAFKA-10185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10185: - Description: Currently, restoration progress is only visible at debug level in the Consumer's F

[jira] [Commented] (KAFKA-10184) Flaky HighAvailabilityTaskAssignorIntegrationTest.shouldScaleOutWithWarmupTasksAndPersistentStores

[ https://issues.apache.org/jira/browse/KAFKA-10184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17140088#comment-17140088 ] John Roesler commented on KAFKA-10184: -- What in the world... How can we not have pr

[jira] [Created] (KAFKA-10185) Streams should log summarized restoration information at info level

John Roesler created KAFKA-10185: Summary: Streams should log summarized restoration information at info level Key: KAFKA-10185 URL: https://issues.apache.org/jira/browse/KAFKA-10185 Project: Kafka

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

[ https://issues.apache.org/jira/browse/KAFKA-10165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-10165. -- Resolution: Fixed > Percentiles metric leaking memory > - > >

[jira] [Assigned] (KAFKA-10173) BufferUnderflowException during Kafka Streams Upgrade

[ https://issues.apache.org/jira/browse/KAFKA-10173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-10173: Assignee: John Roesler > BufferUnderflowException during Kafka Streams Upgrade >

[jira] [Commented] (KAFKA-10173) BufferUnderflowException during Kafka Streams Upgrade

[ https://issues.apache.org/jira/browse/KAFKA-10173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17137089#comment-17137089 ] John Roesler commented on KAFKA-10173: -- Thanks for the report [~karsten.schnitter]

[jira] [Updated] (KAFKA-10173) BufferUnderflowException during Kafka Streams Upgrade

[ https://issues.apache.org/jira/browse/KAFKA-10173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10173: - Fix Version/s: 2.5.1 > BufferUnderflowException during Kafka Streams Upgrade > -

[jira] [Updated] (KAFKA-10173) BufferUnderflowException during Kafka Streams Upgrade

[ https://issues.apache.org/jira/browse/KAFKA-10173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10173: - Priority: Blocker (was: Major) > BufferUnderflowException during Kafka Streams Upgrade > --

[jira] [Updated] (KAFKA-10086) Standby state isn't always re-used when transitioning to active

[ https://issues.apache.org/jira/browse/KAFKA-10086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10086: - Affects Version/s: (was: 2.7.0) > Standby state isn't always re-used when transitioning to a

[jira] [Updated] (KAFKA-10086) Standby state isn't always re-used when transitioning to active

[ https://issues.apache.org/jira/browse/KAFKA-10086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10086: - Fix Version/s: (was: 2.7.0) > Standby state isn't always re-used when transitioning to activ

[jira] [Resolved] (KAFKA-10086) Standby state isn't always re-used when transitioning to active

[ https://issues.apache.org/jira/browse/KAFKA-10086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-10086. -- Resolution: Fixed > Standby state isn't always re-used when transitioning to active >

[jira] [Updated] (KAFKA-10086) Standby state isn't always re-used when transitioning to active

[ https://issues.apache.org/jira/browse/KAFKA-10086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10086: - Description: This ticket was initially just to write an integration test, but I escalated it to

[jira] [Updated] (KAFKA-10086) Cooperative Rebalance causes standby state not to be re-used when transitioning to active

[ https://issues.apache.org/jira/browse/KAFKA-10086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10086: - Description: This ticket was initially just to write an integration test, but I escalated it to

[jira] [Updated] (KAFKA-10086) Standby state isn't always re-used when transitioning to active

[ https://issues.apache.org/jira/browse/KAFKA-10086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10086: - Summary: Standby state isn't always re-used when transitioning to active (was: Cooperative Reba

[jira] [Updated] (KAFKA-10086) Cooperative Rebalance causes standby state not to be re-used when transitioning to active

[ https://issues.apache.org/jira/browse/KAFKA-10086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10086: - Summary: Cooperative Rebalance causes standby state not to be re-used when transitioning to acti

[jira] [Updated] (KAFKA-10086) Cooperative Rebalance causes standby state not to be re-used when transitioning to active

[ https://issues.apache.org/jira/browse/KAFKA-10086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10086: - Description: This ticket was initially just to write an integration test, but I escalated it to

[jira] [Updated] (KAFKA-10086) Write Integration Test for StreamsTaskAssignor/HighAvailabilityTaskAssignor

[ https://issues.apache.org/jira/browse/KAFKA-10086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10086: - Priority: Blocker (was: Critical) > Write Integration Test for StreamsTaskAssignor/HighAvailabi

[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 ] John Roesler updated KAFKA-10079: - Fix Version/s: 2.7.0 > Improve thread-level stickiness of stateful tasks > -

[jira] [Updated] (KAFKA-10121) Streams Task Assignment optimization design

[ https://issues.apache.org/jira/browse/KAFKA-10121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10121: - Description: Beginning in Kafka 2.6.0, Streams has a new task assignment algorithm that reacts

[jira] [Commented] (KAFKA-10123) Regression resetting offsets in consumer when fetching from old broker

[ https://issues.apache.org/jira/browse/KAFKA-10123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17129791#comment-17129791 ] John Roesler commented on KAFKA-10123: -- I've just also added this as a blocker for

[jira] [Updated] (KAFKA-10123) Regression resetting offsets in consumer when fetching from old broker

[ https://issues.apache.org/jira/browse/KAFKA-10123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10123: - Fix Version/s: 2.5.1 > Regression resetting offsets in consumer when fetching from old broker >

[jira] [Commented] (KAFKA-10122) Consumer should allow heartbeat during rebalance as well

[ https://issues.apache.org/jira/browse/KAFKA-10122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128763#comment-17128763 ] John Roesler commented on KAFKA-10122: -- Thanks, Guozhang! I feel like this was my o

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

[ https://issues.apache.org/jira/browse/KAFKA-10119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128608#comment-17128608 ] John Roesler commented on KAFKA-10119: -- Thanks for marking this as a blocker, it se

[jira] [Updated] (KAFKA-10077) Filter downstream of state-store results in suprious tombstones

[ https://issues.apache.org/jira/browse/KAFKA-10077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10077: - Issue Type: Improvement (was: Bug) > Filter downstream of state-store results in suprious tombs

[jira] [Updated] (KAFKA-10121) Streams Task Assignment optimization design

[ https://issues.apache.org/jira/browse/KAFKA-10121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10121: - Description: Beginning in Kafka 2.6.0, Streams has a new task assignment algorithm that reacts

[jira] [Created] (KAFKA-10121) Streams Task Assignment optimization design

John Roesler created KAFKA-10121: Summary: Streams Task Assignment optimization design Key: KAFKA-10121 URL: https://issues.apache.org/jira/browse/KAFKA-10121 Project: Kafka Issue Type: Task

[jira] [Commented] (KAFKA-9891) Invalid state store content after task migration with exactly_once and standby replicas

[ https://issues.apache.org/jira/browse/KAFKA-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128389#comment-17128389 ] John Roesler commented on KAFKA-9891: - Hi [~mjsax] and [~bchen225242] , I see you're

[jira] [Commented] (KAFKA-10091) Improve task idling

[ https://issues.apache.org/jira/browse/KAFKA-10091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17127733#comment-17127733 ] John Roesler commented on KAFKA-10091: -- Thanks Guozhang. That would certainly be ea

[jira] [Commented] (KAFKA-10091) Improve task idling

[ https://issues.apache.org/jira/browse/KAFKA-10091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17127456#comment-17127456 ] John Roesler commented on KAFKA-10091: -- Sure thing, Guozhang! I’m a little hazy on

[jira] [Created] (KAFKA-10091) Improve task idling

John Roesler created KAFKA-10091: Summary: Improve task idling Key: KAFKA-10091 URL: https://issues.apache.org/jira/browse/KAFKA-10091 Project: Kafka Issue Type: Task Components: st

[jira] [Created] (KAFKA-10086) Write Integration Test for StreamsTaskAssignor/HighAvailabilityTaskAssignor

John Roesler created KAFKA-10086: Summary: Write Integration Test for StreamsTaskAssignor/HighAvailabilityTaskAssignor Key: KAFKA-10086 URL: https://issues.apache.org/jira/browse/KAFKA-10086 Project:

[jira] [Updated] (KAFKA-10084) System test failure: StreamsEosTest.test_failure_and_recovery_complex

[ https://issues.apache.org/jira/browse/KAFKA-10084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10084: - Component/s: streams > System test failure: StreamsEosTest.test_failure_and_recovery_complex > -

[jira] [Commented] (KAFKA-10084) System test failure: StreamsEosTest.test_failure_and_recovery_complex

[ https://issues.apache.org/jira/browse/KAFKA-10084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17124224#comment-17124224 ] John Roesler commented on KAFKA-10084: -- Thanks to some advice from [~mjsax] , it se

[jira] [Updated] (KAFKA-10084) System test failure: StreamsEosTest.test_failure_and_recovery_complex

[ https://issues.apache.org/jira/browse/KAFKA-10084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10084: - Affects Version/s: 2.6.0 > System test failure: StreamsEosTest.test_failure_and_recovery_complex

[jira] [Updated] (KAFKA-10084) System test failure: StreamsEosTest.test_failure_and_recovery_complex

[ https://issues.apache.org/jira/browse/KAFKA-10084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10084: - Affects Version/s: 2.7.0 > System test failure: StreamsEosTest.test_failure_and_recovery_complex

[jira] [Updated] (KAFKA-10084) System test failure: StreamsEosTest.test_failure_and_recovery_complex

[ https://issues.apache.org/jira/browse/KAFKA-10084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10084: - Fix Version/s: 2.6.0 2.7.0 > System test failure: StreamsEosTest.test_failure

[jira] [Created] (KAFKA-10084) System test failure: StreamsEosTest.test_failure_and_recovery_complex

John Roesler created KAFKA-10084: Summary: System test failure: StreamsEosTest.test_failure_and_recovery_complex Key: KAFKA-10084 URL: https://issues.apache.org/jira/browse/KAFKA-10084 Project: Kafka

[jira] [Updated] (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:all-tabpanel ] John Roesler updated KAFKA-10068: - Fix Version/s: 2.6.0 > Verify HighAvailabilityTaskAssignor performance with large clusters and

[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&focusedCommentId=17121323#comment-17121323 ] John Roesler commented on KAFKA-10068: -- Thanks, [~ableegoldman] , that is indeed wh

[jira] [Updated] (KAFKA-10066) TopologyTestDriver isn't taking record headers into account during de/serialization

[ https://issues.apache.org/jira/browse/KAFKA-10066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10066: - Fix Version/s: 2.5.1 > TopologyTestDriver isn't taking record headers into account during > de/

[jira] [Commented] (KAFKA-10066) TopologyTestDriver isn't taking record headers into account during de/serialization

[ https://issues.apache.org/jira/browse/KAFKA-10066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17120370#comment-17120370 ] John Roesler commented on KAFKA-10066: -- Great! Thanks. > TopologyTestDriver isn't

[jira] [Commented] (KAFKA-10066) TopologyTestDriver isn't taking record headers into account during de/serialization

[ https://issues.apache.org/jira/browse/KAFKA-10066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17120291#comment-17120291 ] John Roesler commented on KAFKA-10066: -- Hey, @mjsax, since you’re already proposing

[jira] [Commented] (KAFKA-9841) Connector and Task duplicated when a worker join with old generation assignment

[ https://issues.apache.org/jira/browse/KAFKA-9841?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17119969#comment-17119969 ] John Roesler commented on KAFKA-9841: - Hello [~LucentWong] and [~kkonstantine] , I'm

[jira] [Commented] (KAFKA-10030) Throw exception while fetching a key from a single partition

[ https://issues.apache.org/jira/browse/KAFKA-10030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17119968#comment-17119968 ] John Roesler commented on KAFKA-10030: -- I'm getting ready for the 2.5.1 release at

[jira] [Commented] (KAFKA-9861) Process Simplification - Community Validation of Kafka Release Candidates

[ https://issues.apache.org/jira/browse/KAFKA-9861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17119966#comment-17119966 ] John Roesler commented on KAFKA-9861: - This ticket is targeted for the 2.5.1 release,

[jira] [Commented] (KAFKA-9861) Process Simplification - Community Validation of Kafka Release Candidates

[ https://issues.apache.org/jira/browse/KAFKA-9861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17119963#comment-17119963 ] John Roesler commented on KAFKA-9861: - Hi [~iekpo] , One resource that may help is:

[jira] [Updated] (KAFKA-10049) KTable-KTable Foreign Key join throwing Serialization Exception

[ https://issues.apache.org/jira/browse/KAFKA-10049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10049: - Fix Version/s: 2.5.1 2.6.0 > KTable-KTable Foreign Key join throwing Serializ

[jira] [Commented] (KAFKA-10066) TopologyTestDriver.createOutputTopic isn't taking record headers into account during deserialization

[ https://issues.apache.org/jira/browse/KAFKA-10066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17119955#comment-17119955 ] John Roesler commented on KAFKA-10066: -- Hi [~sdutry] , Thanks for the report! It s

[jira] [Commented] (KAFKA-10062) Add a method to retrieve the current timestamp as known by the Streams app

[ https://issues.apache.org/jira/browse/KAFKA-10062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17119952#comment-17119952 ] John Roesler commented on KAFKA-10062: -- Thanks [~psmolinski] , This seems like a r

[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&focusedCommentId=17119939#comment-17119939 ] John Roesler commented on KAFKA-10068: -- Oh, it's also worth mentioning that based o

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