[jira] [Commented] (KAFKA-8801) electLeaderForPartitions redundancy for some success elect partitions

[ https://issues.apache.org/jira/browse/KAFKA-8801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1690#comment-1690 ] Ismael Juma commented on KAFKA-8801: cc [~jsancio] > electLeaderForPartitions redundancy for some

[jira] [Commented] (KAFKA-8788) Optimize client metadata handling with a large number of partitions

[ https://issues.apache.org/jira/browse/KAFKA-8788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16907773#comment-16907773 ] ASF GitHub Bot commented on KAFKA-8788: --- ijuma commented on pull request #7192: KAFKA-8788:

[jira] [Commented] (KAFKA-8801) electLeaderForPartitions redundancy for some success elect partitions

[ https://issues.apache.org/jira/browse/KAFKA-8801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16907767#comment-16907767 ] shilin Lu commented on KAFKA-8801: -- [~junrao] please take a look at this issue, thank you >

[jira] [Assigned] (KAFKA-8806) Kafka.poll spends significant amount of time in KafkaConsumer.updateAssignmentMetadataIfNeeded

[ https://issues.apache.org/jira/browse/KAFKA-8806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reassigned KAFKA-8806: -- Assignee: David Arthur > Kafka.poll spends significant amount of time in >

[jira] [Created] (KAFKA-8806) Kafka.poll spends significant amount of time in KafkaConsumer.updateAssignmentMetadataIfNeeded

Xavier Léauté created KAFKA-8806: Summary: Kafka.poll spends significant amount of time in KafkaConsumer.updateAssignmentMetadataIfNeeded Key: KAFKA-8806 URL: https://issues.apache.org/jira/browse/KAFKA-8806

[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=16907672#comment-16907672 ] David Jacot commented on KAFKA-8796: [~rmarou] Have you tried to experiment with throttling the

[jira] [Created] (KAFKA-8805) Bump producer epoch following recoverable errors

Bob Barrett created KAFKA-8805: -- Summary: Bump producer epoch following recoverable errors Key: KAFKA-8805 URL: https://issues.apache.org/jira/browse/KAFKA-8805 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-8804) Internal Connect REST endpoints are insecure

Chris Egerton created KAFKA-8804: Summary: Internal Connect REST endpoints are insecure Key: KAFKA-8804 URL: https://issues.apache.org/jira/browse/KAFKA-8804 Project: Kafka Issue Type: Bug

[jira] [Assigned] (KAFKA-8755) Stand-by Task of an Optimized Source Table Does Not Write Anything to its State Store

[ https://issues.apache.org/jira/browse/KAFKA-8755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Pettitt reassigned KAFKA-8755: Assignee: Chris Pettitt > Stand-by Task of an Optimized Source Table Does Not Write

[jira] [Commented] (KAFKA-4212) Add a key-value store that is a TTL persistent cache

[ https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16907548#comment-16907548 ] Guozhang Wang commented on KAFKA-4212: -- Hello [~jamesritt] sorry for being late to this discussion,

[jira] [Updated] (KAFKA-8799) Support ability to pass global user data to consumers during Assignment

[ https://issues.apache.org/jira/browse/KAFKA-8799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-8799: - Component/s: consumer > Support ability to pass global user data to consumers during Assignment

[jira] [Assigned] (KAFKA-8730) Add API to delete consumer offsets (KIP-496)

[ https://issues.apache.org/jira/browse/KAFKA-8730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot reassigned KAFKA-8730: -- Assignee: David Jacot > Add API to delete consumer offsets (KIP-496) >

[jira] [Commented] (KAFKA-8802) ConcurrentSkipListMap shows performance regression in cache and in-memory store

[ https://issues.apache.org/jira/browse/KAFKA-8802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16907477#comment-16907477 ] ASF GitHub Bot commented on KAFKA-8802: --- vvcephei commented on pull request #7213: KAFKA-8802:

[jira] [Created] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

Raman Gupta created KAFKA-8803: -- Summary: Stream will not start due to TimeoutException: Timeout expired after 6milliseconds while awaiting InitProducerId Key: KAFKA-8803 URL:

[jira] [Commented] (KAFKA-8802) ConcurrentSkipListMap shows performance regression in cache and in-memory store

[ https://issues.apache.org/jira/browse/KAFKA-8802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16907464#comment-16907464 ] ASF GitHub Bot commented on KAFKA-8802: --- ableegoldman commented on pull request #7212: KAFKA-8802:

[jira] [Created] (KAFKA-8802) ConcurrentSkipListMap shows performance regression in cache and in-memory store

Sophie Blee-Goldman created KAFKA-8802: -- Summary: ConcurrentSkipListMap shows performance regression in cache and in-memory store Key: KAFKA-8802 URL: https://issues.apache.org/jira/browse/KAFKA-8802

[jira] [Reopened] (KAFKA-7912) In-memory key-value store does not support concurrent access

[ https://issues.apache.org/jira/browse/KAFKA-7912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman reopened KAFKA-7912: The fix for this caused a performance regression and is being rolled back. We should

[jira] [Commented] (KAFKA-7335) Store clusterId locally to ensure broker joins the right cluster

[ https://issues.apache.org/jira/browse/KAFKA-7335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16907444#comment-16907444 ] ASF GitHub Bot commented on KAFKA-7335: --- hachikuji commented on pull request #7189: KAFKA-7335:

[jira] [Commented] (KAFKA-8345) Create an Administrative API for Replica Reassignment

[ https://issues.apache.org/jira/browse/KAFKA-8345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16907409#comment-16907409 ] ASF GitHub Bot commented on KAFKA-8345: --- cmccabe commented on pull request #7120: KAFKA-8345:

[jira] [Assigned] (KAFKA-8800) Flaky Test SaslScramSslEndToEndAuthorizationTest#testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl

[ https://issues.apache.org/jira/browse/KAFKA-8800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lee Dongjin reassigned KAFKA-8800: -- Assignee: Lee Dongjin > Flaky Test >

[jira] [Commented] (KAFKA-8041) Flaky Test LogDirFailureTest#testIOExceptionDuringLogRoll

[ https://issues.apache.org/jira/browse/KAFKA-8041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16907202#comment-16907202 ] Bruno Cadonna commented on KAFKA-8041: --

[jira] [Commented] (KAFKA-8661) Flaky Test RebalanceSourceConnectorsIntegrationTest#testStartTwoConnectors

[ https://issues.apache.org/jira/browse/KAFKA-8661?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16907201#comment-16907201 ] Bruno Cadonna commented on KAFKA-8661: --

[jira] [Commented] (KAFKA-8720) Flakey test AdminClientIntegrationTest #testElectUncleanLeadersForManyPartitions

[ https://issues.apache.org/jira/browse/KAFKA-8720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16907197#comment-16907197 ] Bruno Cadonna commented on KAFKA-8720: --

[jira] [Commented] (KAFKA-1778) Create new re-elect controller admin function

[ https://issues.apache.org/jira/browse/KAFKA-1778?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16907088#comment-16907088 ] weiwei commented on KAFKA-1778: --- Is there any progress on this issue? In the preceding solution, a brokerX

[jira] [Created] (KAFKA-8801) electLeaderForPartitions redundancy for some success elect partitions

shilin Lu created KAFKA-8801: Summary: electLeaderForPartitions redundancy for some success elect partitions Key: KAFKA-8801 URL: https://issues.apache.org/jira/browse/KAFKA-8801 Project: Kafka

[jira] [Commented] (KAFKA-8579) Expose RocksDB Metrics to JMX

[ https://issues.apache.org/jira/browse/KAFKA-8579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16906939#comment-16906939 ] ASF GitHub Bot commented on KAFKA-8579: --- cadonna commented on pull request #7209: KAFKA-8579:

[jira] [Resolved] (KAFKA-8792) Default ZK configuration to disable AdminServer

[ https://issues.apache.org/jira/browse/KAFKA-8792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira resolved KAFKA-8792. - Resolution: Fixed Reviewer: Ismael Juma Fix Version/s: 2.4.0 > Default ZK

[jira] [Resolved] (KAFKA-8695) Metrics UnderReplicated and UnderMinIsr are diverging when configuration is inconsistent

[ https://issues.apache.org/jira/browse/KAFKA-8695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexandre Dupriez resolved KAFKA-8695. -- Resolution: Duplicate De-duplicating in favor of 

[jira] [Updated] (KAFKA-6556) allow to attach callbacks in kafka streams, to be triggered when a window is expired

[ https://issues.apache.org/jira/browse/KAFKA-6556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6556: --- Labels: needs-kip (was: kip) > allow to attach callbacks in kafka streams, to be triggered

[jira] [Commented] (KAFKA-6556) allow to attach callbacks in kafka streams, to be triggered when a window is expired

[ https://issues.apache.org/jira/browse/KAFKA-6556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16906914#comment-16906914 ] Matthias J. Sax commented on KAFKA-6556: This feature is not schedule atm and I don't think that