[jira] [Resolved] (KAFKA-7497) Kafka Streams should support self-join on streams

[ https://issues.apache.org/jira/browse/KAFKA-7497?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-7497. Resolution: Fixed > Kafka Streams should support self-join on streams >

[jira] [Resolved] (KAFKA-7497) Kafka Streams should support self-join on streams

[ https://issues.apache.org/jira/browse/KAFKA-7497?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-7497. Resolution: Fixed > Kafka Streams should support self-join on streams >

[jira] [Resolved] (KAFKA-14173) TopologyTestDriver does not use mock wall clock time when sending test records

[ https://issues.apache.org/jira/browse/KAFKA-14173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-14173. - Resolution: Not A Problem > TopologyTestDriver does not use mock wall clock time when

[jira] [Commented] (KAFKA-14173) TopologyTestDriver does not use mock wall clock time when sending test records

[ https://issues.apache.org/jira/browse/KAFKA-14173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17725356#comment-17725356 ] Matthias J. Sax commented on KAFKA-14173: - Just discovering this ticket. I guess you would need

[jira] [Resolved] (KAFKA-14173) TopologyTestDriver does not use mock wall clock time when sending test records

[ https://issues.apache.org/jira/browse/KAFKA-14173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-14173. - Resolution: Not A Problem > TopologyTestDriver does not use mock wall clock time when

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

[ https://issues.apache.org/jira/browse/KAFKA-10575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-10575: Labels: kip (was: ) > StateRestoreListener#onRestoreEnd should always be triggered >

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

[ https://issues.apache.org/jira/browse/KAFKA-10575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-10575: Description: Part of KIP-869:

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

[ https://issues.apache.org/jira/browse/KAFKA-10575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-10575. - Fix Version/s: 3.5.0 Resolution: Fixed > StateRestoreListener#onRestoreEnd

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

[ https://issues.apache.org/jira/browse/KAFKA-10575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-10575. - Fix Version/s: 3.5.0 Resolution: Fixed > StateRestoreListener#onRestoreEnd

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

[ https://issues.apache.org/jira/browse/KAFKA-10575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-10575: --- Assignee: Guozhang Wang (was: highluck) > StateRestoreListener#onRestoreEnd

[jira] [Commented] (KAFKA-13349) Allow Iterator.remove on KeyValueIterator

[ https://issues.apache.org/jira/browse/KAFKA-13349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722005#comment-17722005 ] Matthias J. Sax commented on KAFKA-13349: - Yes, we want to add `remove()` to interface

[jira] [Commented] (KAFKA-14911) Add system tests for rolling upgrade path of KIP-904

[ https://issues.apache.org/jira/browse/KAFKA-14911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722004#comment-17722004 ] Matthias J. Sax commented on KAFKA-14911: - No worries. And thanks for helping on reviewing!

[jira] [Commented] (KAFKA-14981) Set `group.instance.id` in streams consumer so that rebalance will not happen if a instance is restarted

[ https://issues.apache.org/jira/browse/KAFKA-14981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722003#comment-17722003 ] Matthias J. Sax commented on KAFKA-14981: - I was not aware that there was (or maybe still are)

[jira] [Commented] (KAFKA-14981) Set `group.instance.id` in streams consumer so that rebalance will not happen if a instance is restarted

[ https://issues.apache.org/jira/browse/KAFKA-14981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17721114#comment-17721114 ] Matthias J. Sax commented on KAFKA-14981: - Very interesting idea – given that we persist the

[jira] [Commented] (KAFKA-14957) Default value for state.dir is confusing

[ https://issues.apache.org/jira/browse/KAFKA-14957?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17719079#comment-17719079 ] Matthias J. Sax commented on KAFKA-14957: - Ah. Thanks. That's gonna be nasty to fix... This

[jira] [Updated] (KAFKA-14957) Default value for state.dir is confusing

[ https://issues.apache.org/jira/browse/KAFKA-14957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-14957: Component/s: docs > Default value for state.dir is confusing >

[jira] [Updated] (KAFKA-14957) Default value for state.dir is confusing

[ https://issues.apache.org/jira/browse/KAFKA-14957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-14957: Labels: beginner newbie (was: ) > Default value for state.dir is confusing >

[jira] [Updated] (KAFKA-14957) Default value for state.dir is confusing

[ https://issues.apache.org/jira/browse/KAFKA-14957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-14957: Priority: Minor (was: Major) > Default value for state.dir is confusing >

[jira] [Commented] (KAFKA-14957) Default value for state.dir is confusing

[ https://issues.apache.org/jira/browse/KAFKA-14957?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17718759#comment-17718759 ] Matthias J. Sax commented on KAFKA-14957: - [~mimaison] – Thanks. What part of the docs are you

[jira] [Updated] (KAFKA-14949) Add Streams upgrade tests from AK 3.4

[ https://issues.apache.org/jira/browse/KAFKA-14949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-14949: Component/s: system tests > Add Streams upgrade tests from AK 3.4 >

[jira] [Assigned] (KAFKA-14911) Add system tests for rolling upgrade path of KIP-904

[ https://issues.apache.org/jira/browse/KAFKA-14911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-14911: --- Assignee: Victoria Xia > Add system tests for rolling upgrade path of KIP-904 >

[jira] [Assigned] (KAFKA-14839) Exclude protected variable from JavaDocs

[ https://issues.apache.org/jira/browse/KAFKA-14839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-14839: --- Assignee: Atul Sharma > Exclude protected variable from JavaDocs >

[jira] [Commented] (KAFKA-14839) Exclude protected variable from JavaDocs

[ https://issues.apache.org/jira/browse/KAFKA-14839?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17716493#comment-17716493 ] Matthias J. Sax commented on KAFKA-14839: - Sure! > Exclude protected variable from JavaDocs >

[jira] [Updated] (KAFKA-14936) Add Grace Period To Stream Table Join

[ https://issues.apache.org/jira/browse/KAFKA-14936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-14936: Labels: kip streams (was: streams) > Add Grace Period To Stream Table Join >

[jira] [Updated] (KAFKA-14172) bug: State stores lose state when tasks are reassigned under EOS wit…

[ https://issues.apache.org/jira/browse/KAFKA-14172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-14172: Fix Version/s: 3.4.1 > bug: State stores lose state when tasks are reassigned under EOS

[jira] [Updated] (KAFKA-14922) kafka-streams-application-reset deletes topics not belonging to specified application-id

[ https://issues.apache.org/jira/browse/KAFKA-14922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-14922: Labels: beginner needs-kip newbie (was: ) > kafka-streams-application-reset deletes

[jira] [Updated] (KAFKA-14862) Outer stream-stream join does not output all results with multiple input partitions

[ https://issues.apache.org/jira/browse/KAFKA-14862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-14862: Affects Version/s: 3.1.0 > Outer stream-stream join does not output all results with

[jira] [Commented] (KAFKA-14722) Make BooleanSerde public

[ https://issues.apache.org/jira/browse/KAFKA-14722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17715157#comment-17715157 ] Matthias J. Sax commented on KAFKA-14722: - I did a PR:

[jira] [Commented] (KAFKA-14922) kafka-streams-application-reset deletes topics not belonging to specified application-id

[ https://issues.apache.org/jira/browse/KAFKA-14922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17714770#comment-17714770 ] Matthias J. Sax commented on KAFKA-14922: - {quote}We could add a warning with the list of

[jira] [Updated] (KAFKA-14922) kafka-streams-application-reset deletes topics not belonging to specified application-id

[ https://issues.apache.org/jira/browse/KAFKA-14922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-14922: Component/s: streams tools > kafka-streams-application-reset deletes

[jira] [Commented] (KAFKA-14922) kafka-streams-application-reset deletes topics not belonging to specified application-id

[ https://issues.apache.org/jira/browse/KAFKA-14922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17714354#comment-17714354 ] Matthias J. Sax commented on KAFKA-14922: - Thanks for creating this ticket. It's a know issue

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

[ https://issues.apache.org/jira/browse/KAFKA-4327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-4327. Fix Version/s: (was: 4.0.0) Resolution: Fixed This was resolved via

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

[ https://issues.apache.org/jira/browse/KAFKA-4327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-4327. Fix Version/s: (was: 4.0.0) Resolution: Fixed This was resolved via

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

[ https://issues.apache.org/jira/browse/KAFKA-4327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-4327: -- Assignee: (was: Jorge Esteban Quilcate Otoya) > Move Reset Tool from core to

[jira] [Commented] (KAFKA-14586) Move StreamsResetter to tools

[ https://issues.apache.org/jira/browse/KAFKA-14586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17713836#comment-17713836 ] Matthias J. Sax commented on KAFKA-14586: - Thanks for providing context, and no worries about

[jira] [Assigned] (KAFKA-14862) Outer stream-stream join does not output all results with multiple input partitions

[ https://issues.apache.org/jira/browse/KAFKA-14862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-14862: --- Assignee: Matthias J. Sax > Outer stream-stream join does not output all results

[jira] [Commented] (KAFKA-14586) Move StreamsResetter to tools

[ https://issues.apache.org/jira/browse/KAFKA-14586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17713233#comment-17713233 ] Matthias J. Sax commented on KAFKA-14586: - [~mimaison] [~sagarrao] – I am just realizing that we

[jira] [Commented] (KAFKA-14911) Add system tests for rolling upgrade path of KIP-904

[ https://issues.apache.org/jira/browse/KAFKA-14911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17713230#comment-17713230 ] Matthias J. Sax commented on KAFKA-14911: - [~fqpublic] – are you planning to pickup this ticket?

[jira] [Resolved] (KAFKA-7499) Extend ProductionExceptionHandler to cover serialization exceptions

[ https://issues.apache.org/jira/browse/KAFKA-7499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-7499. Fix Version/s: 3.5.0 Resolution: Fixed > Extend ProductionExceptionHandler to cover

[jira] [Resolved] (KAFKA-7499) Extend ProductionExceptionHandler to cover serialization exceptions

[ https://issues.apache.org/jira/browse/KAFKA-7499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-7499. Fix Version/s: 3.5.0 Resolution: Fixed > Extend ProductionExceptionHandler to cover

[jira] [Resolved] (KAFKA-14834) Improved processor semantics for versioned stores

[ https://issues.apache.org/jira/browse/KAFKA-14834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-14834. - Fix Version/s: 3.5.0 Resolution: Fixed > Improved processor semantics for

[jira] [Resolved] (KAFKA-14834) Improved processor semantics for versioned stores

[ https://issues.apache.org/jira/browse/KAFKA-14834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-14834. - Fix Version/s: 3.5.0 Resolution: Fixed > Improved processor semantics for

[jira] [Updated] (KAFKA-14209) Optimize stream stream self join to use single state store

[ https://issues.apache.org/jira/browse/KAFKA-14209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-14209: Description: KIP-862:

[jira] [Updated] (KAFKA-14209) Optimize stream stream self join to use single state store

[ https://issues.apache.org/jira/browse/KAFKA-14209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-14209: Labels: kip (was: ) > Optimize stream stream self join to use single state store >

[jira] [Assigned] (KAFKA-14054) Unexpected client shutdown as TimeoutException is thrown as IllegalStateException

[ https://issues.apache.org/jira/browse/KAFKA-14054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-14054: --- Assignee: Matthias J. Sax > Unexpected client shutdown as TimeoutException is

[jira] [Reopened] (KAFKA-14318) KIP-878: Autoscaling for Statically Partitioned Streams

[ https://issues.apache.org/jira/browse/KAFKA-14318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-14318: - > KIP-878: Autoscaling for Statically Partitioned Streams >

[jira] [Resolved] (KAFKA-14318) KIP-878: Autoscaling for Statically Partitioned Streams

[ https://issues.apache.org/jira/browse/KAFKA-14318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-14318. - Resolution: Fixed > KIP-878: Autoscaling for Statically Partitioned Streams >

[jira] [Resolved] (KAFKA-14318) KIP-878: Autoscaling for Statically Partitioned Streams

[ https://issues.apache.org/jira/browse/KAFKA-14318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-14318. - Resolution: Fixed > KIP-878: Autoscaling for Statically Partitioned Streams >

[jira] [Reopened] (KAFKA-14318) KIP-878: Autoscaling for Statically Partitioned Streams

[ https://issues.apache.org/jira/browse/KAFKA-14318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-14318: - > KIP-878: Autoscaling for Statically Partitioned Streams >

[jira] [Assigned] (KAFKA-14318) KIP-878: Autoscaling for Statically Partitioned Streams

[ https://issues.apache.org/jira/browse/KAFKA-14318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-14318: --- Assignee: (was: A. Sophie Blee-Goldman) > KIP-878: Autoscaling for Statically

[jira] [Updated] (KAFKA-14318) KIP-878: Autoscaling for Statically Partitioned Streams

[ https://issues.apache.org/jira/browse/KAFKA-14318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-14318: Fix Version/s: (was: 3.5.0) > KIP-878: Autoscaling for Statically Partitioned Streams

[jira] [Resolved] (KAFKA-14491) Introduce Versioned Key-Value Stores to Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-14491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-14491. - Fix Version/s: 3.5.0 Resolution: Fixed > Introduce Versioned Key-Value Stores to

[jira] [Resolved] (KAFKA-14491) Introduce Versioned Key-Value Stores to Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-14491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-14491. - Fix Version/s: 3.5.0 Resolution: Fixed > Introduce Versioned Key-Value Stores to

[jira] [Resolved] (KAFKA-14864) Memory leak in KStreamWindowAggregate with ON_WINDOW_CLOSE emit strategy

[ https://issues.apache.org/jira/browse/KAFKA-14864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-14864. - Fix Version/s: 3.4.1 3.3.3 Resolution: Fixed > Memory leak in

[jira] [Resolved] (KAFKA-14864) Memory leak in KStreamWindowAggregate with ON_WINDOW_CLOSE emit strategy

[ https://issues.apache.org/jira/browse/KAFKA-14864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-14864. - Fix Version/s: 3.4.1 3.3.3 Resolution: Fixed > Memory leak in

[jira] [Commented] (KAFKA-14722) Make BooleanSerde public

[ https://issues.apache.org/jira/browse/KAFKA-14722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17708211#comment-17708211 ] Matthias J. Sax commented on KAFKA-14722: - The docs PRs was not merged yet – thus the work is

[jira] [Updated] (KAFKA-14722) Make BooleanSerde public

[ https://issues.apache.org/jira/browse/KAFKA-14722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-14722: Fix Version/s: 3.5.0 > Make BooleanSerde public > > >

[jira] [Updated] (KAFKA-14864) Memory leak in KStreamWindowAggregate with ON_WINDOW_CLOSE emit strategy

[ https://issues.apache.org/jira/browse/KAFKA-14864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-14864: Affects Version/s: 3.3.2 3.4.0 > Memory leak in

[jira] [Updated] (KAFKA-14847) Separate the callers of commitAllTasks v.s. commitTasks for EOS(-v2) and ALOS

[ https://issues.apache.org/jira/browse/KAFKA-14847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-14847: Description: Today, EOS-v2/v1 and ALOS shares the same internal callpath inside

[jira] [Updated] (KAFKA-14847) Separate the callers of commitAllTasks v.s. commitTasks for EOS(-v2) and ALOS

[ https://issues.apache.org/jira/browse/KAFKA-14847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-14847: Description: Today, EOS-v2/v1 and ALOS shares the same internal callpath inside

[jira] [Updated] (KAFKA-14847) Separate the callers of commitAllTasks v.s. commitTasks for EOS(-v2) and ALOS

[ https://issues.apache.org/jira/browse/KAFKA-14847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-14847: Description: Today, EOS-v2/v1 and ALOS shares the same internal callpath inside

[jira] [Created] (KAFKA-14839) Exclude protected variable from JavaDocs

Matthias J. Sax created KAFKA-14839: --- Summary: Exclude protected variable from JavaDocs Key: KAFKA-14839 URL: https://issues.apache.org/jira/browse/KAFKA-14839 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-14839) Exclude protected variable from JavaDocs

Matthias J. Sax created KAFKA-14839: --- Summary: Exclude protected variable from JavaDocs Key: KAFKA-14839 URL: https://issues.apache.org/jira/browse/KAFKA-14839 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-7224) KIP-328: Add spill-to-disk for Suppression

[ https://issues.apache.org/jira/browse/KAFKA-7224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17702980#comment-17702980 ] Matthias J. Sax commented on KAFKA-7224: With

[jira] [Updated] (KAFKA-14385) Flaky Test QueryableStateIntegrationTest.shouldNotMakeStoreAvailableUntilAllStoresAvailable

[ https://issues.apache.org/jira/browse/KAFKA-14385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-14385: Priority: Critical (was: Major) > Flaky Test >

[jira] [Updated] (KAFKA-14384) Flaky Test SelfJoinUpgradeIntegrationTest.shouldUpgradeWithTopologyOptimizationOff

[ https://issues.apache.org/jira/browse/KAFKA-14384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-14384: Priority: Critical (was: Major) > Flaky Test >

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

[ https://issues.apache.org/jira/browse/KAFKA-10184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-10184: Priority: Critical (was: Minor) > Flaky >

[jira] [Updated] (KAFKA-8691) Flakey test ProcessorContextTest#shouldNotAllowToScheduleZeroMillisecondPunctuation

[ https://issues.apache.org/jira/browse/KAFKA-8691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8691: --- Priority: Critical (was: Major) > Flakey test >

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

[ https://issues.apache.org/jira/browse/KAFKA-14533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-14533: Priority: Critical (was: Major) > Flaky Test

[jira] [Assigned] (KAFKA-10688) Handle accidental truncation of repartition topics as exceptional failure

[ https://issues.apache.org/jira/browse/KAFKA-10688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-10688: --- Assignee: (was: Guozhang Wang) > Handle accidental truncation of repartition

[jira] [Assigned] (KAFKA-4969) State-store workload-aware StreamsPartitionAssignor

[ https://issues.apache.org/jira/browse/KAFKA-4969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-4969: -- Assignee: Bill Bejeck > State-store workload-aware StreamsPartitionAssignor >

[jira] [Commented] (KAFKA-14778) Kafka Streams 2.7.1 to 3.3.1 rolling upgrade with static membership triggers a rebalance

[ https://issues.apache.org/jira/browse/KAFKA-14778?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17697181#comment-17697181 ] Matthias J. Sax commented on KAFKA-14778: - Thanks for reporting this. – I believe the issue is

[jira] [Updated] (KAFKA-14722) Make BooleanSerde public

[ https://issues.apache.org/jira/browse/KAFKA-14722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-14722: Description: KIP-907:

[jira] [Updated] (KAFKA-14722) Make BooleanSerde public

[ https://issues.apache.org/jira/browse/KAFKA-14722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-14722: Labels: beginner kip newbie (was: beginner need-kip newbie) > Make BooleanSerde public >

[jira] [Updated] (KAFKA-12446) Define KGroupedTable#aggregate subtractor + adder order of execution

[ https://issues.apache.org/jira/browse/KAFKA-12446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-12446: Description: KIP-904:

[jira] [Updated] (KAFKA-12446) Define KGroupedTable#aggregate subtractor + adder order of execution

[ https://issues.apache.org/jira/browse/KAFKA-12446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-12446: Labels: kip (was: ) > Define KGroupedTable#aggregate subtractor + adder order of

[jira] [Commented] (KAFKA-14748) Relax non-null FK left-join requirement

[ https://issues.apache.org/jira/browse/KAFKA-14748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17696313#comment-17696313 ] Matthias J. Sax commented on KAFKA-14748: - Yes, the behavior would change. But make this change

[jira] [Commented] (KAFKA-9234) Consider using @Nullable and @Nonnull annotations

[ https://issues.apache.org/jira/browse/KAFKA-9234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17696306#comment-17696306 ] Matthias J. Sax commented on KAFKA-9234: Thanks for the pointer – I am not familiar with JSpecify

[jira] [Commented] (KAFKA-9234) Consider using @Nullable and @Nonnull annotations

[ https://issues.apache.org/jira/browse/KAFKA-9234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17696249#comment-17696249 ] Matthias J. Sax commented on KAFKA-9234: {quote}I just joined the community this week. {quote}

[jira] [Assigned] (KAFKA-9234) Consider using @Nullable and @Nonnull annotations

[ https://issues.apache.org/jira/browse/KAFKA-9234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-9234: -- Assignee: Ganesh Sahu (was: Manasvi Gupta) > Consider using @Nullable and @Nonnull

[jira] [Commented] (KAFKA-14748) Relax non-null FK left-join requirement

[ https://issues.apache.org/jira/browse/KAFKA-14748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695945#comment-17695945 ] Matthias J. Sax commented on KAFKA-14748: - {quote}But for table-table FK-joins, today the former

[jira] [Commented] (KAFKA-14747) FK join should record discarded subscription responses

[ https://issues.apache.org/jira/browse/KAFKA-14747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695848#comment-17695848 ] Matthias J. Sax commented on KAFKA-14747: - You would create a branch from `trunk` – for more

[jira] [Commented] (KAFKA-9234) Consider using @Nullable and @Nonnull annotations

[ https://issues.apache.org/jira/browse/KAFKA-9234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695846#comment-17695846 ] Matthias J. Sax commented on KAFKA-9234:  [~rndgstn] did look into the PRs - maybe he knows best?

[jira] [Assigned] (KAFKA-14533) Flaky Test SmokeTestDriverIntegrationTest.shouldWorkWithRebalance

[ https://issues.apache.org/jira/browse/KAFKA-14533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-14533: --- Assignee: Guozhang Wang > Flaky Test

[jira] [Commented] (KAFKA-14748) Relax non-null FK left-join requirement

[ https://issues.apache.org/jira/browse/KAFKA-14748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17694229#comment-17694229 ] Matthias J. Sax commented on KAFKA-14748: - {quote}Hence, adding a `filter` operator after the

[jira] [Reopened] (KAFKA-4106) Consumer / add configure method to PartitionAssignor interface

[ https://issues.apache.org/jira/browse/KAFKA-4106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-4106: > Consumer / add configure method to PartitionAssignor interface >

[jira] [Resolved] (KAFKA-4106) Consumer / add configure method to PartitionAssignor interface

[ https://issues.apache.org/jira/browse/KAFKA-4106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-4106. Resolution: Fixed > Consumer / add configure method to PartitionAssignor interface >

[jira] [Reopened] (KAFKA-3117) Fail test at: PlaintextConsumerTest. testAutoCommitOnRebalance

[ https://issues.apache.org/jira/browse/KAFKA-3117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-3117: > Fail test at: PlaintextConsumerTest. testAutoCommitOnRebalance >

[jira] [Resolved] (KAFKA-8177) Allow for separate connect instances to have sink connectors with the same name

[ https://issues.apache.org/jira/browse/KAFKA-8177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-8177. Resolution: Fixed > Allow for separate connect instances to have sink connectors with the

[jira] [Reopened] (KAFKA-8177) Allow for separate connect instances to have sink connectors with the same name

[ https://issues.apache.org/jira/browse/KAFKA-8177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-8177: > Allow for separate connect instances to have sink connectors with the same > name >

[jira] [Resolved] (KAFKA-5452) Aggressive log compaction ratio appears to have no negative effect on log-compacted topics

[ https://issues.apache.org/jira/browse/KAFKA-5452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-5452. Resolution: Fixed > Aggressive log compaction ratio appears to have no negative effect on

[jira] [Resolved] (KAFKA-5452) Aggressive log compaction ratio appears to have no negative effect on log-compacted topics

[ https://issues.apache.org/jira/browse/KAFKA-5452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-5452. Resolution: Fixed > Aggressive log compaction ratio appears to have no negative effect on

[jira] [Resolved] (KAFKA-4106) Consumer / add configure method to PartitionAssignor interface

[ https://issues.apache.org/jira/browse/KAFKA-4106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-4106. Resolution: Fixed > Consumer / add configure method to PartitionAssignor interface >

[jira] [Reopened] (KAFKA-4106) Consumer / add configure method to PartitionAssignor interface

[ https://issues.apache.org/jira/browse/KAFKA-4106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-4106: > Consumer / add configure method to PartitionAssignor interface >

[jira] [Reopened] (KAFKA-3117) Fail test at: PlaintextConsumerTest. testAutoCommitOnRebalance

[ https://issues.apache.org/jira/browse/KAFKA-3117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-3117: > Fail test at: PlaintextConsumerTest. testAutoCommitOnRebalance >

[jira] [Resolved] (KAFKA-6014) new consumer mirror maker halts after committing offsets to a deleted topic

[ https://issues.apache.org/jira/browse/KAFKA-6014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6014. Resolution: Fixed > new consumer mirror maker halts after committing offsets to a deleted

[jira] [Resolved] (KAFKA-8177) Allow for separate connect instances to have sink connectors with the same name

[ https://issues.apache.org/jira/browse/KAFKA-8177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-8177. Resolution: Fixed > Allow for separate connect instances to have sink connectors with the

[jira] [Reopened] (KAFKA-4187) Adding a flag to prefix topics with mirror maker

[ https://issues.apache.org/jira/browse/KAFKA-4187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-4187: > Adding a flag to prefix topics with mirror maker >

[jira] [Resolved] (KAFKA-4187) Adding a flag to prefix topics with mirror maker

[ https://issues.apache.org/jira/browse/KAFKA-4187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-4187. Resolution: Fixed > Adding a flag to prefix topics with mirror maker >

[jira] [Reopened] (KAFKA-8177) Allow for separate connect instances to have sink connectors with the same name

[ https://issues.apache.org/jira/browse/KAFKA-8177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-8177: > Allow for separate connect instances to have sink connectors with the same > name >

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