[jira] [Commented] (KAFKA-14279) Add 3.3.1 to broker/client and stream upgrade/compatibility tests

[ https://issues.apache.org/jira/browse/KAFKA-14279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17653254#comment-17653254 ] A. Sophie Blee-Goldman commented on KAFKA-14279: Temporarily bumping to 3.5 so I can run

[jira] [Updated] (KAFKA-14279) Add 3.3.1 to broker/client and stream upgrade/compatibility tests

[ https://issues.apache.org/jira/browse/KAFKA-14279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-14279: --- Fix Version/s: 3.5.0 (was: 3.4.0) > Add 3.3.1 to

[jira] [Commented] (KAFKA-12886) Enable request forwarding by default

[ https://issues.apache.org/jira/browse/KAFKA-12886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17653253#comment-17653253 ] A. Sophie Blee-Goldman commented on KAFKA-12886: Temporarily bumping to 3.5 so I can run

[jira] [Updated] (KAFKA-14175) KRaft Upgrades Part 2

[ https://issues.apache.org/jira/browse/KAFKA-14175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-14175: --- Fix Version/s: 3.5.0 > KRaft Upgrades Part 2 > - > >

[jira] [Updated] (KAFKA-12886) Enable request forwarding by default

[ https://issues.apache.org/jira/browse/KAFKA-12886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12886: --- Fix Version/s: 3.5.0 (was: 3.4.0) > Enable request

[jira] [Updated] (KAFKA-14305) KRaft Metadata Transactions

[ https://issues.apache.org/jira/browse/KAFKA-14305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-14305: --- Fix Version/s: 3.5.0 (was: 3.4.0) > KRaft Metadata

[jira] [Updated] (KAFKA-14175) KRaft Upgrades Part 2

[ https://issues.apache.org/jira/browse/KAFKA-14175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-14175: --- Fix Version/s: (was: 3.4.0) > KRaft Upgrades Part 2 >

[jira] [Commented] (KAFKA-12622) Automate LICENSE file validation

[ https://issues.apache.org/jira/browse/KAFKA-12622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17653252#comment-17653252 ] A. Sophie Blee-Goldman commented on KAFKA-12622: Updates for 3.4:

[jira] [Updated] (KAFKA-12622) Automate LICENSE file validation

[ https://issues.apache.org/jira/browse/KAFKA-12622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12622: --- Fix Version/s: 3.5.0 (was: 3.4.0) > Automate LICENSE

[jira] [Updated] (KAFKA-14498) flaky org.apache.kafka.tools.MetadataQuorumCommandTest

[ https://issues.apache.org/jira/browse/KAFKA-14498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-14498: --- Fix Version/s: 3.4.0 (was: 3.5.0) > flaky

[jira] [Commented] (KAFKA-13295) Long restoration times for new tasks can lead to transaction timeouts

[ https://issues.apache.org/jira/browse/KAFKA-13295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17653025#comment-17653025 ] A. Sophie Blee-Goldman commented on KAFKA-13295: [~mjsax] unfortunately no, it's a

[jira] [Updated] (KAFKA-13295) Long restoration times for new tasks can lead to transaction timeouts

[ https://issues.apache.org/jira/browse/KAFKA-13295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-13295: --- Fix Version/s: 3.5.0 > Long restoration times for new tasks can lead to

[jira] [Commented] (KAFKA-14555) Segfault in RocksDB DumpDataBlocks

[ https://issues.apache.org/jira/browse/KAFKA-14555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17653024#comment-17653024 ] A. Sophie Blee-Goldman commented on KAFKA-14555: [~gharris1727] can you open a new issue

[jira] [Commented] (KAFKA-14404) Fix & update docs on client configs controlled by Streams

[ https://issues.apache.org/jira/browse/KAFKA-14404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17653022#comment-17653022 ] A. Sophie Blee-Goldman commented on KAFKA-14404: [~sujayopensource]  that would be

[jira] [Commented] (KAFKA-14459) Document how to use and close a 'Statistics' in the example RocksDBConfigSetter

[ https://issues.apache.org/jira/browse/KAFKA-14459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17653021#comment-17653021 ] A. Sophie Blee-Goldman commented on KAFKA-14459: [~sujayopensource] go for it! Let me

[jira] [Commented] (KAFKA-14419) Same message consumed again by the same stream task after partition is lost and reassigned

[ https://issues.apache.org/jira/browse/KAFKA-14419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17653017#comment-17653017 ] A. Sophie Blee-Goldman commented on KAFKA-14419: Hm. Could you try and reproduce the

[jira] [Resolved] (KAFKA-13602) Allow to broadcast a result record

[ https://issues.apache.org/jira/browse/KAFKA-13602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman resolved KAFKA-13602. Resolution: Fixed > Allow to broadcast a result record >

[jira] [Updated] (KAFKA-13602) Allow to broadcast a result record

[ https://issues.apache.org/jira/browse/KAFKA-13602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-13602: --- Fix Version/s: 3.4.0 (was: 3.5.0) > Allow to

[jira] [Created] (KAFKA-14539) Simplify StreamsMetadataState by replacing the Cluster metadata with partition info map

A. Sophie Blee-Goldman created KAFKA-14539: -- Summary: Simplify StreamsMetadataState by replacing the Cluster metadata with partition info map Key: KAFKA-14539 URL:

[jira] [Updated] (KAFKA-14077) KRaft should support recovery from failed disk

[ https://issues.apache.org/jira/browse/KAFKA-14077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-14077: --- Fix Version/s: 3.5.0 (was: 3.4.0) > KRaft should

[jira] [Updated] (KAFKA-13602) Allow to broadcast a result record

[ https://issues.apache.org/jira/browse/KAFKA-13602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-13602: --- Fix Version/s: 3.5.0 (was: 3.4.0) > Allow to

[jira] [Updated] (KAFKA-13602) Allow to broadcast a result record

[ https://issues.apache.org/jira/browse/KAFKA-13602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-13602: --- Labels: kip newbie++ (was: needs-kip newbie++) > Allow to broadcast a

[jira] [Reopened] (KAFKA-13602) Allow to broadcast a result record

[ https://issues.apache.org/jira/browse/KAFKA-13602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman reopened KAFKA-13602: Reverting in 3.4 due to logging-related perf/security issue, and some open

[jira] [Commented] (KAFKA-12319) Flaky test ConnectionQuotasTest.testListenerConnectionRateLimitWhenActualRateAboveLimit()

[ https://issues.apache.org/jira/browse/KAFKA-12319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17647830#comment-17647830 ] A. Sophie Blee-Goldman commented on KAFKA-12319: bumping this to 3.5.0 as we are past

[jira] [Updated] (KAFKA-8280) Flaky Test DynamicBrokerReconfigurationTest#testUncleanLeaderElectionEnable

[ https://issues.apache.org/jira/browse/KAFKA-8280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-8280: -- Fix Version/s: 3.5.0 (was: 3.4.0) > Flaky Test

[jira] [Updated] (KAFKA-6527) Transient failure in DynamicBrokerReconfigurationTest.testDefaultTopicConfig

[ https://issues.apache.org/jira/browse/KAFKA-6527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-6527: -- Fix Version/s: 3.5.0 (was: 3.4.0) > Transient failure

[jira] [Updated] (KAFKA-7957) Flaky Test DynamicBrokerReconfigurationTest#testMetricsReporterUpdate

[ https://issues.apache.org/jira/browse/KAFKA-7957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-7957: -- Fix Version/s: 3.5.0 (was: 3.4.0) > Flaky Test

[jira] [Updated] (KAFKA-12319) Flaky test ConnectionQuotasTest.testListenerConnectionRateLimitWhenActualRateAboveLimit()

[ https://issues.apache.org/jira/browse/KAFKA-12319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12319: --- Fix Version/s: 3.5.0 (was: 3.4.0) > Flaky test >

[jira] [Commented] (KAFKA-13421) Fix ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

[ https://issues.apache.org/jira/browse/KAFKA-13421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17647828#comment-17647828 ] A. Sophie Blee-Goldman commented on KAFKA-13421: bumping this to 3.5.0 as we are past

[jira] [Updated] (KAFKA-13421) Fix ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

[ https://issues.apache.org/jira/browse/KAFKA-13421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-13421: --- Fix Version/s: 3.5.0 (was: 3.4.0) > Fix >

[jira] [Resolved] (KAFKA-13736) Flaky kafka.network.SocketServerTest.closingChannelWithBufferedReceives

[ https://issues.apache.org/jira/browse/KAFKA-13736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman resolved KAFKA-13736. Resolution: Fixed > Flaky

[jira] [Updated] (KAFKA-13736) Flaky kafka.network.SocketServerTest.closingChannelWithBufferedReceives

[ https://issues.apache.org/jira/browse/KAFKA-13736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-13736: --- Fix Version/s: (was: 3.4.0) > Flaky

[jira] [Commented] (KAFKA-13950) Resource leak at multiple places in the code

[ https://issues.apache.org/jira/browse/KAFKA-13950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17647827#comment-17647827 ] A. Sophie Blee-Goldman commented on KAFKA-13950: Bumping this to 3.5.0 as we are past

[jira] [Updated] (KAFKA-13950) Resource leak at multiple places in the code

[ https://issues.apache.org/jira/browse/KAFKA-13950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-13950: --- Fix Version/s: 3.5.0 (was: 3.4.0) > Resource leak at

[jira] [Commented] (KAFKA-14186) Add unit tests for BatchFileWriter

[ https://issues.apache.org/jira/browse/KAFKA-14186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17647826#comment-17647826 ] A. Sophie Blee-Goldman commented on KAFKA-14186: [~mumrah] bumping this to 3.5.0 as we

[jira] [Updated] (KAFKA-14241) Implement the snapshot cleanup policy

[ https://issues.apache.org/jira/browse/KAFKA-14241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-14241: --- Fix Version/s: 3.5.0 (was: 3.4.0) > Implement the

[jira] [Updated] (KAFKA-14186) Add unit tests for BatchFileWriter

[ https://issues.apache.org/jira/browse/KAFKA-14186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-14186: --- Fix Version/s: 3.5.0 (was: 3.4.0) > Add unit tests

[jira] [Updated] (KAFKA-13588) We should consolidate `changelogFor` methods to simplify the generation of internal topic names

[ https://issues.apache.org/jira/browse/KAFKA-13588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-13588: --- Fix Version/s: 4.0.0 (was: 3.4.0) > We should

[jira] [Commented] (KAFKA-7109) KafkaConsumer should close its incremental fetch sessions on close

[ https://issues.apache.org/jira/browse/KAFKA-7109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17647825#comment-17647825 ] A. Sophie Blee-Goldman commented on KAFKA-7109: --- bumping this to 3.5.0 as we are past code

[jira] [Updated] (KAFKA-7109) KafkaConsumer should close its incremental fetch sessions on close

[ https://issues.apache.org/jira/browse/KAFKA-7109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-7109: -- Fix Version/s: 3.5.0 (was: 3.4.0) > KafkaConsumer

[jira] [Resolved] (KAFKA-4852) ByteBufferSerializer not compatible with offsets

[ https://issues.apache.org/jira/browse/KAFKA-4852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman resolved KAFKA-4852. --- Resolution: Fixed > ByteBufferSerializer not compatible with offsets >

[jira] [Commented] (KAFKA-4852) ByteBufferSerializer not compatible with offsets

[ https://issues.apache.org/jira/browse/KAFKA-4852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17647824#comment-17647824 ] A. Sophie Blee-Goldman commented on KAFKA-4852: --- [~LSK] [~wdaehn] is there a reason this

[jira] [Commented] (KAFKA-14418) Add safety checks for modifying partitions of __consumer_offsets

[ https://issues.apache.org/jira/browse/KAFKA-14418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17647822#comment-17647822 ] A. Sophie Blee-Goldman commented on KAFKA-14418: [~divijvaidya] I just went ahead and

[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 ] A. Sophie Blee-Goldman updated KAFKA-14318: --- Fix Version/s: 3.5.0 (was: 3.4.0) > KIP-878:

[jira] [Updated] (KAFKA-14418) Add safety checks for modifying partitions of __consumer_offsets

[ https://issues.apache.org/jira/browse/KAFKA-14418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-14418: --- Fix Version/s: (was: 3.4.0) > Add safety checks for modifying

[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 ] A. Sophie Blee-Goldman updated KAFKA-14318: --- Labels: kip (was: needs-kip) > KIP-878: Autoscaling for Statically

[jira] [Updated] (KAFKA-14302) Infinite probing rebalance if a changelog topic got emptied

[ https://issues.apache.org/jira/browse/KAFKA-14302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-14302: --- Fix Version/s: 3.5.0 (was: 3.4.0) > Infinite probing

[jira] [Commented] (KAFKA-14302) Infinite probing rebalance if a changelog topic got emptied

[ https://issues.apache.org/jira/browse/KAFKA-14302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17647820#comment-17647820 ] A. Sophie Blee-Goldman commented on KAFKA-14302: I did look into this briefly but it was

[jira] [Commented] (KAFKA-14241) Implement the snapshot cleanup policy

[ https://issues.apache.org/jira/browse/KAFKA-14241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17647819#comment-17647819 ] A. Sophie Blee-Goldman commented on KAFKA-14241: [~jagsancio]  bumping this to 3.5.0 as

[jira] [Updated] (KAFKA-14139) Replaced disk can lead to loss of committed data even with non-empty ISR

[ https://issues.apache.org/jira/browse/KAFKA-14139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-14139: --- Fix Version/s: 3.5.0 (was: 3.4.0) > Replaced disk

[jira] [Updated] (KAFKA-14094) KIP-853: KRaft Voters Change

[ https://issues.apache.org/jira/browse/KAFKA-14094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-14094: --- Fix Version/s: 3.5.0 (was: 3.4.0) > KIP-853: KRaft

[jira] [Commented] (KAFKA-14139) Replaced disk can lead to loss of committed data even with non-empty ISR

[ https://issues.apache.org/jira/browse/KAFKA-14139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17647817#comment-17647817 ] A. Sophie Blee-Goldman commented on KAFKA-14139: [~hachikuji]  bumping this to 3.5.0 as

[jira] [Commented] (KAFKA-14094) KIP-853: KRaft Voters Change

[ https://issues.apache.org/jira/browse/KAFKA-14094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17647816#comment-17647816 ] A. Sophie Blee-Goldman commented on KAFKA-14094: [~jagsancio] bumping this to 3.5.0 as

[jira] [Resolved] (KAFKA-14291) KRaft: ApiVersionsResponse doesn't have finalizedFeatures and finalizedFeatureEpoch in KRaft mode

[ https://issues.apache.org/jira/browse/KAFKA-14291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman resolved KAFKA-14291. Resolution: Duplicate Marking this as a duplicate of KAFKA-13990 as

[jira] [Commented] (KAFKA-14145) Faster propagation of high-watermark in KRaft topic partitions

[ https://issues.apache.org/jira/browse/KAFKA-14145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17647815#comment-17647815 ] A. Sophie Blee-Goldman commented on KAFKA-14145: [~jagsancio]  moving this to 3.5.0

[jira] [Updated] (KAFKA-14145) Faster propagation of high-watermark in KRaft topic partitions

[ https://issues.apache.org/jira/browse/KAFKA-14145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-14145: --- Fix Version/s: 3.5.0 (was: 3.4.0) > Faster

[jira] [Updated] (KAFKA-7632) Support Compression Level

[ https://issues.apache.org/jira/browse/KAFKA-7632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-7632: -- Fix Version/s: (was: 3.4.0) > Support Compression Level >

[jira] [Updated] (KAFKA-14291) KRaft: ApiVersionsResponse doesn't have finalizedFeatures and finalizedFeatureEpoch in KRaft mode

[ https://issues.apache.org/jira/browse/KAFKA-14291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-14291: --- Fix Version/s: (was: 3.4.0) > KRaft: ApiVersionsResponse doesn't have

[jira] [Commented] (KAFKA-7632) Support Compression Level

[ https://issues.apache.org/jira/browse/KAFKA-7632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17647813#comment-17647813 ] A. Sophie Blee-Goldman commented on KAFKA-7632: --- [~dongjin]  Removing the target version as

[jira] [Commented] (KAFKA-12399) Deprecate Log4J Appender

[ https://issues.apache.org/jira/browse/KAFKA-12399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17647811#comment-17647811 ] A. Sophie Blee-Goldman commented on KAFKA-12399: [~dongjin] moving this to 3.5.0 since

[jira] [Updated] (KAFKA-12399) Deprecate Log4J Appender

[ https://issues.apache.org/jira/browse/KAFKA-12399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12399: --- Fix Version/s: 3.5.0 (was: 3.4.0) > Deprecate Log4J

[jira] [Updated] (KAFKA-12679) Rebalancing a restoring or running task may cause directory livelocking with newly created task

[ https://issues.apache.org/jira/browse/KAFKA-12679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12679: --- Fix Version/s: (was: 3.4.0) > Rebalancing a restoring or running task

[jira] [Commented] (KAFKA-13299) Accept listeners that have the same port but use IPv4 vs IPv6

[ https://issues.apache.org/jira/browse/KAFKA-13299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17647810#comment-17647810 ] A. Sophie Blee-Goldman commented on KAFKA-13299: [~mdedetrich-aiven] moving this to

[jira] [Updated] (KAFKA-13299) Accept listeners that have the same port but use IPv4 vs IPv6

[ https://issues.apache.org/jira/browse/KAFKA-13299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-13299: --- Fix Version/s: 3.5.0 (was: 3.4.0) > Accept listeners

[jira] [Commented] (KAFKA-13891) sync group failed with rebalanceInProgress error cause rebalance many rounds in coopeartive

[ https://issues.apache.org/jira/browse/KAFKA-13891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17647809#comment-17647809 ] A. Sophie Blee-Goldman commented on KAFKA-13891: Bumping this to 3.5.0 since we're past

[jira] [Updated] (KAFKA-13891) sync group failed with rebalanceInProgress error cause rebalance many rounds in coopeartive

[ https://issues.apache.org/jira/browse/KAFKA-13891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-13891: --- Fix Version/s: 3.5.0 (was: 3.4.0) > sync group

[jira] [Updated] (KAFKA-14038) Optimize calculation of size for log in remote tier

[ https://issues.apache.org/jira/browse/KAFKA-14038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-14038: --- Fix Version/s: 3.5.0 (was: 3.4.0) > Optimize

[jira] [Commented] (KAFKA-14038) Optimize calculation of size for log in remote tier

[ https://issues.apache.org/jira/browse/KAFKA-14038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17647807#comment-17647807 ] A. Sophie Blee-Goldman commented on KAFKA-14038: [~divijvaidya]  bumped to 3.5 as we are

[jira] [Commented] (KAFKA-14077) KRaft should support recovery from failed disk

[ https://issues.apache.org/jira/browse/KAFKA-14077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17647805#comment-17647805 ] A. Sophie Blee-Goldman commented on KAFKA-14077: [~hachikuji] [~jagsancio] what's the

[jira] [Commented] (KAFKA-14279) Add 3.3.1 to broker/client and stream upgrade/compatibility tests

[ https://issues.apache.org/jira/browse/KAFKA-14279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17647804#comment-17647804 ] A. Sophie Blee-Goldman commented on KAFKA-14279: [~jsancio] why is this marked as a

[jira] [Updated] (KAFKA-12473) Make the "cooperative-sticky, range" as the default assignor

[ https://issues.apache.org/jira/browse/KAFKA-12473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-12473: --- Fix Version/s: 3.5.0 (was: 3.4.0) > Make the

[jira] [Commented] (KAFKA-12886) Enable request forwarding by default

[ https://issues.apache.org/jira/browse/KAFKA-12886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17647800#comment-17647800 ] A. Sophie Blee-Goldman commented on KAFKA-12886: [~hachikuji] [~jagsancio] what's the

[jira] [Commented] (KAFKA-14260) InMemoryKeyValueStore iterator still throws ConcurrentModificationException

[ https://issues.apache.org/jira/browse/KAFKA-14260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17645545#comment-17645545 ] A. Sophie Blee-Goldman commented on KAFKA-14260: Well, actually, it turns out we are

[jira] [Created] (KAFKA-14460) In-memory store iterators can return results with null values

A. Sophie Blee-Goldman created KAFKA-14460: -- Summary: In-memory store iterators can return results with null values Key: KAFKA-14460 URL: https://issues.apache.org/jira/browse/KAFKA-14460

[jira] [Commented] (KAFKA-14362) Same message consumed by two consumers in the same group after client restart

[ https://issues.apache.org/jira/browse/KAFKA-14362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17645541#comment-17645541 ] A. Sophie Blee-Goldman commented on KAFKA-14362: Nice find, I would not at all be

[jira] [Commented] (KAFKA-14419) Same message consumed again by the same stream task after partition is lost and reassigned

[ https://issues.apache.org/jira/browse/KAFKA-14419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17645540#comment-17645540 ] A. Sophie Blee-Goldman commented on KAFKA-14419: [~Carlstedt] can you try reproducing

[jira] [Updated] (KAFKA-14459) Document how to use and close a 'Statistics' in the example RocksDBConfigSetter

[ https://issues.apache.org/jira/browse/KAFKA-14459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-14459: --- Description: We fixed a memory leak in KAFKA-14432 where we were sometimes

[jira] [Updated] (KAFKA-14459) Document how to use and close a 'Statistics' in the example RocksDBConfigSetter

[ https://issues.apache.org/jira/browse/KAFKA-14459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-14459: --- Labels: docs newbie (was: ) > Document how to use and close a 'Statistics'

[jira] [Created] (KAFKA-14459) Document how to use and close a 'Statistics' in the example RocksDBConfigSetter

A. Sophie Blee-Goldman created KAFKA-14459: -- Summary: Document how to use and close a 'Statistics' in the example RocksDBConfigSetter Key: KAFKA-14459 URL:

[jira] [Resolved] (KAFKA-14454) KTableKTableForeignKeyInnerJoinCustomPartitionerIntegrationTest#shouldThrowIllegalArgumentExceptionWhenCustomPartionerReturnsMultiplePartitions passes when run individu

[ https://issues.apache.org/jira/browse/KAFKA-14454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman resolved KAFKA-14454. Resolution: Fixed >

[jira] [Resolved] (KAFKA-14432) RocksDBStore relies on finalizers to not leak memory

[ https://issues.apache.org/jira/browse/KAFKA-14432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman resolved KAFKA-14432. Resolution: Fixed > RocksDBStore relies on finalizers to not leak memory

[jira] [Commented] (KAFKA-14260) InMemoryKeyValueStore iterator still throws ConcurrentModificationException

[ https://issues.apache.org/jira/browse/KAFKA-14260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17644129#comment-17644129 ] A. Sophie Blee-Goldman commented on KAFKA-14260: Ok I did merge a patch to fix where we

[jira] [Resolved] (KAFKA-14260) InMemoryKeyValueStore iterator still throws ConcurrentModificationException

[ https://issues.apache.org/jira/browse/KAFKA-14260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman resolved KAFKA-14260. Resolution: Fixed > InMemoryKeyValueStore iterator still throws

[jira] [Updated] (KAFKA-14260) InMemoryKeyValueStore iterator still throws ConcurrentModificationException

[ https://issues.apache.org/jira/browse/KAFKA-14260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-14260: --- Fix Version/s: 3.4.0 > InMemoryKeyValueStore iterator still throws

[jira] [Resolved] (KAFKA-13602) Allow to broadcast a result record

[ https://issues.apache.org/jira/browse/KAFKA-13602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman resolved KAFKA-13602. Resolution: Fixed > Allow to broadcast a result record >

[jira] [Updated] (KAFKA-13602) Allow to broadcast a result record

[ https://issues.apache.org/jira/browse/KAFKA-13602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-13602: --- Fix Version/s: 3.4.0 > Allow to broadcast a result record >

[jira] [Updated] (KAFKA-14443) Mirror Maker Connectors leak admin clients used for topic creation

[ https://issues.apache.org/jira/browse/KAFKA-14443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-14443: --- Fix Version/s: 3.4.0 > Mirror Maker Connectors leak admin clients used for

[jira] [Resolved] (KAFKA-14415) ThreadCache is getting slower with every additional state store

[ https://issues.apache.org/jira/browse/KAFKA-14415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman resolved KAFKA-14415. Resolution: Fixed > ThreadCache is getting slower with every additional

[jira] [Updated] (KAFKA-14415) ThreadCache is getting slower with every additional state store

[ https://issues.apache.org/jira/browse/KAFKA-14415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-14415: --- Fix Version/s: 3.4.0 > ThreadCache is getting slower with every additional

[jira] [Updated] (KAFKA-14379) consumer should refresh preferred read replica on update metadata

[ https://issues.apache.org/jira/browse/KAFKA-14379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-14379: --- Priority: Blocker (was: Critical) > consumer should refresh preferred read

[jira] [Created] (KAFKA-14444) Simplify user experience of customizing partitioning strategy in Streams

A. Sophie Blee-Goldman created KAFKA-1: -- Summary: Simplify user experience of customizing partitioning strategy in Streams Key: KAFKA-1 URL: https://issues.apache.org/jira/browse/KAFKA-1

[jira] [Updated] (KAFKA-13152) Replace "buffered.records.per.partition" & "cache.max.bytes.buffering" with "{statestore.cache}/{input.buffer}.max.bytes"

[ https://issues.apache.org/jira/browse/KAFKA-13152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-13152: --- Summary: Replace "buffered.records.per.partition" &

[jira] [Updated] (KAFKA-13152) Replace "buffered.records.per.partition" & "cache.max.bytes.buffering" with "{cache}/{input.buffer.max.bytes}"

[ https://issues.apache.org/jira/browse/KAFKA-13152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-13152: --- Summary: Replace "buffered.records.per.partition" &

[jira] [Commented] (KAFKA-14146) KIP-840: Config file option for MessageReader/MessageFormatter in ConsoleProducer/ConsoleConsumer

[ https://issues.apache.org/jira/browse/KAFKA-14146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17641607#comment-17641607 ] A. Sophie Blee-Goldman commented on KAFKA-14146: Moved to 3.5 since it looks like this

[jira] [Updated] (KAFKA-14146) KIP-840: Config file option for MessageReader/MessageFormatter in ConsoleProducer/ConsoleConsumer

[ https://issues.apache.org/jira/browse/KAFKA-14146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-14146: --- Fix Version/s: 3.5.0 (was: 3.4.0) > KIP-840: Config

[jira] [Commented] (KAFKA-14415) ThreadCache is getting slower with every additional state store

[ https://issues.apache.org/jira/browse/KAFKA-14415?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17638119#comment-17638119 ] A. Sophie Blee-Goldman commented on KAFKA-14415: Nice find, I bet the assumption when

[jira] [Commented] (KAFKA-14400) KStream - KStream - LeftJoin() does not call ValueJoiner with null value

[ https://issues.apache.org/jira/browse/KAFKA-14400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17636407#comment-17636407 ] A. Sophie Blee-Goldman commented on KAFKA-14400: Is this happening because the actual

[jira] [Commented] (KAFKA-14362) Same message consumed by two consumers in the same group after client restart

[ https://issues.apache.org/jira/browse/KAFKA-14362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17636398#comment-17636398 ] A. Sophie Blee-Goldman commented on KAFKA-14362: The offset commit failing due to

[jira] [Updated] (KAFKA-14325) NullPointer in ProcessorParameters.toString

[ https://issues.apache.org/jira/browse/KAFKA-14325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-14325: --- Fix Version/s: 3.4.0 > NullPointer in ProcessorParameters.toString >

[jira] [Updated] (KAFKA-14325) NullPointer in ProcessorParameters.toString

[ https://issues.apache.org/jira/browse/KAFKA-14325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-14325: --- Fix Version/s: 3.3.2 > NullPointer in ProcessorParameters.toString >

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