[jira] [Commented] (KAFKA-15190) Allow configuring a streams process ID

[ https://issues.apache.org/jira/browse/KAFKA-15190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17743311#comment-17743311 ] A. Sophie Blee-Goldman commented on KAFKA-15190: I'm all for this, thoug

[jira] [Commented] (KAFKA-15178) Poor performance of ConsumerCoordinator with many TopicPartitions

[ https://issues.apache.org/jira/browse/KAFKA-15178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17742151#comment-17742151 ] A. Sophie Blee-Goldman commented on KAFKA-15178: Nice catch! > Poor per

[jira] [Created] (KAFKA-15045) Move Streams task assignor to public configs

A. Sophie Blee-Goldman created KAFKA-15045: -- Summary: Move Streams task assignor to public configs Key: KAFKA-15045 URL: https://issues.apache.org/jira/browse/KAFKA-15045 Project: Kafka

[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&focusedCommentId=17721546#comment-17721546 ] A. Sophie Blee-Goldman commented on KAFKA-14981: Have we resolved all th

[jira] [Created] (KAFKA-14976) Left/outer stream-stream joins create KV stores that aren't customizable

A. Sophie Blee-Goldman created KAFKA-14976: -- Summary: Left/outer stream-stream joins create KV stores that aren't customizable Key: KAFKA-14976 URL: https://issues.apache.org/jira/browse/KAFKA-14976

[jira] [Updated] (KAFKA-14976) Left/outer stream-stream joins create KV stores that aren't customizable

[ https://issues.apache.org/jira/browse/KAFKA-14976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-14976: --- Labels: needs-kip (was: ) > Left/outer stream-stream joins create KV stores

[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&focusedCommentId=17719572#comment-17719572 ] A. Sophie Blee-Goldman commented on KAFKA-13891: Thanks [~pnee] – just t

[jira] [Commented] (KAFKA-14016) Revoke more partitions than expected in Cooperative rebalance

[ https://issues.apache.org/jira/browse/KAFKA-14016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17719570#comment-17719570 ] A. Sophie Blee-Goldman commented on KAFKA-14016: Nice job [~pnee] – than

[jira] [Updated] (KAFKA-14553) RecordAccumulator hangs in infinite NOP loop

[ https://issues.apache.org/jira/browse/KAFKA-14553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-14553: --- Fix Version/s: 3.4.0 > RecordAccumulator hangs in infinite NOP loop > --

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

[ https://issues.apache.org/jira/browse/KAFKA-14533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17680403#comment-17680403 ] A. Sophie Blee-Goldman commented on KAFKA-14533: I'll give it a few more

[jira] [Created] (KAFKA-14650) IQv2 can throw ConcurrentModificationException when accessing Tasks

A. Sophie Blee-Goldman created KAFKA-14650: -- Summary: IQv2 can throw ConcurrentModificationException when accessing Tasks Key: KAFKA-14650 URL: https://issues.apache.org/jira/browse/KAFKA-14650

[jira] [Commented] (KAFKA-14639) Kafka CooperativeStickyAssignor revokes/assigns partition in one rebalance cycle

[ https://issues.apache.org/jira/browse/KAFKA-14639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17680141#comment-17680141 ] A. Sophie Blee-Goldman commented on KAFKA-14639: Thanks for the addition

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

[ https://issues.apache.org/jira/browse/KAFKA-14533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17680134#comment-17680134 ] A. Sophie Blee-Goldman commented on KAFKA-14533: FYI after disabling the

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

[ https://issues.apache.org/jira/browse/KAFKA-14533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17679735#comment-17679735 ] A. Sophie Blee-Goldman edited comment on KAFKA-14533 at 1/23/23 11:37 PM:

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

[ https://issues.apache.org/jira/browse/KAFKA-14533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17679735#comment-17679735 ] A. Sophie Blee-Goldman commented on KAFKA-14533: https://github.com/apac

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

[ https://issues.apache.org/jira/browse/KAFKA-14533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17679729#comment-17679729 ] A. Sophie Blee-Goldman commented on KAFKA-14533: Not sure why this is ha

[jira] [Commented] (KAFKA-14639) Kafka CooperativeStickyAssignor revokes/assigns partition in one rebalance cycle

[ https://issues.apache.org/jira/browse/KAFKA-14639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17678981#comment-17678981 ] A. Sophie Blee-Goldman commented on KAFKA-14639: There's definitely some

[jira] [Commented] (KAFKA-14553) RecordAccumulator hangs in infinite NOP loop

[ https://issues.apache.org/jira/browse/KAFKA-14553?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17653273#comment-17653273 ] A. Sophie Blee-Goldman commented on KAFKA-14553: For some reason the rel

[jira] [Updated] (KAFKA-14553) RecordAccumulator hangs in infinite NOP loop

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

[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&focusedCommentId=17653254#comment-17653254 ] A. Sophie Blee-Goldman commented on KAFKA-14279: Temporarily bumping to

[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 brok

[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&focusedCommentId=17653253#comment-17653253 ] A. Sophie Blee-Goldman commented on KAFKA-12886: Temporarily bumping to

[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 fo

[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 Tr

[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&focusedCommentId=17653252#comment-17653252 ] A. Sophie Blee-Goldman commented on KAFKA-12622: Updates for 3.4: https

[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 org.apache.

[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&focusedCommentId=17653025#comment-17653025 ] A. Sophie Blee-Goldman commented on KAFKA-13295: [~mjsax] unfortunately

[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 tran

[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&focusedCommentId=17653024#comment-17653024 ] A. Sophie Blee-Goldman commented on KAFKA-14555: [~gharris1727] can you

[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&focusedCommentId=17653022#comment-17653022 ] A. Sophie Blee-Goldman commented on KAFKA-14404: [~sujayopensource]  tha

[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&focusedCommentId=17653021#comment-17653021 ] A. Sophie Blee-Goldman commented on KAFKA-14459: [~sujayopensource] go f

[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&focusedCommentId=17653017#comment-17653017 ] A. Sophie Blee-Goldman commented on KAFKA-14419: Hm. Could you try and r

[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 broadcas

[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: https://issues.apache.org/jira/browse/KA

[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 supp

[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 broadcas

[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 resul

[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 se

[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&focusedCommentId=17647830#comment-17647830 ] A. Sophie Blee-Goldman commented on KAFKA-12319: bumping this to 3.5.0 a

[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 DynamicBr

[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 in

[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 DynamicBr

[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 > Con

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

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

[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 > ConsumerBo

[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 kafka.network.SocketServerTest.closingChannelWit

[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 kafka.network.SocketServerTest.closi

[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&focusedCommentId=17647827#comment-17647827 ] A. Sophie Blee-Goldman commented on KAFKA-13950: Bumping this to 3.5.0 a

[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&focusedCommentId=17647826#comment-17647826 ] A. Sophie Blee-Goldman commented on KAFKA-14186: [~mumrah] bumping this

[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 sna

[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 fo

[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 consoli

[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&focusedCommentId=17647825#comment-17647825 ] A. Sophie Blee-Goldman commented on KAFKA-7109: --- bumping this to 3.5.0 as w

[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 should

[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&focusedCommentId=17647824#comment-17647824 ] A. Sophie Blee-Goldman commented on KAFKA-4852: --- [~LSK] [~wdaehn] is there

[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&focusedCommentId=17647822#comment-17647822 ] A. Sophie Blee-Goldman commented on KAFKA-14418: [~divijvaidya] I just w

[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: Autoscal

[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 partitions

[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 Partitio

[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&focusedCommentId=17647820#comment-17647820 ] A. Sophie Blee-Goldman commented on KAFKA-14302: I did look into this br

[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&focusedCommentId=17647819#comment-17647819 ] A. Sophie Blee-Goldman commented on KAFKA-14241: [~jagsancio]  bumping t

[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 can

[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 Vo

[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&focusedCommentId=17647817#comment-17647817 ] A. Sophie Blee-Goldman commented on KAFKA-14139: [~hachikuji]  bumping t

[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&focusedCommentId=17647816#comment-17647816 ] A. Sophie Blee-Goldman commented on KAFKA-14094: [~jagsancio] bumping th

[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 descri

[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&focusedCommentId=17647815#comment-17647815 ] A. Sophie Blee-Goldman commented on KAFKA-14145: [~jagsancio]  moving th

[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 propagatio

[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 fi

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

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

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

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

[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 A

[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 ma

[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&focusedCommentId=17647810#comment-17647810 ] A. Sophie Blee-Goldman commented on KAFKA-13299: [~mdedetrich-aiven] mov

[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&focusedCommentId=17647809#comment-17647809 ] A. Sophie Blee-Goldman commented on KAFKA-13891: Bumping this to 3.5.0 s

[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 failed

[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 calculat

[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&focusedCommentId=17647807#comment-17647807 ] A. Sophie Blee-Goldman commented on KAFKA-14038: [~divijvaidya]  bumped

[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&focusedCommentId=17647805#comment-17647805 ] A. Sophie Blee-Goldman commented on KAFKA-14077: [~hachikuji] [~jagsanci

[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&focusedCommentId=17647804#comment-17647804 ] A. Sophie Blee-Goldman commented on KAFKA-14279: [~jsancio] why is this

[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 "coopera

[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&focusedCommentId=17647800#comment-17647800 ] A. Sophie Blee-Goldman commented on KAFKA-12886: [~hachikuji] [~jagsanci

[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&focusedCommentId=17645545#comment-17645545 ] A. Sophie Blee-Goldman commented on KAFKA-14260: Well, actually, it turn

[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 Pro

[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&focusedCommentId=17645541#comment-17645541 ] A. Sophie Blee-Goldman commented on KAFKA-14362: Nice find, I would not

[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&focusedCommentId=17645540#comment-17645540 ] A. Sophie Blee-Goldman commented on KAFKA-14419: [~Carlstedt] can you tr

[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 f

[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: https://issues.apache.org/jira/browse/KAFKA-1445

[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 > KTableKTableForeignKeyInnerJoinCustomPartitionerIntegr

[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 >

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