[jira] [Commented] (KAFKA-15994) Add complex example compose file

[ https://issues.apache.org/jira/browse/KAFKA-15994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800561#comment-17800561 ] Stanislav Kozlovski commented on KAFKA-15994: - Changing target version to 3.

[jira] [Updated] (KAFKA-15994) Add complex example compose file

[ https://issues.apache.org/jira/browse/KAFKA-15994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-15994: Fix Version/s: 3.8.0 (was: 3.7.0) > Add complex example com

[jira] [Updated] (KAFKA-16016) Migrate utility scripts to kafka codebase

[ https://issues.apache.org/jira/browse/KAFKA-16016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-16016: Fix Version/s: 3.8.0 (was: 3.7.0) > Migrate utility scripts

[jira] [Commented] (KAFKA-16016) Migrate utility scripts to kafka codebase

[ https://issues.apache.org/jira/browse/KAFKA-16016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800560#comment-17800560 ] Stanislav Kozlovski commented on KAFKA-16016: - Changing the Fix Version here

[jira] [Resolved] (KAFKA-16007) ZK migrations can be slow for large clusters

[ https://issues.apache.org/jira/browse/KAFKA-16007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski resolved KAFKA-16007. - Resolution: Fixed Closing since it's merged   > ZK migrations can be slow for

[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=17800556#comment-17800556 ] Stanislav Kozlovski commented on KAFKA-12622: - For 3.7, I did: ``` git check

[jira] (KAFKA-15818) Implement max poll interval

[ https://issues.apache.org/jira/browse/KAFKA-15818 ] Stanislav Kozlovski deleted comment on KAFKA-15818: - was (Author: enether): Was this merged to the 3.7 branch?   > Implement max poll interval > --- > >

[jira] [Commented] (KAFKA-15818) Implement max poll interval

[ https://issues.apache.org/jira/browse/KAFKA-15818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800451#comment-17800451 ] Stanislav Kozlovski commented on KAFKA-15818: - Was this merged to the 3.7 br

[jira] [Resolved] (KAFKA-15818) Implement max poll interval

[ https://issues.apache.org/jira/browse/KAFKA-15818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski resolved KAFKA-15818. - Resolution: Fixed > Implement max poll interval > --- >

[jira] [Commented] (KAFKA-15818) Implement max poll interval

[ https://issues.apache.org/jira/browse/KAFKA-15818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800450#comment-17800450 ] Stanislav Kozlovski commented on KAFKA-15818: - seems merged! closing this is

[jira] [Commented] (KAFKA-16026) AsyncConsumer does not send a poll event to the background thread

[ https://issues.apache.org/jira/browse/KAFKA-16026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800448#comment-17800448 ] Stanislav Kozlovski commented on KAFKA-16026: - This seems merged, so closing

[jira] [Resolved] (KAFKA-16026) AsyncConsumer does not send a poll event to the background thread

[ https://issues.apache.org/jira/browse/KAFKA-16026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski resolved KAFKA-16026. - Resolution: Fixed https://github.com/apache/kafka/pull/15035   > AsyncConsumer

[jira] [Commented] (KAFKA-16016) Migrate utility scripts to kafka codebase

[ https://issues.apache.org/jira/browse/KAFKA-16016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800447#comment-17800447 ] Stanislav Kozlovski commented on KAFKA-16016: - We are discussing in the mail

[jira] [Updated] (KAFKA-15388) Handle topics that were having compaction as retention earlier are changed to delete only retention policy and onboarded to tiered storage.

[ https://issues.apache.org/jira/browse/KAFKA-15388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-15388: Fix Version/s: 3.8.0 (was: 3.7.0) > Handle topics that were

[jira] [Commented] (KAFKA-15818) Implement max poll interval

[ https://issues.apache.org/jira/browse/KAFKA-15818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798964#comment-17798964 ] Stanislav Kozlovski commented on KAFKA-15818: - [~pnee] this blocker bug seem

[jira] [Commented] (KAFKA-15388) Handle topics that were having compaction as retention earlier are changed to delete only retention policy and onboarded to tiered storage.

[ https://issues.apache.org/jira/browse/KAFKA-15388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798962#comment-17798962 ] Stanislav Kozlovski commented on KAFKA-15388: - [~satish.duggana] should we c

[jira] [Commented] (KAFKA-15529) Flaky test ReassignReplicaShrinkTest.executeTieredStorageTest

[ https://issues.apache.org/jira/browse/KAFKA-15529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798963#comment-17798963 ] Stanislav Kozlovski commented on KAFKA-15529: - [~divijvaidya] should we actu

[jira] [Commented] (KAFKA-15147) Measure pending and outstanding Remote Segment operations

[ https://issues.apache.org/jira/browse/KAFKA-15147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798168#comment-17798168 ] Stanislav Kozlovski commented on KAFKA-15147: - sounds good > Measure pendin

[jira] [Commented] (KAFKA-15781) Change ProducerConfig(props, doLog) constructor to protected

[ https://issues.apache.org/jira/browse/KAFKA-15781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17796623#comment-17796623 ] Stanislav Kozlovski commented on KAFKA-15781: - Hey, I am managing the 3.7 re

[jira] [Commented] (KAFKA-15448) Streams StandbyTaskUpdateListener

[ https://issues.apache.org/jira/browse/KAFKA-15448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17796620#comment-17796620 ] Stanislav Kozlovski commented on KAFKA-15448: - [~coltmcnealy-lh] can we: - l

[jira] [Updated] (KAFKA-15406) Add the ForwardingManager metrics from KIP-938

[ https://issues.apache.org/jira/browse/KAFKA-15406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-15406: Affects Version/s: 3.8.0 (was: 3.7.0) > Add the Forward

[jira] [Commented] (KAFKA-15406) Add the ForwardingManager metrics from KIP-938

[ https://issues.apache.org/jira/browse/KAFKA-15406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17796619#comment-17796619 ] Stanislav Kozlovski commented on KAFKA-15406: - I think we can call this a sl

[jira] [Commented] (KAFKA-15147) Measure pending and outstanding Remote Segment operations

[ https://issues.apache.org/jira/browse/KAFKA-15147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17796618#comment-17796618 ] Stanislav Kozlovski commented on KAFKA-15147: - hey [~divijvaidya] [~christo_

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=17775711#comment-17775711 ] Stanislav Kozlovski commented on KAFKA-13152: - [~sagarrao] sounds good, I am

[jira] [Commented] (KAFKA-15147) Measure pending and outstanding Remote Segment operations

[ https://issues.apache.org/jira/browse/KAFKA-15147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17775304#comment-17775304 ] Stanislav Kozlovski commented on KAFKA-15147: - thanks for the quick update [

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

[ https://issues.apache.org/jira/browse/KAFKA-14175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski resolved KAFKA-14175. - Resolution: Won't Fix > KRaft Upgrades Part 2 > - > >

[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 ] Stanislav Kozlovski updated KAFKA-14175: Fix Version/s: (was: 3.7.0) > KRaft Upgrades Part 2 > - >

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

[ https://issues.apache.org/jira/browse/KAFKA-14175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17775301#comment-17775301 ] Stanislav Kozlovski commented on KAFKA-14175: - [~mumrah] confirmed to me tha

[jira] [Commented] (KAFKA-14945) Add Serializer#serializeToByteBuffer() to reduce memory copying

[ https://issues.apache.org/jira/browse/KAFKA-14945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17775300#comment-17775300 ] Stanislav Kozlovski commented on KAFKA-14945: - [~LSK] given the lack of acti

[jira] [Commented] (KAFKA-15230) ApiVersions data between controllers is not reliable

[ https://issues.apache.org/jira/browse/KAFKA-15230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17775299#comment-17775299 ] Stanislav Kozlovski commented on KAFKA-15230: - Did it release with 3.6.0?  

[jira] [Updated] (KAFKA-10892) Add Topology#connectSourceStoreAndTopic as a public method

[ https://issues.apache.org/jira/browse/KAFKA-10892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-10892: Fix Version/s: (was: 3.7.0) > Add Topology#connectSourceStoreAndTopic as a pub

[jira] [Commented] (KAFKA-10892) Add Topology#connectSourceStoreAndTopic as a public method

[ https://issues.apache.org/jira/browse/KAFKA-10892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17775298#comment-17775298 ] Stanislav Kozlovski commented on KAFKA-10892: - Given the lack of activity on

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=17775296#comment-17775296 ] Stanislav Kozlovski commented on KAFKA-12473: - [~dajac] [~showuon] shall we

[jira] [Commented] (KAFKA-15147) Measure pending and outstanding Remote Segment operations

[ https://issues.apache.org/jira/browse/KAFKA-15147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17775295#comment-17775295 ] Stanislav Kozlovski commented on KAFKA-15147: - [~divijvaidya] given that the

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

[ https://issues.apache.org/jira/browse/KAFKA-14175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17775294#comment-17775294 ] Stanislav Kozlovski commented on KAFKA-14175: - given the lack of activity in

[jira] [Commented] (KAFKA-15594) Add 3.6.0 to streams upgrade/compatibility tests

[ https://issues.apache.org/jira/browse/KAFKA-15594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17775293#comment-17775293 ] Stanislav Kozlovski commented on KAFKA-15594: - [~satish.duggana] is anyone g

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

[ https://issues.apache.org/jira/browse/KAFKA-12399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-12399: Fix Version/s: (was: 3.7.0) > Deprecate Log4J Appender KIP-719 > -

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

[ https://issues.apache.org/jira/browse/KAFKA-12399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17775292#comment-17775292 ] Stanislav Kozlovski commented on KAFKA-12399: - This was last reviewed on Mar

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=17775291#comment-17775291 ] Stanislav Kozlovski commented on KAFKA-13152: - Given there hasn't been much

[jira] [Commented] (KAFKA-15593) Add 3.6.0 to broker/client upgrade/compatibility tests

[ https://issues.apache.org/jira/browse/KAFKA-15593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17775286#comment-17775286 ] Stanislav Kozlovski commented on KAFKA-15593: - [~satish.duggana] is this goo

[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 ] Stanislav Kozlovski updated KAFKA-14077: Fix Version/s: (was: 3.7.0) > KRaft should support recovery from failed disk >

[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=17775285#comment-17775285 ] Stanislav Kozlovski commented on KAFKA-14077: - I asked [~jagsancio] and [~ha

[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=17775284#comment-17775284 ] Stanislav Kozlovski commented on KAFKA-12886: - [~rdielhenn] is this targetti

[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 ] Stanislav Kozlovski updated KAFKA-12886: Fix Version/s: (was: 3.7.0) > Enable request forwarding by default > -

[jira] [Commented] (KAFKA-15406) Add the ForwardingManager metrics from KIP-938

[ https://issues.apache.org/jira/browse/KAFKA-15406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17775275#comment-17775275 ] Stanislav Kozlovski commented on KAFKA-15406: - [~cmccabe] given that we are

[jira] [Commented] (KAFKA-10345) Add auto reloading for trust/key store paths

[ https://issues.apache.org/jira/browse/KAFKA-10345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17743007#comment-17743007 ] Stanislav Kozlovski commented on KAFKA-10345: - While the KIP isn't implement

[jira] [Commented] (KAFKA-14121) AlterPartitionReassignments API should allow callers to specify the option of preserving the replication factor

[ https://issues.apache.org/jira/browse/KAFKA-14121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17576570#comment-17576570 ] Stanislav Kozlovski commented on KAFKA-14121: - Thank you!   > AlterPartiti

[jira] [Commented] (KAFKA-14121) AlterPartitionReassignments API should allow callers to specify the option of preserving the replication factor

[ https://issues.apache.org/jira/browse/KAFKA-14121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17576405#comment-17576405 ] Stanislav Kozlovski commented on KAFKA-14121: - hey [~sagarrao] , this KIP is

[jira] [Updated] (KAFKA-14121) AlterPartitionReassignments API should allow callers to specify the option of preserving the replication factor

[ https://issues.apache.org/jira/browse/KAFKA-14121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-14121: Description: Using Kafka's public APIs to get metadata regarding the non-reassigni

[jira] [Created] (KAFKA-14121) AlterPartitionReassignments API should allow callers to specify the option of preserving the replication factor

Stanislav Kozlovski created KAFKA-14121: --- Summary: AlterPartitionReassignments API should allow callers to specify the option of preserving the replication factor Key: KAFKA-14121 URL: https://issues.apache.

[jira] [Resolved] (KAFKA-8406) kafka-topics throws wrong error on invalid configuration with bootstrap-server and alter config

[ https://issues.apache.org/jira/browse/KAFKA-8406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski resolved KAFKA-8406. Fix Version/s: 2.4.0 Resolution: Fixed > kafka-topics throws wrong error on

[jira] [Commented] (KAFKA-8406) kafka-topics throws wrong error on invalid configuration with bootstrap-server and alter config

[ https://issues.apache.org/jira/browse/KAFKA-8406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17412103#comment-17412103 ] Stanislav Kozlovski commented on KAFKA-8406: Fixed in 2.4 - https://github.co

[jira] [Issue Comment Deleted] (KAFKA-8406) kafka-topics throws wrong error on invalid configuration with bootstrap-server and alter config

[ https://issues.apache.org/jira/browse/KAFKA-8406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-8406: --- Comment: was deleted (was: [~savulchik] are you sure? Can you try the exact same comm

[jira] [Commented] (KAFKA-12555) Log reason for rolling a segment

[ https://issues.apache.org/jira/browse/KAFKA-12555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17317341#comment-17317341 ] Stanislav Kozlovski commented on KAFKA-12555: - No, I don't know the reasons.

[jira] [Updated] (KAFKA-12555) Log reason for rolling a segment

[ https://issues.apache.org/jira/browse/KAFKA-12555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-12555: Labels: newbie (was: ) > Log reason for rolling a segment > -

[jira] [Created] (KAFKA-12555) Log reason for rolling a segment

Stanislav Kozlovski created KAFKA-12555: --- Summary: Log reason for rolling a segment Key: KAFKA-12555 URL: https://issues.apache.org/jira/browse/KAFKA-12555 Project: Kafka Issue Type: Im

[jira] [Updated] (KAFKA-10510) Reassigning partitions should not allow increasing RF of a partition unless configured with it

[ https://issues.apache.org/jira/browse/KAFKA-10510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-10510: Description: Kafka should have some validations in place against increasing the RF

[jira] [Created] (KAFKA-10510) Reassigning partitions should not allow increasing RF of a partition unless configured with it

Stanislav Kozlovski created KAFKA-10510: --- Summary: Reassigning partitions should not allow increasing RF of a partition unless configured with it Key: KAFKA-10510 URL: https://issues.apache.org/jira/browse/K

[jira] [Commented] (KAFKA-10353) Trogdor - Fix RoundTripWorker to not fail when the topic it's trying to create already exists

[ https://issues.apache.org/jira/browse/KAFKA-10353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17170819#comment-17170819 ] Stanislav Kozlovski commented on KAFKA-10353: - Should be fixed as of KAFKA-1

[jira] [Resolved] (KAFKA-10353) Trogdor - Fix RoundTripWorker to not fail when the topic it's trying to create already exists

[ https://issues.apache.org/jira/browse/KAFKA-10353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski resolved KAFKA-10353. - Resolution: Duplicate > Trogdor - Fix RoundTripWorker to not fail when the topic

[jira] [Created] (KAFKA-10353) Trogdor - Fix RoundTripWorker to not fail when the topic it's trying to create already exists

Stanislav Kozlovski created KAFKA-10353: --- Summary: Trogdor - Fix RoundTripWorker to not fail when the topic it's trying to create already exists Key: KAFKA-10353 URL: https://issues.apache.org/jira/browse/KA

[jira] [Commented] (KAFKA-10302) Ensure thread-safe access to Partition#remoteReplicasMap

[ https://issues.apache.org/jira/browse/KAFKA-10302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17165489#comment-17165489 ] Stanislav Kozlovski commented on KAFKA-10302: - [~johnthotekat] I have not, n

[jira] [Commented] (KAFKA-10301) Partition#remoteReplicasMap can be empty in certain race conditions

[ https://issues.apache.org/jira/browse/KAFKA-10301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17165484#comment-17165484 ] Stanislav Kozlovski commented on KAFKA-10301: - Merged in master ([fa6e5b892

[jira] [Resolved] (KAFKA-10301) Partition#remoteReplicasMap can be empty in certain race conditions

[ https://issues.apache.org/jira/browse/KAFKA-10301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski resolved KAFKA-10301. - Resolution: Fixed > Partition#remoteReplicasMap can be empty in certain race con

[jira] [Commented] (KAFKA-10301) Partition#remoteReplicasMap can be empty in certain race conditions

[ https://issues.apache.org/jira/browse/KAFKA-10301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17163686#comment-17163686 ] Stanislav Kozlovski commented on KAFKA-10301: - cc [~rhauch] - this would be

[jira] [Updated] (KAFKA-10301) Partition#remoteReplicasMap can be empty in certain race conditions

[ https://issues.apache.org/jira/browse/KAFKA-10301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-10301: Description: In Partition#updateAssignmentAndIsr, we would previously update the

[jira] [Created] (KAFKA-10302) Ensure thread-safe access to Partition#remoteReplicasMap

Stanislav Kozlovski created KAFKA-10302: --- Summary: Ensure thread-safe access to Partition#remoteReplicasMap Key: KAFKA-10302 URL: https://issues.apache.org/jira/browse/KAFKA-10302 Project: Kafka

[jira] [Updated] (KAFKA-10301) Partition#remoteReplicasMap can be empty in certain race conditions

[ https://issues.apache.org/jira/browse/KAFKA-10301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-10301: Description: In Partition#updateAssignmentAndIsr, we would previously update the

[jira] [Created] (KAFKA-10301) RemoteReplicasMap can be empty in certain race conditions

Stanislav Kozlovski created KAFKA-10301: --- Summary: RemoteReplicasMap can be empty in certain race conditions Key: KAFKA-10301 URL: https://issues.apache.org/jira/browse/KAFKA-10301 Project: Kafka

[jira] [Updated] (KAFKA-10301) Partition#remoteReplicasMap can be empty in certain race conditions

[ https://issues.apache.org/jira/browse/KAFKA-10301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-10301: Summary: Partition#remoteReplicasMap can be empty in certain race conditions (was

[jira] [Commented] (KAFKA-7304) memory leakage in org.apache.kafka.common.network.Selector

[ https://issues.apache.org/jira/browse/KAFKA-7304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17152523#comment-17152523 ] Stanislav Kozlovski commented on KAFKA-7304: Given that this Jira is for repo

[jira] [Assigned] (KAFKA-7940) Flaky Test CustomQuotaCallbackTest#testCustomQuotaCallback

[ https://issues.apache.org/jira/browse/KAFKA-7940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski reassigned KAFKA-7940: -- Assignee: (was: Stanislav Kozlovski) > Flaky Test CustomQuotaCallbackTest#

[jira] [Commented] (KAFKA-8406) kafka-topics throws wrong error on invalid configuration with bootstrap-server and alter config

[ https://issues.apache.org/jira/browse/KAFKA-8406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17124052#comment-17124052 ] Stanislav Kozlovski commented on KAFKA-8406: [~savulchik] are you sure? Can y

[jira] [Resolved] (KAFKA-8723) flaky test LeaderElectionCommandTest#testAllTopicPartition

[ https://issues.apache.org/jira/browse/KAFKA-8723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski resolved KAFKA-8723. Resolution: Fixed > flaky test LeaderElectionCommandTest#testAllTopicPartition > --

[jira] [Assigned] (KAFKA-7599) Trogdor - Allow configuration for not throttling Benchmark Workers and expose messages per second in task status

[ https://issues.apache.org/jira/browse/KAFKA-7599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski reassigned KAFKA-7599: -- Assignee: (was: Stanislav Kozlovski) > Trogdor - Allow configuration for n

[jira] [Assigned] (KAFKA-8264) Flaky Test PlaintextConsumerTest#testLowMaxFetchSizeForRequestAndPartition

[ https://issues.apache.org/jira/browse/KAFKA-8264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski reassigned KAFKA-8264: -- Assignee: (was: Stanislav Kozlovski) > Flaky Test PlaintextConsumerTest#te

[jira] [Commented] (KAFKA-9617) Replica Fetcher can mark partition as failed when max.message.bytes is changed

[ https://issues.apache.org/jira/browse/KAFKA-9617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17088692#comment-17088692 ] Stanislav Kozlovski commented on KAFKA-9617: Feel free to assign yourself [~s

[jira] [Created] (KAFKA-9866) Do not attempt to elect preferred leader replicas which are outside ISR

Stanislav Kozlovski created KAFKA-9866: -- Summary: Do not attempt to elect preferred leader replicas which are outside ISR Key: KAFKA-9866 URL: https://issues.apache.org/jira/browse/KAFKA-9866 Pro

[jira] [Assigned] (KAFKA-9617) Replica Fetcher can mark partition as failed when max.message.bytes is changed

[ https://issues.apache.org/jira/browse/KAFKA-9617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski reassigned KAFKA-9617: -- Assignee: (was: Stanislav Kozlovski) > Replica Fetcher can mark partition

[jira] [Updated] (KAFKA-9617) Replica Fetcher can mark partition as failed when max.message.bytes is changed

[ https://issues.apache.org/jira/browse/KAFKA-9617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-9617: --- Labels: newbie (was: ) > Replica Fetcher can mark partition as failed when max.messa

[jira] [Issue Comment Deleted] (KAFKA-9617) Replica Fetcher can mark partition as failed when max.message.bytes is changed

[ https://issues.apache.org/jira/browse/KAFKA-9617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-9617: --- Comment: was deleted (was: I do not have bandwidth to work on this currently) > Repl

[jira] [Assigned] (KAFKA-9617) Replica Fetcher can mark partition as failed when max.message.bytes is changed

[ https://issues.apache.org/jira/browse/KAFKA-9617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski reassigned KAFKA-9617: -- Assignee: Stanislav Kozlovski > Replica Fetcher can mark partition as failed w

[jira] [Commented] (KAFKA-9617) Replica Fetcher can mark partition as failed when max.message.bytes is changed

[ https://issues.apache.org/jira/browse/KAFKA-9617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17055266#comment-17055266 ] Stanislav Kozlovski commented on KAFKA-9617: I do not have bandwidth to work

[jira] [Assigned] (KAFKA-9617) Replica Fetcher can mark partition as failed when max.message.bytes is changed

[ https://issues.apache.org/jira/browse/KAFKA-9617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski reassigned KAFKA-9617: -- Assignee: (was: Stanislav Kozlovski) > Replica Fetcher can mark partition

[jira] [Commented] (KAFKA-8796) A broker joining the cluster should be able to replicate without impacting the cluster

[ https://issues.apache.org/jira/browse/KAFKA-8796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17052230#comment-17052230 ] Stanislav Kozlovski commented on KAFKA-8796: I'm not sure it's a duplicate. E

[jira] [Commented] (KAFKA-8796) A broker joining the cluster should be able to replicate without impacting the cluster

[ https://issues.apache.org/jira/browse/KAFKA-8796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17052070#comment-17052070 ] Stanislav Kozlovski commented on KAFKA-8796: Hey there [~blodsbror]. Unfortun

[jira] [Created] (KAFKA-9617) Replica Fetcher can mark partition as failed when max.message.bytes is changed

Stanislav Kozlovski created KAFKA-9617: -- Summary: Replica Fetcher can mark partition as failed when max.message.bytes is changed Key: KAFKA-9617 URL: https://issues.apache.org/jira/browse/KAFKA-9617

[jira] [Updated] (KAFKA-8001) AlterLogDirs: Fetch from future replica stalls when local replica becomes a leader

[ https://issues.apache.org/jira/browse/KAFKA-8001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-8001: --- Description: With KIP-320, fetch from follower / future replica returns FENCED_LEADER

[jira] [Updated] (KAFKA-8001) AlterLogDirs: Fetch from future replica stalls when local replica becomes a leader

[ https://issues.apache.org/jira/browse/KAFKA-8001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-8001: --- Summary: AlterLogDirs: Fetch from future replica stalls when local replica becomes a

[jira] [Updated] (KAFKA-8001) Fetch from future replica stalls when local replica becomes a leader

[ https://issues.apache.org/jira/browse/KAFKA-8001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-8001: --- Description: With KIP-320, fetch from follower / future replica returns FENCED_LEADER

[jira] [Created] (KAFKA-9589) LogValidatorTest#testLogAppendTimeNonCompressedV2 is not executed and does not pass

Stanislav Kozlovski created KAFKA-9589: -- Summary: LogValidatorTest#testLogAppendTimeNonCompressedV2 is not executed and does not pass Key: KAFKA-9589 URL: https://issues.apache.org/jira/browse/KAFKA-9589

[jira] [Commented] (KAFKA-9577) Client encountering SASL_HANDSHAKE protocol version errors on 2.5 / trunk

[ https://issues.apache.org/jira/browse/KAFKA-9577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17041046#comment-17041046 ] Stanislav Kozlovski commented on KAFKA-9577: Do we have a system test that wo

[jira] [Commented] (KAFKA-9280) Duplicate messages are observed in ACK mode ALL

[ https://issues.apache.org/jira/browse/KAFKA-9280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17040343#comment-17040343 ] Stanislav Kozlovski commented on KAFKA-9280: The example I gave was a fetch r

[jira] [Commented] (KAFKA-9530) Flaky Test kafka.admin.DescribeConsumerGroupTest.testDescribeGroupWithShortInitializationTimeout

[ https://issues.apache.org/jira/browse/KAFKA-9530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17039015#comment-17039015 ] Stanislav Kozlovski commented on KAFKA-9530: I managed to reproduce the failu

[jira] [Commented] (KAFKA-9280) Duplicate messages are observed in ACK mode ALL

[ https://issues.apache.org/jira/browse/KAFKA-9280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17034540#comment-17034540 ] Stanislav Kozlovski commented on KAFKA-9280: [~vikram484] this shouldn't happ

[jira] [Commented] (KAFKA-9484) Unnecessary LeaderAndIsr update following reassignment completion

[ https://issues.apache.org/jira/browse/KAFKA-9484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17028481#comment-17028481 ] Stanislav Kozlovski commented on KAFKA-9484: Makes sense to me :) > Unnecess

[jira] [Assigned] (KAFKA-9099) Reassignments should be retried after unexpected errors

[ https://issues.apache.org/jira/browse/KAFKA-9099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski reassigned KAFKA-9099: -- Assignee: (was: Stanislav Kozlovski) > Reassignments should be retried aft

[jira] [Commented] (KAFKA-8723) flaky test LeaderElectionCommandTest#testAllTopicPartition

[ https://issues.apache.org/jira/browse/KAFKA-8723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16964782#comment-16964782 ] Stanislav Kozlovski commented on KAFKA-8723: It is likely that https://issues

[jira] [Commented] (KAFKA-9120) Convert ./bin/kafka-reassign-partitions.sh to use KIP-455

[ https://issues.apache.org/jira/browse/KAFKA-9120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16964077#comment-16964077 ] Stanislav Kozlovski commented on KAFKA-9120: This is tracked in https://issue

[jira] [Commented] (KAFKA-8010) kafka-configs.sh does not allow setting config with an equal in the value

[ https://issues.apache.org/jira/browse/KAFKA-8010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16961918#comment-16961918 ] Stanislav Kozlovski commented on KAFKA-8010: I also hit this issue and verifi

<    1   2   3   4   5   6   >