[jira] [Assigned] (KAFKA-12829) Remove Deprecated methods can classes of old Processor API

2024-08-05 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-12829: --- Assignee: Junyao Huang > Remove Deprecated methods can classes of old Processor API

[jira] [Commented] (KAFKA-16336) Remove Deprecated metric standby-process-ratio

2024-08-05 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17871123#comment-17871123 ] Matthias J. Sax commented on KAFKA-16336: - Thanks [~frankvicky] – If [~kyrmar98]

[jira] [Commented] (KAFKA-12830) Remove Deprecated constructor in TimeWindowedDeserializer and TimeWindowedSerde

2024-08-05 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17871122#comment-17871122 ] Matthias J. Sax commented on KAFKA-12830: - No need to ask – feel free to self-as

[jira] [Commented] (KAFKA-12824) Remove Deprecated method KStream#branch

2024-08-05 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17871119#comment-17871119 ] Matthias J. Sax commented on KAFKA-12824: - Go ahead. All tasks for 4.0 are unblo

[jira] [Assigned] (KAFKA-12830) Remove Deprecated constructor in TimeWindowedDeserializer and TimeWindowedSerde

2024-08-05 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-12830: --- Assignee: PoAn Yang > Remove Deprecated constructor in TimeWindowedDeserializer and

[jira] [Commented] (KAFKA-12832) Remove Deprecated methods under RocksDBGenericOptionsToDbOptionsColumnFamilyOptionsAdapter

2024-08-05 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17871121#comment-17871121 ] Matthias J. Sax commented on KAFKA-12832: - Done. You can now also self-assign ti

[jira] [Assigned] (KAFKA-12832) Remove Deprecated methods under RocksDBGenericOptionsToDbOptionsColumnFamilyOptionsAdapter

2024-08-05 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-12832: --- Assignee: 黃竣陽 > Remove Deprecated methods under > RocksDBGenericOptionsToDbOptions

[jira] [Commented] (KAFKA-16328) Remove Deprecated config from StreamsConfig

2024-08-05 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17871118#comment-17871118 ] Matthias J. Sax commented on KAFKA-16328: - Thanks for picking it up! > Remove D

[jira] [Commented] (KAFKA-17253) Remove leaking getter methods in Joined helper class

2024-08-03 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17870785#comment-17870785 ] Matthias J. Sax commented on KAFKA-17253: - Sure. No need to asked :) > Remove l

[jira] [Assigned] (KAFKA-17253) Remove leaking getter methods in Joined helper class

2024-08-03 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-17253: --- Assignee: TengYao Chi > Remove leaking getter methods in Joined helper class >

[jira] [Updated] (KAFKA-17253) Remove leaking getter methods in Joined helper class

