[jira] [Commented] (KAFKA-9625) Unable to Describe broker configurations that have been set via IncrementalAlterConfigs

[ https://issues.apache.org/jira/browse/KAFKA-9625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17061432#comment-17061432 ] ASF GitHub Bot commented on KAFKA-9625: --- cmccabe commented on pull request #8260: K

[jira] [Commented] (KAFKA-5604) All producer methods should raise `ProducerFencedException` after the first time.

[ https://issues.apache.org/jira/browse/KAFKA-5604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17061275#comment-17061275 ] Xiang Zhang commented on KAFKA-5604: Also, under that TODO marker, it says "this shou

[jira] [Comment Edited] (KAFKA-5604) All producer methods should raise `ProducerFencedException` after the first time.

[ https://issues.apache.org/jira/browse/KAFKA-5604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17061275#comment-17061275 ] Xiang Zhang edited comment on KAFKA-5604 at 3/18/20, 12:19 AM:

[jira] [Commented] (KAFKA-5604) All producer methods should raise `ProducerFencedException` after the first time.

[ https://issues.apache.org/jira/browse/KAFKA-5604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17061269#comment-17061269 ] Xiang Zhang commented on KAFKA-5604: [~guozhang] I believe there is still a TODO mark

[jira] [Commented] (KAFKA-3919) Broker faills to start after ungraceful shutdown due to non-monotonically incrementing offsets in logs

[ https://issues.apache.org/jira/browse/KAFKA-3919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17061243#comment-17061243 ] Jun Rao commented on KAFKA-3919: [~zhangchenghui]: Appreciate the detailed analysis. I no

[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&focusedCommentId=17061205#comment-17061205 ] ASF GitHub Bot commented on KAFKA-8803: --- guozhangwang commented on pull request #82

[jira] [Updated] (KAFKA-7493) Rewrite test_broker_type_bounce_at_start

[ https://issues.apache.org/jira/browse/KAFKA-7493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Arthur updated KAFKA-7493: Fix Version/s: 2.6.0 > Rewrite test_broker_type_bounce_at_start > -

[jira] [Updated] (KAFKA-7271) Fix ignored test in streams_upgrade_test.py: test_upgrade_downgrade_brokers

[ https://issues.apache.org/jira/browse/KAFKA-7271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Arthur updated KAFKA-7271: Fix Version/s: 2.6.0 > Fix ignored test in streams_upgrade_test.py: test_upgrade_downgrade_brokers

[jira] [Assigned] (KAFKA-9659) Kafka Streams / Consumer configured for static membership fails on "fatal exception: group.instance.id gets fenced"

[ https://issues.apache.org/jira/browse/KAFKA-9659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-9659: Assignee: Guozhang Wang > Kafka Streams / Consumer configured for static membership fails

[jira] [Created] (KAFKA-9731) Increased fetch request rate with leader selector due to HW propagation

Vahid Hashemian created KAFKA-9731: -- Summary: Increased fetch request rate with leader selector due to HW propagation Key: KAFKA-9731 URL: https://issues.apache.org/jira/browse/KAFKA-9731 Project: Ka

[jira] [Updated] (KAFKA-3702) SslTransportLayer.close() does not shutdown gracefully

[ https://issues.apache.org/jira/browse/KAFKA-3702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram updated KAFKA-3702: -- Fix Version/s: (was: 2.0.0) > SslTransportLayer.close() does not shutdown gracefully >

[jira] [Reopened] (KAFKA-3702) SslTransportLayer.close() does not shutdown gracefully

[ https://issues.apache.org/jira/browse/KAFKA-3702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram reopened KAFKA-3702: --- We changed the log level of the entry `Failed to send SSL Close message` from WARN to DEBUG, but

[jira] [Comment Edited] (KAFKA-9573) TestUpgrade system test failed on Java11.

[ https://issues.apache.org/jira/browse/KAFKA-9573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17060926#comment-17060926 ] Nikolay Izhikov edited comment on KAFKA-9573 at 3/17/20, 1:58 PM: -

[jira] [Commented] (KAFKA-9573) TestUpgrade system test failed on Java11.

[ https://issues.apache.org/jira/browse/KAFKA-9573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17060926#comment-17060926 ] Nikolay Izhikov commented on KAFKA-9573: {noformat} =

[jira] [Commented] (KAFKA-9730) add tag "partition" to BrokerTopicMetrics so as to observe the partition metrics on the same broker

[ https://issues.apache.org/jira/browse/KAFKA-9730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17060811#comment-17060811 ] ASF GitHub Bot commented on KAFKA-9730: --- chia7712 commented on pull request #8309:

[jira] [Updated] (KAFKA-9730) add tag "partition" to BrokerTopicMetrics so as to observe the partition metrics on the same broker

[ https://issues.apache.org/jira/browse/KAFKA-9730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai updated KAFKA-9730: -- Summary: add tag "partition" to BrokerTopicMetrics so as to observe the partition metrics on th

[jira] [Updated] (KAFKA-9730) add tag "partition" to BrokerTopicMetrics so as to observe the metrics of partition in the same broker

[ https://issues.apache.org/jira/browse/KAFKA-9730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai updated KAFKA-9730: -- Attachment: trunk.jpg patch.jpg > add tag "partition" to BrokerTopicMetrics so

[jira] [Created] (KAFKA-9730) add tag "partition" to BrokerTopicMetrics so as to observe the metrics of partition in the same broker

Chia-Ping Tsai created KAFKA-9730: - Summary: add tag "partition" to BrokerTopicMetrics so as to observe the metrics of partition in the same broker Key: KAFKA-9730 URL: https://issues.apache.org/jira/browse/KAFKA-

[jira] [Updated] (KAFKA-9729) Shrink inWriteLock time in SimpleAuthorizer

[ https://issues.apache.org/jira/browse/KAFKA-9729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiao Zhang updated KAFKA-9729: -- Description: Current SimpleAuthorizer needs 'inWriteLock' when processing add/remove acls requests, wh

[jira] [Updated] (KAFKA-9729) Shrink inWriteLock time in SimpleAuthorizer

[ https://issues.apache.org/jira/browse/KAFKA-9729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiao Zhang updated KAFKA-9729: -- Description: Current SimpleAuthorizer needs 'inWriteLock' when processing add/remove acls requests, wh

[jira] [Updated] (KAFKA-9729) Shrink inWriteLock time in SimpleAuthorizer

[ https://issues.apache.org/jira/browse/KAFKA-9729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiao Zhang updated KAFKA-9729: -- Description: Current SimpleAuthorizer needs 'inWriteLock' when processing add/remove acls requests, wh

[jira] [Updated] (KAFKA-9729) Shrink inWriteLock time in SimpleAuthorizer

[ https://issues.apache.org/jira/browse/KAFKA-9729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiao Zhang updated KAFKA-9729: -- Description: Current SimpleAuthorizer needs 'inWriteLock' when processing add/remove acls requests, wh

[jira] [Updated] (KAFKA-9729) Shrink inWriteLock time in SimpleAuthorizer

[ https://issues.apache.org/jira/browse/KAFKA-9729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiao Zhang updated KAFKA-9729: -- Description: Current SimpleAuthorizer needs 'inWriteLock' when processing add/remove acls requests, wh

[jira] [Updated] (KAFKA-9729) Shrink inWriteLock time in SimpleAuthorizer

[ https://issues.apache.org/jira/browse/KAFKA-9729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiao Zhang updated KAFKA-9729: -- Description: Current SimpleAuthorizer needs 'inWriteLock' when processing add/remove acls requests, wh

[jira] [Updated] (KAFKA-9729) Shrink inWriteLock time in SimpleAuthorizer

[ https://issues.apache.org/jira/browse/KAFKA-9729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiao Zhang updated KAFKA-9729: -- Description: Current SimpleAuthorizer needs 'inWriteLock' when processing add/remove acls requests, wh

[jira] [Created] (KAFKA-9729) Shrink inWriteLock time in SimpleAuthorizer

Jiao Zhang created KAFKA-9729: - Summary: Shrink inWriteLock time in SimpleAuthorizer Key: KAFKA-9729 URL: https://issues.apache.org/jira/browse/KAFKA-9729 Project: Kafka Issue Type: Improvement

[jira] [Resolved] (KAFKA-6941) when passing port = 0 to worker, the advertisedPort still is 0 rather than a random port

[ https://issues.apache.org/jira/browse/KAFKA-6941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-6941. --- Resolution: Won't Fix > when passing port = 0 to worker, the advertisedPort still is 0 rather

[jira] [Resolved] (KAFKA-6931) Make worker id configurable

[ https://issues.apache.org/jira/browse/KAFKA-6931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-6931. --- Resolution: Won't Fix > Make worker id configurable > --- > >

[jira] [Resolved] (KAFKA-7084) NewTopicBuilder#config should accept Map rather than Map

[ https://issues.apache.org/jira/browse/KAFKA-7084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-7084. --- Resolution: Won't Fix > NewTopicBuilder#config should accept Map rather than > Map > ---

[jira] [Commented] (KAFKA-7084) NewTopicBuilder#config should accept Map rather than Map

[ https://issues.apache.org/jira/browse/KAFKA-7084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17060733#comment-17060733 ] ASF GitHub Bot commented on KAFKA-7084: --- chia7712 commented on pull request #5261:

[jira] [Commented] (KAFKA-6941) when passing port = 0 to worker, the advertisedPort still is 0 rather than a random port

[ https://issues.apache.org/jira/browse/KAFKA-6941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17060735#comment-17060735 ] ASF GitHub Bot commented on KAFKA-6941: --- chia7712 commented on pull request #5076:

[jira] [Commented] (KAFKA-6931) Make worker id configurable

[ https://issues.apache.org/jira/browse/KAFKA-6931?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17060734#comment-17060734 ] ASF GitHub Bot commented on KAFKA-6931: --- chia7712 commented on pull request #5069: