[jira] [Resolved] (KAFKA-8899) Optimize Partition.maybeIncrementLeaderHW

[ https://issues.apache.org/jira/browse/KAFKA-8899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Bradstreet resolved KAFKA-8899. - Resolution: Duplicate Duplicate of https://issues.apache.org/jira/browse/KAFKA-8841 >

[jira] [Commented] (KAFKA-8841) Optimize Partition.maybeIncrementLeaderHW

[ https://issues.apache.org/jira/browse/KAFKA-8841?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16928932#comment-16928932 ] Lucas Bradstreet commented on KAFKA-8841: - PR is available at 

[jira] [Updated] (KAFKA-8904) Reduce metadata lookups when producing to a large number of topics

[ https://issues.apache.org/jira/browse/KAFKA-8904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Brian Byrne updated KAFKA-8904: --- Summary: Reduce metadata lookups when producing to a large number of topics (was: Reduce metadata

[jira] [Created] (KAFKA-8904) Reduce metadata lookups when producting to a large number of topics

Brian Byrne created KAFKA-8904: -- Summary: Reduce metadata lookups when producting to a large number of topics Key: KAFKA-8904 URL: https://issues.apache.org/jira/browse/KAFKA-8904 Project: Kafka

[jira] [Updated] (KAFKA-8903) allow the new replica (offset 0) to catch up with current leader using latest offset

[ https://issues.apache.org/jira/browse/KAFKA-8903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] GEORGE LI updated KAFKA-8903: - Description: It very common (and sometimes frequent) that a broker has hardware failures (disk, memory,

[jira] [Updated] (KAFKA-8903) allow the new replica (offset 0) to catch up with current leader using latest offset

[ https://issues.apache.org/jira/browse/KAFKA-8903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] GEORGE LI updated KAFKA-8903: - Description: It very common (and sometimes frequent) that a broker has hardware failures (disk, memory,

[jira] [Commented] (KAFKA-8903) allow the new replica (offset 0) to catch up with current leader using latest offset

[ https://issues.apache.org/jira/browse/KAFKA-8903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16928906#comment-16928906 ] GEORGE LI commented on KAFKA-8903: -- e.g. {code:java} /usr/lib/kafka/bin/kafka-configs.sh

[jira] [Created] (KAFKA-8903) allow the new replica (offset 0) to catch up with current leader using latest offset

GEORGE LI created KAFKA-8903: Summary: allow the new replica (offset 0) to catch up with current leader using latest offset Key: KAFKA-8903 URL: https://issues.apache.org/jira/browse/KAFKA-8903 Project:

[jira] [Commented] (KAFKA-8427) Error while cleanup under windows for EmbeddedKafkaCluster

[ https://issues.apache.org/jira/browse/KAFKA-8427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16928863#comment-16928863 ] Evan Nelson commented on KAFKA-8427: This issue is still present in 2.3.0 > Error while cleanup

[jira] [Commented] (KAFKA-7625) Kafka Broker node JVM crash - kafka.coordinator.transaction.TransactionCoordinator.$anonfun$handleEndTransaction

[ https://issues.apache.org/jira/browse/KAFKA-7625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16928853#comment-16928853 ] zhangzhisheng commented on KAFKA-7625: -- we has the crash case in 2.12.0.11.0.2 version and

[jira] [Comment Edited] (KAFKA-6098) Delete and Re-create topic operation could result in race condition

[ https://issues.apache.org/jira/browse/KAFKA-6098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16928844#comment-16928844 ] Brian Byrne edited comment on KAFKA-6098 at 9/12/19 7:45 PM: - I've been

[jira] [Commented] (KAFKA-6098) Delete and Re-create topic operation could result in race condition

[ https://issues.apache.org/jira/browse/KAFKA-6098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16928844#comment-16928844 ] Brian Byrne commented on KAFKA-6098: I've been investigating this issue and have collected some

[jira] [Commented] (KAFKA-7658) Add KStream#toTable to the Streams DSL

[ https://issues.apache.org/jira/browse/KAFKA-7658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16928828#comment-16928828 ] Matthias J. Sax commented on KAFKA-7658: Added you to the list of contributors. You can now

[jira] [Assigned] (KAFKA-7658) Add KStream#toTable to the Streams DSL

[ https://issues.apache.org/jira/browse/KAFKA-7658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-7658: -- Assignee: Aishwarya Pradeep Kumar > Add KStream#toTable to the Streams DSL >

[jira] [Comment Edited] (KAFKA-7658) Add KStream#toTable to the Streams DSL

[ https://issues.apache.org/jira/browse/KAFKA-7658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16928814#comment-16928814 ] Aishwarya Pradeep Kumar edited comment on KAFKA-7658 at 9/12/19 6:40 PM:

[jira] [Commented] (KAFKA-7658) Add KStream#toTable to the Streams DSL

[ https://issues.apache.org/jira/browse/KAFKA-7658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16928814#comment-16928814 ] Aishwarya Pradeep Kumar commented on KAFKA-7658: Thank you!! KIP is created 

[jira] [Created] (KAFKA-8902) Benchmark cooperative vs eager rebalancing

Sophie Blee-Goldman created KAFKA-8902: -- Summary: Benchmark cooperative vs eager rebalancing Key: KAFKA-8902 URL: https://issues.apache.org/jira/browse/KAFKA-8902 Project: Kafka Issue

[jira] [Commented] (KAFKA-8179) Incremental Rebalance Protocol for Kafka Consumer

[ https://issues.apache.org/jira/browse/KAFKA-8179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16928781#comment-16928781 ] Guozhang Wang commented on KAFKA-8179: -- [~ableegoldman] Let's use this umbrella ticket to track our

[jira] [Commented] (KAFKA-8026) Flaky Test RegexSourceIntegrationTest#testRegexMatchesTopicsAWhenDeleted

[ https://issues.apache.org/jira/browse/KAFKA-8026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16928730#comment-16928730 ] ASF GitHub Bot commented on KAFKA-8026: --- mjsax commented on pull request #7051: KAFKA-8026: Fix for

[jira] [Resolved] (KAFKA-8355) Add static membership to Range assignor

[ https://issues.apache.org/jira/browse/KAFKA-8355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-8355. -- Fix Version/s: 2.4.0 Resolution: Fixed > Add static membership to Range assignor >

[jira] [Commented] (KAFKA-8355) Add static membership to Range assignor

[ https://issues.apache.org/jira/browse/KAFKA-8355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16928729#comment-16928729 ] ASF GitHub Bot commented on KAFKA-8355: --- guozhangwang commented on pull request #7014: KAFKA-8355:

[jira] [Commented] (KAFKA-8682) Add meter for group rebalance rate

[ https://issues.apache.org/jira/browse/KAFKA-8682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16928725#comment-16928725 ] Guozhang Wang commented on KAFKA-8682: -- This is for adding metrics on the broker-side group

[jira] [Commented] (KAFKA-7658) Add KStream#toTable to the Streams DSL

[ https://issues.apache.org/jira/browse/KAFKA-7658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16928721#comment-16928721 ] Matthias J. Sax commented on KAFKA-7658: Write permissions granted. Looking forward to your KIP.

[jira] [Commented] (KAFKA-8119) KafkaConfig listener accessors may fail during dynamic update

[ https://issues.apache.org/jira/browse/KAFKA-8119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16928630#comment-16928630 ] Randall Hauch commented on KAFKA-8119: -- Removed Fix Version 2.2.2 as this issue is not blocking that

[jira] [Updated] (KAFKA-8119) KafkaConfig listener accessors may fail during dynamic update

[ https://issues.apache.org/jira/browse/KAFKA-8119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-8119: - Fix Version/s: (was: 2.2.2) 2.2.3 > KafkaConfig listener accessors may

[jira] [Updated] (KAFKA-8391) Flaky Test RebalanceSourceConnectorsIntegrationTest#testDeleteConnector

[ https://issues.apache.org/jira/browse/KAFKA-8391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-8391: - Fix Version/s: (was: 2.2.2) 2.2.3 > Flaky Test

[jira] [Updated] (KAFKA-8055) Flaky Test LogCleanerParameterizedIntegrationTest#cleanerTest

[ https://issues.apache.org/jira/browse/KAFKA-8055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-8055: - Fix Version/s: (was: 2.2.2) 2.2.3 > Flaky Test

[jira] [Commented] (KAFKA-8055) Flaky Test LogCleanerParameterizedIntegrationTest#cleanerTest

[ https://issues.apache.org/jira/browse/KAFKA-8055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16928626#comment-16928626 ] Randall Hauch commented on KAFKA-8055: -- Removed Fix Version 2.2.2 as this issue is not blocking that

[jira] [Commented] (KAFKA-8391) Flaky Test RebalanceSourceConnectorsIntegrationTest#testDeleteConnector

[ https://issues.apache.org/jira/browse/KAFKA-8391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16928628#comment-16928628 ] Randall Hauch commented on KAFKA-8391: -- Removed Fix Version 2.2.2 as this issue is not blocking that

[jira] [Updated] (KAFKA-8073) Transient failure in kafka.api.UserQuotaTest.testThrottledProducerConsumer

[ https://issues.apache.org/jira/browse/KAFKA-8073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-8073: - Fix Version/s: (was: 2.2.2) 2.2.3 > Transient failure in

[jira] [Commented] (KAFKA-8073) Transient failure in kafka.api.UserQuotaTest.testThrottledProducerConsumer

[ https://issues.apache.org/jira/browse/KAFKA-8073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16928627#comment-16928627 ] Randall Hauch commented on KAFKA-8073: -- Removed Fix Version 2.2.2 as this issue is not blocking that

[jira] [Commented] (KAFKA-8003) Flaky Test TransactionsTest #testFencingOnTransactionExpiration

[ https://issues.apache.org/jira/browse/KAFKA-8003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16928624#comment-16928624 ] Randall Hauch commented on KAFKA-8003: -- Removed Fix Version 2.2.2 as this issue is not blocking that

[jira] [Updated] (KAFKA-8003) Flaky Test TransactionsTest #testFencingOnTransactionExpiration

[ https://issues.apache.org/jira/browse/KAFKA-8003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-8003: - Fix Version/s: (was: 2.2.2) 2.2.3 > Flaky Test TransactionsTest

[jira] [Updated] (KAFKA-2933) Failure in kafka.api.PlaintextConsumerTest.testMultiConsumerDefaultAssignment

[ https://issues.apache.org/jira/browse/KAFKA-2933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-2933: - Fix Version/s: (was: 2.2.2) 2.2.3 > Failure in

[jira] [Commented] (KAFKA-2933) Failure in kafka.api.PlaintextConsumerTest.testMultiConsumerDefaultAssignment

[ https://issues.apache.org/jira/browse/KAFKA-2933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16928623#comment-16928623 ] Randall Hauch commented on KAFKA-2933: -- Removed Fix Version 2.2.2 as this issue is not blocking that

[jira] [Commented] (KAFKA-8047) remove KafkaMbean when network close

[ https://issues.apache.org/jira/browse/KAFKA-8047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16928622#comment-16928622 ] Randall Hauch commented on KAFKA-8047: -- Removed Fix Version 2.2.2 as this issue is not blocking that

[jira] [Updated] (KAFKA-8047) remove KafkaMbean when network close

[ https://issues.apache.org/jira/browse/KAFKA-8047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-8047: - Fix Version/s: (was: 2.2.2) 2.2.3 > remove KafkaMbean when network close

[jira] [Comment Edited] (KAFKA-8834) Distinguish URPs caused by reassignment plus other metrics

[ https://issues.apache.org/jira/browse/KAFKA-8834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16928588#comment-16928588 ] Viktor Somogyi-Vass edited comment on KAFKA-8834 at 9/12/19 2:39 PM: -

[jira] [Commented] (KAFKA-8834) Distinguish URPs caused by reassignment plus other metrics

[ https://issues.apache.org/jira/browse/KAFKA-8834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16928588#comment-16928588 ] Viktor Somogyi-Vass commented on KAFKA-8834: I've been trying to implement ReassignmentMaxLag

[jira] [Assigned] (KAFKA-8834) Distinguish URPs caused by reassignment plus other metrics

[ https://issues.apache.org/jira/browse/KAFKA-8834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Viktor Somogyi-Vass reassigned KAFKA-8834: -- Assignee: Viktor Somogyi-Vass (was: Jason Gustafson) > Distinguish URPs

[jira] [Commented] (KAFKA-7658) Add KStream#toTable to the Streams DSL

[ https://issues.apache.org/jira/browse/KAFKA-7658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16928582#comment-16928582 ] Aishwarya Pradeep Kumar commented on KAFKA-7658: [~mjsax] confluence id: ash26389. Thank

[jira] [Commented] (KAFKA-6895) Schema Inferencing for JsonConverter

[ https://issues.apache.org/jira/browse/KAFKA-6895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16928550#comment-16928550 ] Oliver Weiler commented on KAFKA-6895: -- Hi, how is this supposed to work with timestamps? From my

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

[ https://issues.apache.org/jira/browse/KAFKA-8800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Arthur updated KAFKA-8800: Fix Version/s: (was: 2.3.1) > Flaky Test >

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

[ https://issues.apache.org/jira/browse/KAFKA-8661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Arthur updated KAFKA-8661: Fix Version/s: (was: 2.3.1) > Flaky Test

[jira] [Updated] (KAFKA-8391) Flaky Test RebalanceSourceConnectorsIntegrationTest#testDeleteConnector

[ https://issues.apache.org/jira/browse/KAFKA-8391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Arthur updated KAFKA-8391: Fix Version/s: (was: 2.3.1) > Flaky Test

[jira] [Updated] (KAFKA-8869) Map taskConfigs in KafkaConfigBackingStore grows monotonically despite of task removals

[ https://issues.apache.org/jira/browse/KAFKA-8869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Arthur updated KAFKA-8869: Fix Version/s: (was: 2.3.1) 2.4.0 > Map taskConfigs in

[jira] [Created] (KAFKA-8901) Extend consumer group command to use the new Admin API to delete consumer offsets

David Jacot created KAFKA-8901: -- Summary: Extend consumer group command to use the new Admin API to delete consumer offsets Key: KAFKA-8901 URL: https://issues.apache.org/jira/browse/KAFKA-8901 Project:

[jira] [Commented] (KAFKA-8682) Add meter for group rebalance rate

[ https://issues.apache.org/jira/browse/KAFKA-8682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16928414#comment-16928414 ] Viktor Somogyi-Vass commented on KAFKA-8682: [~hachikuji] do you mind if I take this? > Add

[jira] [Resolved] (KAFKA-8838) Allow consumer group tool to work with non-existing consumer groups

[ https://issues.apache.org/jira/browse/KAFKA-8838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Patrik Kleindl resolved KAFKA-8838. --- Resolution: Not A Problem > Allow consumer group tool to work with non-existing consumer

[jira] [Commented] (KAFKA-8838) Allow consumer group tool to work with non-existing consumer groups

[ https://issues.apache.org/jira/browse/KAFKA-8838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16928395#comment-16928395 ] Patrik Kleindl commented on KAFKA-8838: --- Thanks for making me re-check, it was a human error. The

[jira] [Closed] (KAFKA-8838) Allow consumer group tool to work with non-existing consumer groups

[ https://issues.apache.org/jira/browse/KAFKA-8838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Patrik Kleindl closed KAFKA-8838. - > Allow consumer group tool to work with non-existing consumer groups >