2024-08-03 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-17253: Description: The helper class `Joined` has four getter methods `gracePeriod()`, `keySerde

[jira] [Updated] (KAFKA-17253) Remove leaking getter methods in Joined helper class

2024-08-03 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-17253: Description: The helper class `Joined` has three getter methods `keySerde()`, `valueSerde(

[jira] [Created] (KAFKA-17253) Remove leaking getter methods in Joined helper class

2024-08-03 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-17253: --- Summary: Remove leaking getter methods in Joined helper class Key: KAFKA-17253 URL: https://issues.apache.org/jira/browse/KAFKA-17253 Project: Kafka Is

[jira] [Created] (KAFKA-17253) Remove leaking getter methods in Joined helper class

2024-08-03 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-17253: --- Summary: Remove leaking getter methods in Joined helper class Key: KAFKA-17253 URL: https://issues.apache.org/jira/browse/KAFKA-17253 Project: Kafka Is

[jira] [Updated] (KAFKA-17251) KafkaStreams.cleanup() semantics unclear

2024-08-02 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-17251: Description: `KafkaStreams#cleanup()` method is designed to delete an instance local state

[jira] [Updated] (KAFKA-17251) KafkaStreams.cleanup() semantics unclear

2024-08-02 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-17251: Description: `KafkaStreams#cleanup()` method is designed to delete an instance local state

[jira] [Created] (KAFKA-17251) KafkaStreams.cleanup() semantics unclear

2024-08-02 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-17251: --- Summary: KafkaStreams.cleanup() semantics unclear Key: KAFKA-17251 URL: https://issues.apache.org/jira/browse/KAFKA-17251 Project: Kafka Issue Type: Im

[jira] [Created] (KAFKA-17251) KafkaStreams.cleanup() semantics unclear

2024-08-02 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-17251: --- Summary: KafkaStreams.cleanup() semantics unclear Key: KAFKA-17251 URL: https://issues.apache.org/jira/browse/KAFKA-17251 Project: Kafka Issue Type: Im

[jira] [Updated] (KAFKA-17248) Extend KIP-714 to allow for registering additional metrics with clients

2024-08-02 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-17248: Labels: kip (was: need-kip) > Extend KIP-714 to allow for registering additional metrics

[jira] [Updated] (KAFKA-17248) Extend KIP-714 to allow for registering additional metrics with clients

2024-08-02 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-17248: Component/s: admin clients consumer prod

[jira] [Updated] (KAFKA-17248) Extend KIP-714 to allow for registering additional metrics with clients

2024-08-02 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-17248: Description: Add new methods to the Admin, Consumer, and Producer interfaces and implement

[jira] [Updated] (KAFKA-17248) Extend KIP-714 to allow for registering additional metrics with clients

2024-08-02 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-17248: Component/s: streams > Extend KIP-714 to allow for registering additional metrics with cli

[jira] [Commented] (KAFKA-12827) Remove Deprecated method KafkaStreams#setUncaughtExceptionHandler

2024-07-31 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17870011#comment-17870011 ] Matthias J. Sax commented on KAFKA-12827: - Done. You can now also self-assign ti

[jira] [Assigned] (KAFKA-12827) Remove Deprecated method KafkaStreams#setUncaughtExceptionHandler

2024-07-31 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-12827: --- Assignee: Abhishek Giri > Remove Deprecated method KafkaStreams#setUncaughtExceptio

[jira] [Commented] (KAFKA-12823) Remove Deprecated method KStream#through

2024-07-30 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17869803#comment-17869803 ] Matthias J. Sax commented on KAFKA-12823: - Done. You can now also self-assign.

[jira] [Assigned] (KAFKA-12823) Remove Deprecated method KStream#through

2024-07-30 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-12823: --- Assignee: Arnav Dadarya > Remove Deprecated method KStream#through > --

[jira] [Commented] (KAFKA-16863) Consider removing `default.` prefix for exception handler config

2024-07-30 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17869792#comment-17869792 ] Matthias J. Sax commented on KAFKA-16863: - [~muralibasani] – `trunk` was bumped

[jira] [Created] (KAFKA-17224) Make ForeachProcessor internal

2024-07-30 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-17224: --- Summary: Make ForeachProcessor internal Key: KAFKA-17224 URL: https://issues.apache.org/jira/browse/KAFKA-17224 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-17224) Make ForeachProcessor internal

2024-07-30 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-17224: --- Summary: Make ForeachProcessor internal Key: KAFKA-17224 URL: https://issues.apache.org/jira/browse/KAFKA-17224 Project: Kafka Issue Type: Improvement

[jira] [Comment Edited] (KAFKA-17216) StreamsConfig STATE_DIR_CONFIG

2024-07-30 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17869781#comment-17869781 ] Matthias J. Sax edited comment on KAFKA-17216 at 7/31/24 12:53 AM: ---

[jira] [Commented] (KAFKA-17216) StreamsConfig STATE_DIR_CONFIG

2024-07-30 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17869781#comment-17869781 ] Matthias J. Sax commented on KAFKA-17216: - Just saw this other comment: [https:

[jira] [Commented] (KAFKA-16332) Remove Deprecated builder methods for Time/Session/Join/SlidingWindows

2024-07-30 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17869780#comment-17869780 ] Matthias J. Sax commented on KAFKA-16332: - Yes, feel free to pickup this ticket.

[jira] [Commented] (KAFKA-16508) Infinite loop if output topic does not exisit

2024-07-30 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17869779#comment-17869779 ] Matthias J. Sax commented on KAFKA-16508: - Updated fix version to 4.0.0 as discu

[jira] [Updated] (KAFKA-16508) Infinite loop if output topic does not exisit

2024-07-30 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-16508: Fix Version/s: 4.0.0 (was: 3.9.0) > Infinite loop if output topic d

[jira] [Commented] (KAFKA-16336) Remove Deprecated metric standby-process-ratio

2024-07-30 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17869771#comment-17869771 ] Matthias J. Sax commented on KAFKA-16336: - [~kyrmar98] – The 3.9 release branch

[jira] [Commented] (KAFKA-16333) Removed Deprecated methods KTable#join

2024-07-30 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17869769#comment-17869769 ] Matthias J. Sax commented on KAFKA-16333: - [~muralibasani] – The 3.9 release bra

[jira] [Commented] (KAFKA-16334) Remove Deprecated command line option from reset tool

2024-07-30 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17869770#comment-17869770 ] Matthias J. Sax commented on KAFKA-16334: - [~caioguedes] – The 3.9 release branc

[jira] [Commented] (KAFKA-16329) Remove Deprecated Task/ThreadMetadata classes and related methods

2024-07-30 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17869767#comment-17869767 ] Matthias J. Sax commented on KAFKA-16329: - [~muralibasani] – The 3.9 release bra

[jira] [Commented] (KAFKA-16330) Remove Deprecated methods/variables from TaskId

2024-07-30 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17869768#comment-17869768 ] Matthias J. Sax commented on KAFKA-16330: - [~muralibasani] – The 3.9 release bra

[jira] [Commented] (KAFKA-12831) Remove Deprecated method StateStore#init

2024-07-30 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17869766#comment-17869766 ] Matthias J. Sax commented on KAFKA-12831: - [~vvakati] – The 3.9 release branch w

[jira] [Commented] (KAFKA-12829) Remove Deprecated methods can classes of old Processor API

2024-07-30 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17869765#comment-17869765 ] Matthias J. Sax commented on KAFKA-12829: - [~pegasas] – The 3.9 release branch w

[jira] [Commented] (KAFKA-12823) Remove Deprecated method KStream#through

2024-07-30 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17869763#comment-17869763 ] Matthias J. Sax commented on KAFKA-12823: - [~ardada2468] – The 3.9 release branc

[jira] [Commented] (KAFKA-12826) Remove Deprecated Class Serdes (Streams)

2024-07-30 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17869764#comment-17869764 ] Matthias J. Sax commented on KAFKA-12826: - [~shiqin.lan] The 3.9 release branch

[jira] [Commented] (KAFKA-12689) Remove deprecated EOS configs

2024-07-30 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17869762#comment-17869762 ] Matthias J. Sax commented on KAFKA-12689: - After some more discussion, I believe

[jira] [Commented] (KAFKA-12822) Remove Deprecated APIs of Kafka Streams in 4.0

2024-07-30 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17869761#comment-17869761 ] Matthias J. Sax commented on KAFKA-12822: - The 3.9 release branch was cut now an

[jira] [Commented] (KAFKA-16327) Remove Deprecated variable StreamsConfig#TOPOLOGY_OPTIMIZATION

2024-07-30 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17869760#comment-17869760 ] Matthias J. Sax commented on KAFKA-16327: - [~ksolves.kafka] – The 3.9 release br

[jira] [Commented] (KAFKA-17215) Remove get-prefix for all getters

2024-07-30 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17869759#comment-17869759 ] Matthias J. Sax commented on KAFKA-17215: - I cannot help with creating a Conflue

[jira] [Commented] (KAFKA-17216) StreamsConfig STATE_DIR_CONFIG

2024-07-30 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17869758#comment-17869758 ] Matthias J. Sax commented on KAFKA-17216: - The only PR which comes to mind with

[jira] [Commented] (KAFKA-17214) Add 3.8.0 Streams and Core to system tests

2024-07-30 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17869756#comment-17869756 ] Matthias J. Sax commented on KAFKA-17214: - Thanks a ton [~jlprat]! > Add 3.8.0

[jira] [Updated] (KAFKA-17216) StreamsConfig STATE_DIR_CONFIG

2024-07-30 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-17216: Component/s: streams > StreamsConfig STATE_DIR_CONFIG > -- > >

[jira] [Commented] (KAFKA-17214) Add 3.8.0 Streams and Core to system tests

2024-07-29 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17869487#comment-17869487 ] Matthias J. Sax commented on KAFKA-17214: - As we already have a 3.9 branch, PR f

[jira] [Updated] (KAFKA-17214) Add 3.8.0 Streams and Core to system tests

2024-07-29 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-17214: Component/s: clients consumer core produ

[jira] [Updated] (KAFKA-17215) Remove get-prefix for all getters

2024-07-29 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-17215: Description: Kafka traditionally does not use a `get` prefix for getter methods. However,

[jira] [Updated] (KAFKA-17215) Remove get-prefix for all getters

2024-07-29 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-17215: Description: Kafka traditionally does not use a `get` prefix for getter methods. However,

[jira] [Updated] (KAFKA-17215) Remove get-prefix for all getters

2024-07-29 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-17215: Description: Kafka traditionally does not use a `get` prefix for getter methods. However,

[jira] [Created] (KAFKA-17215) Remove get-prefix for all getters

2024-07-29 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-17215: --- Summary: Remove get-prefix for all getters Key: KAFKA-17215 URL: https://issues.apache.org/jira/browse/KAFKA-17215 Project: Kafka Issue Type: Improveme

[jira] [Created] (KAFKA-17215) Remove get-prefix for all getters

2024-07-29 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-17215: --- Summary: Remove get-prefix for all getters Key: KAFKA-17215 URL: https://issues.apache.org/jira/browse/KAFKA-17215 Project: Kafka Issue Type: Improveme

[jira] [Assigned] (KAFKA-17112) StreamThread shutdown calls completeShutdown only in CREATED state

2024-07-26 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-17112: --- Assignee: Ao Li > StreamThread shutdown calls completeShutdown only in CREATED stat

[jira] [Resolved] (KAFKA-17204) KafkaStreamsCloseOptionsIntegrationTest.before leaks AdminClient

2024-07-26 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-17204. - Fix Version/s: 3.9.0 Resolution: Fixed > KafkaStreamsCloseOptionsIntegrationTest.

[jira] [Resolved] (KAFKA-17204) KafkaStreamsCloseOptionsIntegrationTest.before leaks AdminClient

2024-07-26 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-17204. - Fix Version/s: 3.9.0 Resolution: Fixed > KafkaStreamsCloseOptionsIntegrationTest.

[jira] [Assigned] (KAFKA-17203) StreamThread leaking producer instances

2024-07-26 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-17203: --- Assignee: PoAn Yang > StreamThread leaking producer instances > ---

[jira] [Commented] (KAFKA-17203) StreamThread leaking producer instances

2024-07-26 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868995#comment-17868995 ] Matthias J. Sax commented on KAFKA-17203: - Thanks for your interest! Go for it!

[jira] [Assigned] (KAFKA-17202) EosIntegrationTest.verifyChangelogMaxRecordOffsetMatchesCheckpointedOffset leaks consumers

2024-07-26 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-17202: --- Assignee: TengYao Chi > EosIntegrationTest.verifyChangelogMaxRecordOffsetMatchesChe

[jira] [Commented] (KAFKA-17202) EosIntegrationTest.verifyChangelogMaxRecordOffsetMatchesCheckpointedOffset leaks consumers

2024-07-26 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868993#comment-17868993 ] Matthias J. Sax commented on KAFKA-17202: - Thanks for your interest to pick it u

[jira] [Commented] (KAFKA-16263) Add Kafka Streams docs about available listeners/callback

2024-07-25 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868808#comment-17868808 ] Matthias J. Sax commented on KAFKA-16263: - It seems [~brandboat] and [~w4lt] are

[jira] [Resolved] (KAFKA-17054) test

2024-07-25 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-17054. - Resolution: Invalid > test > > > Key: KAFKA-17054 >

[jira] [Commented] (KAFKA-13501) Avoid state restore via rebalance if standbys are enabled

2024-07-25 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868807#comment-17868807 ] Matthias J. Sax commented on KAFKA-13501: - It's some not so easy to reproduce ca

[jira] [Resolved] (KAFKA-17054) test

2024-07-25 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-17054. - Resolution: Invalid > test > > > Key: KAFKA-17054 >

[jira] [Commented] (KAFKA-13501) Avoid state restore via rebalance if standbys are enabled

2024-07-22 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17867880#comment-17867880 ] Matthias J. Sax commented on KAFKA-13501: - I don't think state updated solve thi

[jira] [Created] (KAFKA-17178) Update KTable.transformValues to new Processor API

2024-07-21 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-17178: --- Summary: Update KTable.transformValues to new Processor API Key: KAFKA-17178 URL: https://issues.apache.org/jira/browse/KAFKA-17178 Project: Kafka Issu

[jira] [Created] (KAFKA-17178) Update KTable.transformValues to new Processor API

2024-07-21 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-17178: --- Summary: Update KTable.transformValues to new Processor API Key: KAFKA-17178 URL: https://issues.apache.org/jira/browse/KAFKA-17178 Project: Kafka Issu

[jira] [Created] (KAFKA-17164) Consider to enforce application.server : format at config level

2024-07-18 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-17164: --- Summary: Consider to enforce application.server : format at config level Key: KAFKA-17164 URL: https://issues.apache.org/jira/browse/KAFKA-17164 Project: Kafka

[jira] [Created] (KAFKA-17164) Consider to enforce application.server : format at config level

2024-07-18 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-17164: --- Summary: Consider to enforce application.server : format at config level Key: KAFKA-17164 URL: https://issues.apache.org/jira/browse/KAFKA-17164 Project: Kafka

[jira] [Updated] (KAFKA-15379) Add option for Grace period Joins to disable changelog creation

2024-07-18 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-15379: Labels: needs-kip (was: kip) > Add option for Grace period Joins to disable changelog cre

[jira] [Updated] (KAFKA-16038) Periodic Logging of Current Assignment

2024-07-18 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-16038: Labels: needs-kip (was: ) > Periodic Logging of Current Assignment >

[jira] [Updated] (KAFKA-17125) Streams Rebalance Protocol

2024-07-12 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-17125: Labels: kip (was: ) > Streams Rebalance Protocol > --- > >

[jira] [Updated] (KAFKA-17125) Streams Rebalance Protocol

2024-07-12 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-17125: Issue Type: New Feature (was: Task) > Streams Rebalance Protocol > -

[jira] [Created] (KAFKA-17131) Cleanup `ProcessorContext` an related interfaces

2024-07-12 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-17131: --- Summary: Cleanup `ProcessorContext` an related interfaces Key: KAFKA-17131 URL: https://issues.apache.org/jira/browse/KAFKA-17131 Project: Kafka Issue

[jira] [Created] (KAFKA-17131) Cleanup `ProcessorContext` an related interfaces

2024-07-12 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-17131: --- Summary: Cleanup `ProcessorContext` an related interfaces Key: KAFKA-17131 URL: https://issues.apache.org/jira/browse/KAFKA-17131 Project: Kafka Issue

[jira] [Resolved] (KAFKA-10356) Handle accidental deletion of sink-topics as exceptional failure

2024-07-11 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-10356. - Resolution: Not A Problem > Handle accidental deletion of sink-topics as exceptional fai

[jira] [Resolved] (KAFKA-10356) Handle accidental deletion of sink-topics as exceptional failure

2024-07-11 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-10356. - Resolution: Not A Problem > Handle accidental deletion of sink-topics as exceptional fai

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

2024-07-11 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17865263#comment-17865263 ] Matthias J. Sax commented on KAFKA-10356: - Talked to a few people, and there was

[jira] [Updated] (KAFKA-9738) Add Generics Type Parameters to forwarded() in MockProcessorContext

2024-07-11 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9738: --- Description: The method {{forwarded()}} to capture the forwarded records in {{MockProcessorC

[jira] [Updated] (KAFKA-9738) Add Generics Type Parameters to forwarded() in MockProcessorContext

2024-07-11 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9738: --- Labels: kip (was: ) > Add Generics Type Parameters to forwarded() in MockProcessorContext >

[jira] [Assigned] (KAFKA-9738) Add Generics Type Parameters to forwarded() in MockProcessorContext

2024-07-11 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-9738: -- Assignee: Matthias J. Sax > Add Generics Type Parameters to forwarded() in MockProcess

[jira] [Commented] (KAFKA-9738) Add Generics Type Parameters to forwarded() in MockProcessorContext

2024-07-11 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17865145#comment-17865145 ] Matthias J. Sax commented on KAFKA-9738: Given that `Processor` is deprecated alr

[jira] [Resolved] (KAFKA-10814) improving ability of handling exception in kafka

2024-07-11 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-10814. - Resolution: Incomplete Unclear what the problem is. Closing. > improving ability of han

[jira] [Resolved] (KAFKA-10814) improving ability of handling exception in kafka

2024-07-11 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-10814. - Resolution: Incomplete Unclear what the problem is. Closing. > improving ability of han

[jira] [Updated] (KAFKA-6197) Difficult to get to the Kafka Streams javadocs

2024-07-10 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6197: --- Labels: beginner newbie (was: ) > Difficult to get to the Kafka Streams javadocs > -

[jira] [Resolved] (KAFKA-8629) Kafka Streams Apps to support small native images through GraalVM

2024-07-10 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-8629. Resolution: Fixed GraalVM should work with KS now. > Kafka Streams Apps to support small n

[jira] [Resolved] (KAFKA-8629) Kafka Streams Apps to support small native images through GraalVM

2024-07-10 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-8629. Resolution: Fixed GraalVM should work with KS now. > Kafka Streams Apps to support small n

[jira] [Commented] (KAFKA-9738) Add Generics Type Parameters to forwarded() in MockProcessorContext

2024-07-10 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864883#comment-17864883 ] Matthias J. Sax commented on KAFKA-9738: [~cadonna] – I believe this is fixed wit

[jira] [Resolved] (KAFKA-13326) Add multi-cluster support to Kafka Streams

2024-07-10 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-13326. - Resolution: Duplicate > Add multi-cluster support to Kafka Streams > ---

[jira] [Resolved] (KAFKA-13326) Add multi-cluster support to Kafka Streams

2024-07-10 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-13326. - Resolution: Duplicate > Add multi-cluster support to Kafka Streams > ---

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

2024-07-10 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864879#comment-17864879 ] Matthias J. Sax commented on KAFKA-10356: - Is the description of this ticket sti

[jira] [Assigned] (KAFKA-15595) Session window aggregate drops records headers

2024-07-10 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-15595: --- Assignee: (was: Hao Li) > Session window aggregate drops records headers >

[jira] [Reopened] (KAFKA-13183) Dropping nul key/value records upstream to repartiton topic not tracked via metrics

2024-07-10 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-13183: - > Dropping nul key/value records upstream to repartiton topic not tracked via > metrics > -

[jira] [Assigned] (KAFKA-13183) Dropping nul key/value records upstream to repartiton topic not tracked via metrics

2024-07-10 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-13183: --- Assignee: (was: Alex Sorokoumov) > Dropping nul key/value records upstream to r

[jira] [Reopened] (KAFKA-13183) Dropping nul key/value records upstream to repartiton topic not tracked via metrics

2024-07-10 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-13183: - > Dropping nul key/value records upstream to repartiton topic not tracked via > metrics > -

[jira] [Resolved] (KAFKA-13183) Dropping nul key/value records upstream to repartiton topic not tracked via metrics

2024-07-10 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-13183. - Resolution: Fixed > Dropping nul key/value records upstream to repartiton topic not trac

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