[jira] [Commented] (KAFKA-5678) When the broker graceful shutdown occurs, the producer side sends timeout.

[ https://issues.apache.org/jira/browse/KAFKA-5678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16111891#comment-16111891 ] Jiangjie Qin commented on KAFKA-5678: - [~cuiyang] There might be a few things to consider here, the

[jira] [Updated] (KAFKA-5560) LogManager should be able to create new logs based on free disk space

[ https://issues.apache.org/jira/browse/KAFKA-5560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx updated KAFKA-5560: -- Labels: needs-kip (was: kips) > LogManager should be able to create new logs based on free disk space >

[jira] [Commented] (KAFKA-5671) Add StreamsBuilder and deprecate KStreamBuilder

[ https://issues.apache.org/jira/browse/KAFKA-5671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16111821#comment-16111821 ] ASF GitHub Bot commented on KAFKA-5671: --- Github user asfgit closed the pull request at:

[jira] [Commented] (KAFKA-5006) KeyValueStore.put may throw exception unrelated to the current put attempt

[ https://issues.apache.org/jira/browse/KAFKA-5006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16111764#comment-16111764 ] ASF GitHub Bot commented on KAFKA-5006: --- Github user asfgit closed the pull request at:

[jira] [Commented] (KAFKA-5663) LogDirFailureTest system test fails

[ https://issues.apache.org/jira/browse/KAFKA-5663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16111885#comment-16111885 ] ASF GitHub Bot commented on KAFKA-5663: --- Github user asfgit closed the pull request at:

[jira] [Commented] (KAFKA-5684) KStreamPrintProcessor as customized KStreamPeekProcessor

[ https://issues.apache.org/jira/browse/KAFKA-5684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16111779#comment-16111779 ] Guozhang Wang commented on KAFKA-5684: -- 1. regarding using `peek` to implement `print`: yes we have

[jira] [Resolved] (KAFKA-5663) LogDirFailureTest system test fails

[ https://issues.apache.org/jira/browse/KAFKA-5663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-5663. Resolution: Fixed Fix Version/s: 1.0.0 > LogDirFailureTest system test fails >

[jira] [Commented] (KAFKA-2244) Document Kafka metrics configuration properties

[ https://issues.apache.org/jira/browse/KAFKA-2244?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16110426#comment-16110426 ] Pranav Maniar commented on KAFKA-2244: -- [~granthenke], [~sslavic] can I take it think ? > Document

[jira] [Commented] (KAFKA-5684) KStreamPrintProcessor as customized KStreamPeekProcessor

[ https://issues.apache.org/jira/browse/KAFKA-5684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16110481#comment-16110481 ] james chien commented on KAFKA-5684: [~guozhang] I agree with your point, we must to check K/V are

[jira] [Created] (KAFKA-5694) Add ChangeReplicaDirRequest and DescribeReplicaDirRequest (KIP-113)

Dong Lin created KAFKA-5694: --- Summary: Add ChangeReplicaDirRequest and DescribeReplicaDirRequest (KIP-113) Key: KAFKA-5694 URL: https://issues.apache.org/jira/browse/KAFKA-5694 Project: Kafka

[jira] [Commented] (KAFKA-5684) KStreamPrintProcessor as customized KStreamPeekProcessor

[ https://issues.apache.org/jira/browse/KAFKA-5684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16110636#comment-16110636 ] Paolo Patierno commented on KAFKA-5684: --- So it seems to me that the serdes parameters aren't related

[jira] [Commented] (KAFKA-5358) Consumer perf tool should count rebalance time separately

[ https://issues.apache.org/jira/browse/KAFKA-5358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16110630#comment-16110630 ] huxihx commented on KAFKA-5358: --- [~hachikuji] How is the status for this KIP? Is it approved? > Consumer

[jira] [Assigned] (KAFKA-5152) Kafka Streams keeps restoring state after shutdown is initiated during startup

[ https://issues.apache.org/jira/browse/KAFKA-5152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy reassigned KAFKA-5152: - Assignee: Damian Guy (was: Matthias J. Sax) > Kafka Streams keeps restoring state after

[jira] [Commented] (KAFKA-5459) Support kafka-console-producer.sh messages as whole file

[ https://issues.apache.org/jira/browse/KAFKA-5459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16110657#comment-16110657 ] huxihx commented on KAFKA-5459: --- [~tombentley] How do we specify the key if the entire file content is the

[jira] [Commented] (KAFKA-5641) Metadata request should always be allowed to send no regardless of value for max.in.flight.requests.per.connection

[ https://issues.apache.org/jira/browse/KAFKA-5641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16110568#comment-16110568 ] huxihx commented on KAFKA-5641: --- Closed this jira since this improvement does not have much positive impact

[jira] [Resolved] (KAFKA-5641) Metadata request should always be allowed to send no regardless of value for max.in.flight.requests.per.connection

[ https://issues.apache.org/jira/browse/KAFKA-5641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx resolved KAFKA-5641. --- Resolution: Not A Problem > Metadata request should always be allowed to send no regardless of value for >

[jira] [Commented] (KAFKA-2360) The kafka-consumer-perf-test.sh script help information print useless parameters.

[ https://issues.apache.org/jira/browse/KAFKA-2360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16112108#comment-16112108 ] ASF GitHub Bot commented on KAFKA-2360: --- GitHub user huxihx opened a pull request:

[jira] [Assigned] (KAFKA-2360) The kafka-consumer-perf-test.sh script help information print useless parameters.

[ https://issues.apache.org/jira/browse/KAFKA-2360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx reassigned KAFKA-2360: - Assignee: huxihx (was: jin xing) > The kafka-consumer-perf-test.sh script help information print

[jira] [Comment Edited] (KAFKA-5678) When the broker graceful shutdown occurs, the producer side sends timeout.

[ https://issues.apache.org/jira/browse/KAFKA-5678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16112124#comment-16112124 ] cuiyang edited comment on KAFKA-5678 at 8/3/17 3:35 AM: [~becket_qin] Hi Jiang,

[jira] [Comment Edited] (KAFKA-5678) When the broker graceful shutdown occurs, the producer side sends timeout.

[ https://issues.apache.org/jira/browse/KAFKA-5678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16112124#comment-16112124 ] cuiyang edited comment on KAFKA-5678 at 8/3/17 3:40 AM: [~becket_qin] Hi Jiang,

[jira] [Comment Edited] (KAFKA-5678) When the broker graceful shutdown occurs, the producer side sends timeout.

[ https://issues.apache.org/jira/browse/KAFKA-5678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16112124#comment-16112124 ] cuiyang edited comment on KAFKA-5678 at 8/3/17 3:41 AM: [~becket_qin] Hi Jiang,

[jira] [Comment Edited] (KAFKA-5678) When the broker graceful shutdown occurs, the producer side sends timeout.

[ https://issues.apache.org/jira/browse/KAFKA-5678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16112124#comment-16112124 ] cuiyang edited comment on KAFKA-5678 at 8/3/17 3:39 AM: [~becket_qin] Hi Jiang,

[jira] [Comment Edited] (KAFKA-5678) When the broker graceful shutdown occurs, the producer side sends timeout.

[ https://issues.apache.org/jira/browse/KAFKA-5678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16112124#comment-16112124 ] cuiyang edited comment on KAFKA-5678 at 8/3/17 3:40 AM: [~becket_qin] Hi Jiang,

[jira] [Commented] (KAFKA-5621) The producer should retry expired batches when retries are enabled

[ https://issues.apache.org/jira/browse/KAFKA-5621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16112129#comment-16112129 ] Apurva Mehta commented on KAFKA-5621: - [~sutambe] : one clarification. my proposal for

[jira] [Comment Edited] (KAFKA-5678) When the broker graceful shutdown occurs, the producer side sends timeout.

[ https://issues.apache.org/jira/browse/KAFKA-5678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16112124#comment-16112124 ] cuiyang edited comment on KAFKA-5678 at 8/3/17 3:43 AM: [~becket_qin] Hi Jiang,

[jira] [Comment Edited] (KAFKA-5678) When the broker graceful shutdown occurs, the producer side sends timeout.

[ https://issues.apache.org/jira/browse/KAFKA-5678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16112124#comment-16112124 ] cuiyang edited comment on KAFKA-5678 at 8/3/17 3:44 AM: [~becket_qin] Hi Jiang,

[jira] [Commented] (KAFKA-5678) When the broker graceful shutdown occurs, the producer side sends timeout.

[ https://issues.apache.org/jira/browse/KAFKA-5678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16112124#comment-16112124 ] cuiyang commented on KAFKA-5678: [~becket_qin] Hi Jiang, thank you for your patience, I have two

[jira] [Comment Edited] (KAFKA-5678) When the broker graceful shutdown occurs, the producer side sends timeout.

[ https://issues.apache.org/jira/browse/KAFKA-5678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16112124#comment-16112124 ] cuiyang edited comment on KAFKA-5678 at 8/3/17 3:36 AM: [~becket_qin] Hi Jiang,

[jira] [Comment Edited] (KAFKA-5678) When the broker graceful shutdown occurs, the producer side sends timeout.

[ https://issues.apache.org/jira/browse/KAFKA-5678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16112124#comment-16112124 ] cuiyang edited comment on KAFKA-5678 at 8/3/17 3:36 AM: [~becket_qin] Hi Jiang,

[jira] [Created] (KAFKA-5695) Test DeleteRecordsRequest in AuthorizerIntegrationTest

Dong Lin created KAFKA-5695: --- Summary: Test DeleteRecordsRequest in AuthorizerIntegrationTest Key: KAFKA-5695 URL: https://issues.apache.org/jira/browse/KAFKA-5695 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-5695) Test DeleteRecordsRequest in AuthorizerIntegrationTest

[ https://issues.apache.org/jira/browse/KAFKA-5695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16112190#comment-16112190 ] ASF GitHub Bot commented on KAFKA-5695: --- GitHub user lindong28 opened a pull request:

[jira] [Commented] (KAFKA-5684) KStreamPrintProcessor as customized KStreamPeekProcessor

[ https://issues.apache.org/jira/browse/KAFKA-5684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16110849#comment-16110849 ] Paolo Patierno commented on KAFKA-5684: --- Maybe I made a mistake here because the default serdes are

[jira] [Commented] (KAFKA-5096) Only log invalid user configs and overwrite with correct one

[ https://issues.apache.org/jira/browse/KAFKA-5096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16110866#comment-16110866 ] ASF GitHub Bot commented on KAFKA-5096: --- Github user asfgit closed the pull request at:

[jira] [Comment Edited] (KAFKA-5684) KStreamPrintProcessor as customized KStreamPeekProcessor

[ https://issues.apache.org/jira/browse/KAFKA-5684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16110849#comment-16110849 ] Paolo Patierno edited comment on KAFKA-5684 at 8/2/17 2:17 PM: --- Maybe I made

[jira] [Commented] (KAFKA-5692) Refactor PreferredReplicaLeaderElectionCommand to use AdminClient

[ https://issues.apache.org/jira/browse/KAFKA-5692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16111088#comment-16111088 ] Tom Bentley commented on KAFKA-5692: This is now covered by

[jira] [Updated] (KAFKA-5692) Refactor PreferredReplicaLeaderElectionCommand to use AdminClient

[ https://issues.apache.org/jira/browse/KAFKA-5692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tom Bentley updated KAFKA-5692: --- Description: The PreferredReplicaLeaderElectionCommand currently uses a direct connection to

[jira] [Commented] (KAFKA-5674) max.connections.per.ip minimum value to be zero to allow IP address blocking

[ https://issues.apache.org/jira/browse/KAFKA-5674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16110957#comment-16110957 ] ASF GitHub Bot commented on KAFKA-5674: --- GitHub user viktorsomogyi opened a pull request:

[jira] [Commented] (KAFKA-2526) Console Producer / Consumer's serde config is not working

[ https://issues.apache.org/jira/browse/KAFKA-2526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16111024#comment-16111024 ] Aish Raj Dahal commented on KAFKA-2526: --- [~ewencp] Apologies for the naivety, but I was thinking

[jira] [Created] (KAFKA-5693) TopicCreationPolicy and AlterConfigsPolicy overlap

Tom Bentley created KAFKA-5693: -- Summary: TopicCreationPolicy and AlterConfigsPolicy overlap Key: KAFKA-5693 URL: https://issues.apache.org/jira/browse/KAFKA-5693 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-5693) TopicCreationPolicy and AlterConfigsPolicy overlap

[ https://issues.apache.org/jira/browse/KAFKA-5693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16111313#comment-16111313 ] Tom Bentley commented on KAFKA-5693: One (obvious) part solution to this is that the

[jira] [Commented] (KAFKA-3657) NewProducer NullPointerException on ProduceRequest

[ https://issues.apache.org/jira/browse/KAFKA-3657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16111352#comment-16111352 ] Shubham Rander commented on KAFKA-3657: --- [~ijuma] We have seen the same issue intermittently with

[jira] [Comment Edited] (KAFKA-5621) The producer should retry expired batches when retries are enabled

[ https://issues.apache.org/jira/browse/KAFKA-5621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16111237#comment-16111237 ] Sumant Tambe edited comment on KAFKA-5621 at 8/2/17 4:38 PM: - Wait, what?

[jira] [Assigned] (KAFKA-5474) Streams StandbyTask should no checkpoint on commit if EOS is enabled

[ https://issues.apache.org/jira/browse/KAFKA-5474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-5474: Assignee: Guozhang Wang (was: Matthias J. Sax) > Streams StandbyTask should no checkpoint

[jira] [Assigned] (KAFKA-5474) Streams StandbyTask should no checkpoint on commit if EOS is enabled

[ https://issues.apache.org/jira/browse/KAFKA-5474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-5474: Assignee: Matthias J. Sax (was: Guozhang Wang) > Streams StandbyTask should no checkpoint