[jira] [Commented] (KAFKA-7326) Let KStream.print() to flush on each printed line

[ https://issues.apache.org/jira/browse/KAFKA-7326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16594559#comment-16594559 ] ASF GitHub Bot commented on KAFKA-7326: --- huxihx opened a new pull request #5579: KA

[jira] [Comment Edited] (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=16594320#comment-16594320 ] Yu Yang edited comment on KAFKA-7304 at 8/28/18 5:43 AM: - After m

[jira] [Comment Edited] (KAFKA-7318) Should introduce a offset reset policy to consume only the messages after subscribing

[ https://issues.apache.org/jira/browse/KAFKA-7318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16594524#comment-16594524 ] joechen8...@gmail.com edited comment on KAFKA-7318 at 8/28/18 5:17 AM:

[jira] [Commented] (KAFKA-5998) /.checkpoint.tmp Not found exception

[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16594530#comment-16594530 ] Ayushi commented on KAFKA-5998: --- Any updates on this please? The service throws this error

[jira] [Comment Edited] (KAFKA-5998) /.checkpoint.tmp Not found exception

[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16592383#comment-16592383 ] Ayushi edited comment on KAFKA-5998 at 8/28/18 5:11 AM: [~guozhan

[jira] [Comment Edited] (KAFKA-7318) Should introduce a offset reset policy to consume only the messages after subscribing

[ https://issues.apache.org/jira/browse/KAFKA-7318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16594524#comment-16594524 ] joechen8...@gmail.com edited comment on KAFKA-7318 at 8/28/18 5:06 AM:

[jira] [Commented] (KAFKA-7318) Should introduce a offset reset policy to consume only the messages after subscribing

[ https://issues.apache.org/jira/browse/KAFKA-7318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16594524#comment-16594524 ] joechen8...@gmail.com commented on KAFKA-7318: -- I try your solution as below

[jira] [Commented] (KAFKA-7318) Should introduce a offset reset policy to consume only the messages after subscribing

[ https://issues.apache.org/jira/browse/KAFKA-7318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16594404#comment-16594404 ] joechen8...@gmail.com commented on KAFKA-7318: -- Thanks for the answer, but I

[jira] [Comment Edited] (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=16594320#comment-16594320 ] Yu Yang edited comment on KAFKA-7304 at 8/28/18 1:01 AM: - After m

[jira] [Resolved] (KAFKA-7347) Wrong error code returned for OffsetsForLeaderEpoch from non-replica

[ https://issues.apache.org/jira/browse/KAFKA-7347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7347. Resolution: Fixed Fix Version/s: 2.1.0 > Wrong error code returned for OffsetsForLea

[jira] [Commented] (KAFKA-7347) Wrong error code returned for OffsetsForLeaderEpoch from non-replica

[ https://issues.apache.org/jira/browse/KAFKA-7347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16594357#comment-16594357 ] ASF GitHub Bot commented on KAFKA-7347: --- hachikuji closed pull request #5576: KAFKA

[jira] [Updated] (KAFKA-6753) Speed up event processing on the controller

[ https://issues.apache.org/jira/browse/KAFKA-6753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Wang updated KAFKA-6753: -- Description: The existing controller code updates metrics after processing every event. This can slow

[jira] [Created] (KAFKA-7350) Improve or remove the PreferredReplicaImbalanceCount metric

Lucas Wang created KAFKA-7350: - Summary: Improve or remove the PreferredReplicaImbalanceCount metric Key: KAFKA-7350 URL: https://issues.apache.org/jira/browse/KAFKA-7350 Project: Kafka Issue Ty

[jira] [Updated] (KAFKA-6753) Speed up event processing on the controller

[ https://issues.apache.org/jira/browse/KAFKA-6753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Wang updated KAFKA-6753: -- Description: The existing controller code updates metrics after processing every event. This can slow

[jira] [Resolved] (KAFKA-6753) Speed up event processing on the controller

[ https://issues.apache.org/jira/browse/KAFKA-6753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Wang resolved KAFKA-6753. --- Resolution: Fixed > Speed up event processing on the controller > --

[jira] [Commented] (KAFKA-6753) Speed up event processing on the controller

[ https://issues.apache.org/jira/browse/KAFKA-6753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16594328#comment-16594328 ] Lucas Wang commented on KAFKA-6753: --- [~junrao] Thanks will do. > Speed up event proce

[jira] [Comment Edited] (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=16594320#comment-16594320 ] Yu Yang edited comment on KAFKA-7304 at 8/27/18 11:10 PM: -- After

[jira] [Comment Edited] (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=16594320#comment-16594320 ] Yu Yang edited comment on KAFKA-7304 at 8/27/18 11:08 PM: -- After

[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=16594320#comment-16594320 ] Yu Yang commented on KAFKA-7304: After more experiments, we currently think that the issu

[jira] [Updated] (KAFKA-7349) Long Disk Writes cause Zookeeper Disconnects

[ https://issues.apache.org/jira/browse/KAFKA-7349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Adam Kafka updated KAFKA-7349: -- Description: We run our Kafka cluster on a cloud service provider. As a consequence, we notice a large

[jira] [Updated] (KAFKA-7349) Long Disk Writes cause Zookeeper Disconnects

[ https://issues.apache.org/jira/browse/KAFKA-7349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Adam Kafka updated KAFKA-7349: -- Description: We run our Kafka cluster on a cloud service provider. As a consequence, we notice a large

[jira] [Created] (KAFKA-7349) Long Disk Writes cause Zookeeper Disconnects

Adam Kafka created KAFKA-7349: - Summary: Long Disk Writes cause Zookeeper Disconnects Key: KAFKA-7349 URL: https://issues.apache.org/jira/browse/KAFKA-7349 Project: Kafka Issue Type: Bug

[jira] [Updated] (KAFKA-7349) Long Disk Writes cause Zookeeper Disconnects

[ https://issues.apache.org/jira/browse/KAFKA-7349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Adam Kafka updated KAFKA-7349: -- Description: We run our Kafka cluster on a cloud service provider. As a consequence, we notice a large

[jira] [Updated] (KAFKA-7349) Long Disk Writes cause Zookeeper Disconnects

[ https://issues.apache.org/jira/browse/KAFKA-7349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Adam Kafka updated KAFKA-7349: -- Description: We run our Kafka cluster on a cloud service provider. As a consequence, we notice a large

[jira] [Updated] (KAFKA-7349) Long Disk Writes cause Zookeeper Disconnects

[ https://issues.apache.org/jira/browse/KAFKA-7349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Adam Kafka updated KAFKA-7349: -- Description: We run our Kafka cluster on a cloud service provider. As a consequence, we notice a large

[jira] [Resolved] (KAFKA-4065) Missing Property in ProducerConfig.java - KafkaProducer API 0.9.0.0

[ https://issues.apache.org/jira/browse/KAFKA-4065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-4065. -- Resolution: Auto Closed Closing inactive issue. It is highly unlikely to add this feature. > Missing

[jira] [Resolved] (KAFKA-3369) Add unit-tests to the Metadata Cache

[ https://issues.apache.org/jira/browse/KAFKA-3369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3369. -- Resolution: Fixed Closing as per above comment. > Add unit-tests to the Metadata Cache > -

[jira] [Commented] (KAFKA-6789) Add retry logic in AdminClient requests

[ https://issues.apache.org/jira/browse/KAFKA-6789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16594011#comment-16594011 ] ASF GitHub Bot commented on KAFKA-6789: --- omkreddy opened a new pull request #5578:

[jira] [Commented] (KAFKA-7345) Potentially unclosed FileChannel in StateDirectory#unlock

[ https://issues.apache.org/jira/browse/KAFKA-7345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16593885#comment-16593885 ] John Roesler commented on KAFKA-7345: - Thanks. I'll just respond on the PR. I wasn't

[jira] [Commented] (KAFKA-7345) Potentially unclosed FileChannel in StateDirectory#unlock

[ https://issues.apache.org/jira/browse/KAFKA-7345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16593820#comment-16593820 ] Ted Yu commented on KAFKA-7345: --- Replied on PR, copied below. >From the javadoc of FileLock

[jira] [Commented] (KAFKA-7345) Potentially unclosed FileChannel in StateDirectory#unlock

[ https://issues.apache.org/jira/browse/KAFKA-7345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16593818#comment-16593818 ] John Roesler commented on KAFKA-7345: - Hi Ted, I'm not familiar with the semantics o