[jira] [Commented] (KAFKA-8328) Kafka smooth expansion

[ https://issues.apache.org/jira/browse/KAFKA-8328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16916292#comment-16916292 ] roncenzhao commented on KAFKA-8328: --- Hi [~LordChen] , what's the progress about this KIP? The KIP page

[jira] [Commented] (KAFKA-8828) [BC Break] Global store returns a TimestampedKeyValueStore in 2.3

[ https://issues.apache.org/jira/browse/KAFKA-8828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16916255#comment-16916255 ] Marcos Passos commented on KAFKA-8828: -- The issue I’m facing is pretty much the same as Adams’s. I

[jira] [Commented] (KAFKA-8828) [BC Break] Global store returns a TimestampedKeyValueStore in 2.3

[ https://issues.apache.org/jira/browse/KAFKA-8828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16916251#comment-16916251 ] Adam Rinehart commented on KAFKA-8828: -- This issue just happened to me.  I am using the DSL. I

[jira] [Commented] (KAFKA-8831) Joining a new instance sometimes does not cause rebalancing

[ https://issues.apache.org/jira/browse/KAFKA-8831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16916234#comment-16916234 ] Vinoth Chandar commented on KAFKA-8831: --- >>Maybe I'm missing your point, but it doesn't seem like

[jira] [Assigned] (KAFKA-8813) Race condition when creating topics and changing their configuration

[ https://issues.apache.org/jira/browse/KAFKA-8813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vikas Singh reassigned KAFKA-8813: -- Assignee: Vikas Singh > Race condition when creating topics and changing their configuration

[jira] [Commented] (KAFKA-8813) Race condition when creating topics and changing their configuration

[ https://issues.apache.org/jira/browse/KAFKA-8813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16916232#comment-16916232 ] Vikas Singh commented on KAFKA-8813: I am working on a fix for this issue. Expect a PR sometime this

[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=16916224#comment-16916224 ] ASF GitHub Bot commented on KAFKA-8579: --- guozhangwang commented on pull request #7209: KAFKA-8579:

[jira] [Commented] (KAFKA-8831) Joining a new instance sometimes does not cause rebalancing

[ https://issues.apache.org/jira/browse/KAFKA-8831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16916203#comment-16916203 ] Sophie Blee-Goldman commented on KAFKA-8831: >>Ah, is this the one that's trace because it

[jira] [Commented] (KAFKA-8831) Joining a new instance sometimes does not cause rebalancing

[ https://issues.apache.org/jira/browse/KAFKA-8831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16916192#comment-16916192 ] Vinoth Chandar commented on KAFKA-8831: --- Sorry.. keep forgetting to refresh the page before

[jira] [Resolved] (KAFKA-8831) Joining a new instance sometimes does not cause rebalancing

[ https://issues.apache.org/jira/browse/KAFKA-8831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vinoth Chandar resolved KAFKA-8831. --- Resolution: Not A Problem I will think about better logging and put up a patch. Closing this

[jira] [Commented] (KAFKA-8831) Joining a new instance sometimes does not cause rebalancing

[ https://issues.apache.org/jira/browse/KAFKA-8831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16916186#comment-16916186 ] Sophie Blee-Goldman commented on KAFKA-8831: Ah, is this the one that's trace because it will

[jira] [Commented] (KAFKA-8837) KafkaMetricReporterClusterIdTest may not shutdown ZooKeeperTestHarness

[ https://issues.apache.org/jira/browse/KAFKA-8837?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16916175#comment-16916175 ] ASF GitHub Bot commented on KAFKA-8837: --- anatasiavela commented on pull request #7255: KAFKA-8837:

[jira] [Commented] (KAFKA-8831) Joining a new instance sometimes does not cause rebalancing

[ https://issues.apache.org/jira/browse/KAFKA-8831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16916174#comment-16916174 ] Vinoth Chandar commented on KAFKA-8831: --- [~ableegoldman] yes to your statement above.  > Joining a

[jira] [Commented] (KAFKA-8831) Joining a new instance sometimes does not cause rebalancing

[ https://issues.apache.org/jira/browse/KAFKA-8831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16916173#comment-16916173 ] Vinoth Chandar commented on KAFKA-8831: --- Turns out its a LockException that’s in trace mode in

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

[ https://issues.apache.org/jira/browse/KAFKA-8800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16916170#comment-16916170 ] Anna Povzner commented on KAFKA-8800: - I am re-opening this one, because increasing timeouts didn't

[jira] [Commented] (KAFKA-8677) Flakey test GroupEndToEndAuthorizationTest#testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl

[ https://issues.apache.org/jira/browse/KAFKA-8677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16916167#comment-16916167 ] Ismael Juma commented on KAFKA-8677: Can we reopen KAFKA-8800 instead? Btw, I think you did not

[jira] [Commented] (KAFKA-8831) Joining a new instance sometimes does not cause rebalancing

[ https://issues.apache.org/jira/browse/KAFKA-8831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16916165#comment-16916165 ] Sophie Blee-Goldman commented on KAFKA-8831: [~vinoth] Just to clarify, do you delete all

[jira] [Commented] (KAFKA-8831) Joining a new instance sometimes does not cause rebalancing

[ https://issues.apache.org/jira/browse/KAFKA-8831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16916154#comment-16916154 ] Vinoth Chandar commented on KAFKA-8831: --- Elaborating on the topology for context. There are two

[jira] [Assigned] (KAFKA-8677) Flakey test GroupEndToEndAuthorizationTest#testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl

[ https://issues.apache.org/jira/browse/KAFKA-8677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anna Povzner reassigned KAFKA-8677: --- Assignee: Anastasia Vela > Flakey test >

[jira] [Commented] (KAFKA-8677) Flakey test GroupEndToEndAuthorizationTest#testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl

[ https://issues.apache.org/jira/browse/KAFKA-8677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16916153#comment-16916153 ] Anna Povzner commented on KAFKA-8677: - I am re-opening this one, because increasing timeouts in

[jira] [Commented] (KAFKA-8816) RecordCollector offsets updated indirectly by StreamTask

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

[jira] [Created] (KAFKA-8837) KafkaMetricReporterClusterIdTest may not shutdown ZooKeeperTestHarness

Anna Povzner created KAFKA-8837: --- Summary: KafkaMetricReporterClusterIdTest may not shutdown ZooKeeperTestHarness Key: KAFKA-8837 URL: https://issues.apache.org/jira/browse/KAFKA-8837 Project: Kafka

[jira] [Commented] (KAFKA-8831) Joining a new instance sometimes does not cause rebalancing

[ https://issues.apache.org/jira/browse/KAFKA-8831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16916005#comment-16916005 ] Vinoth Chandar commented on KAFKA-8831: --- With this log statement _log.info("Active : " +

[jira] [Commented] (KAFKA-8831) Joining a new instance sometimes does not cause rebalancing

[ https://issues.apache.org/jira/browse/KAFKA-8831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16915987#comment-16915987 ] Guozhang Wang commented on KAFKA-8831: -- Topology from Chris. Topologies: Sub-topology: 0

[jira] [Comment Edited] (KAFKA-8831) Joining a new instance sometimes does not cause rebalancing

[ https://issues.apache.org/jira/browse/KAFKA-8831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16915954#comment-16915954 ] Vinoth Chandar edited comment on KAFKA-8831 at 8/26/19 5:12 PM:

[jira] [Commented] (KAFKA-8831) Joining a new instance sometimes does not cause rebalancing

[ https://issues.apache.org/jira/browse/KAFKA-8831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16915957#comment-16915957 ] Chris Pettitt commented on KAFKA-8831: -- I'm doing state restore too. I happen to be in the office

[jira] [Created] (KAFKA-8836) Add inter-broker protocol to alter ISR

Jason Gustafson created KAFKA-8836: -- Summary: Add inter-broker protocol to alter ISR Key: KAFKA-8836 URL: https://issues.apache.org/jira/browse/KAFKA-8836 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-8831) Joining a new instance sometimes does not cause rebalancing

[ https://issues.apache.org/jira/browse/KAFKA-8831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16915954#comment-16915954 ] Vinoth Chandar commented on KAFKA-8831: --- [~cpettitt-confluent] I am not seeing it recover after 30

[jira] [Created] (KAFKA-8835) Update documentation for URP changes in KIP-352

Jason Gustafson created KAFKA-8835: -- Summary: Update documentation for URP changes in KIP-352 Key: KAFKA-8835 URL: https://issues.apache.org/jira/browse/KAFKA-8835 Project: Kafka Issue

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

Jason Gustafson created KAFKA-8834: -- Summary: Distinguish URPs caused by reassignment plus other metrics Key: KAFKA-8834 URL: https://issues.apache.org/jira/browse/KAFKA-8834 Project: Kafka

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

[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16915946#comment-16915946 ] Raman Gupta commented on KAFKA-8803: [~bbejeck] Any updates on this? The stream still won't start. >

[jira] [Updated] (KAFKA-8412) Still a nullpointer exception thrown on shutdown while flushing before closing producers

[ https://issues.apache.org/jira/browse/KAFKA-8412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-8412: - Fix Version/s: 2.3.1 2.4.0 2.2.2 2.1.2

[jira] [Resolved] (KAFKA-8412) Still a nullpointer exception thrown on shutdown while flushing before closing producers

[ https://issues.apache.org/jira/browse/KAFKA-8412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-8412. -- Resolution: Fixed > Still a nullpointer exception thrown on shutdown while flushing before >

[jira] [Commented] (KAFKA-8412) Still a nullpointer exception thrown on shutdown while flushing before closing producers

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

[jira] [Commented] (KAFKA-7632) Allow fine-grained configuration for compression

[ https://issues.apache.org/jira/browse/KAFKA-7632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16915922#comment-16915922 ] Lee Dongjin commented on KAFKA-7632: [~ckozak] The draft of two interface types are already

[jira] [Updated] (KAFKA-8833) Metric for Broker Consumer Lag in size and time

[ https://issues.apache.org/jira/browse/KAFKA-8833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] NIKHIL updated KAFKA-8833: -- Description: In many use cases consumers are expected to fetch at the tail end of the log. The proposal is to

[jira] [Created] (KAFKA-8833) Metric for Broker Consumer Lag in size and time

NIKHIL created KAFKA-8833: - Summary: Metric for Broker Consumer Lag in size and time Key: KAFKA-8833 URL: https://issues.apache.org/jira/browse/KAFKA-8833 Project: Kafka Issue Type: Improvement

[jira] [Comment Edited] (KAFKA-8468) AdminClient.deleteTopics doesn't wait until topic is deleted

[ https://issues.apache.org/jira/browse/KAFKA-8468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16913516#comment-16913516 ] Viktor Somogyi-Vass edited comment on KAFKA-8468 at 8/26/19 9:21 AM: -

[jira] [Commented] (KAFKA-8468) AdminClient.deleteTopics doesn't wait until topic is deleted

[ https://issues.apache.org/jira/browse/KAFKA-8468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16915623#comment-16915623 ] Gabor Somogyi commented on KAFKA-8468: -- [~viktorsomogyi] thanks for investing your time! Related