[jira] [Resolved] (KAFKA-2925) NullPointerException if FileStreamSinkTask is stopped before initialization finishes

2018-02-02 Thread Robert Yokota (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Yokota resolved KAFKA-2925. -- Resolution: Cannot Reproduce I wasn't able to reproduce the NPE and by reviewing the code it

[jira] [Updated] (KAFKA-6476) Document dynamic config update

2018-02-02 Thread Rajini Sivaram (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram updated KAFKA-6476: -- Description: Add documentation for dynamic broker config update. Include:   - Command line

[jira] [Assigned] (KAFKA-2925) NullPointerException if FileStreamSinkTask is stopped before initialization finishes

2018-02-02 Thread Robert Yokota (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Yokota reassigned KAFKA-2925: Assignee: Robert Yokota > NullPointerException if FileStreamSinkTask is stopped before

[jira] [Resolved] (KAFKA-6496) NAT and Kafka

2018-02-02 Thread Ronald van de Kuil (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ronald van de Kuil resolved KAFKA-6496. --- Resolution: Not A Bug > NAT and Kafka > - > > Key:

[jira] [Created] (KAFKA-6526) Update controller to handle changes to unclean.leader.election.enable

2018-02-02 Thread Rajini Sivaram (JIRA)
Rajini Sivaram created KAFKA-6526: - Summary: Update controller to handle changes to unclean.leader.election.enable Key: KAFKA-6526 URL: https://issues.apache.org/jira/browse/KAFKA-6526 Project: Kafka

[jira] [Created] (KAFKA-6527) Transient failure in DynamicBrokerReconfigurationTest.testDefaultTopicConfig

2018-02-02 Thread Jason Gustafson (JIRA)
Jason Gustafson created KAFKA-6527: -- Summary: Transient failure in DynamicBrokerReconfigurationTest.testDefaultTopicConfig Key: KAFKA-6527 URL: https://issues.apache.org/jira/browse/KAFKA-6527

[jira] [Created] (KAFKA-6525) Connect should allow pluggable encryption for records

2018-02-02 Thread Randall Hauch (JIRA)
Randall Hauch created KAFKA-6525: Summary: Connect should allow pluggable encryption for records Key: KAFKA-6525 URL: https://issues.apache.org/jira/browse/KAFKA-6525 Project: Kafka Issue

[jira] [Commented] (KAFKA-6511) Connect header parser incorrectly parses arrays

2018-02-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16350764#comment-16350764 ] ASF GitHub Bot commented on KAFKA-6511: --- rhauch opened a new pull request #4516: KAFKA-6511:

[jira] [Updated] (KAFKA-6496) NAT and Kafka

2018-02-02 Thread Ronald van de Kuil (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ronald van de Kuil updated KAFKA-6496: -- Affects Version/s: (was: 1.0.0) 0.11.0.0 > NAT and Kafka >

[jira] [Commented] (KAFKA-6496) NAT and Kafka

2018-02-02 Thread Ronald van de Kuil (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16350715#comment-16350715 ] Ronald van de Kuil commented on KAFKA-6496: --- Hey Manikumar! That was a very good tip! I have

[jira] [Created] (KAFKA-6528) Transient failure in DynamicBrokerReconfigurationTest.testThreadPoolResize

2018-02-02 Thread Jason Gustafson (JIRA)
Jason Gustafson created KAFKA-6528: -- Summary: Transient failure in DynamicBrokerReconfigurationTest.testThreadPoolResize Key: KAFKA-6528 URL: https://issues.apache.org/jira/browse/KAFKA-6528

[jira] [Commented] (KAFKA-6354) Update KStream JavaDoc with regard to KIP-182

2018-02-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16350836#comment-16350836 ] ASF GitHub Bot commented on KAFKA-6354: --- mjsax closed pull request #4456: KAFKA-6354 Update KStream

[jira] [Updated] (KAFKA-6354) Update KStream JavaDoc with regard to KIP-182

2018-02-02 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6354: --- Fix Version/s: 1.0.1 1.1.0 > Update KStream JavaDoc with regard to KIP-182

[jira] [Comment Edited] (KAFKA-5105) ReadOnlyKeyValueStore range scans are not ordered

2018-02-02 Thread Dmitry Minkovsky (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16350970#comment-16350970 ] Dmitry Minkovsky edited comment on KAFKA-5105 at 2/2/18 9:51 PM: -

[jira] [Commented] (KAFKA-6498) Add RocksDB statistics via Streams metrics

2018-02-02 Thread james chien (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16351245#comment-16351245 ] james chien commented on KAFKA-6498: [~guozhang] Thank for your summarization, I will start to do the

[jira] [Updated] (KAFKA-6058) KIP-222: Add "describe consumer groups" and "list consumer groups" to KafkaAdminClient

2018-02-02 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6058: --- Fix Version/s: 1.2.0 > KIP-222: Add "describe consumer groups" and "list consumer groups" to

[jira] [Commented] (KAFKA-5105) ReadOnlyKeyValueStore range scans are not ordered

2018-02-02 Thread Dmitry Minkovsky (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16350952#comment-16350952 ] Dmitry Minkovsky commented on KAFKA-5105: - Wondering if anyone knows whether 1.0.0 and up are

[jira] [Updated] (KAFKA-5105) ReadOnlyKeyValueStore range scans are not ordered

2018-02-02 Thread Dmitry Minkovsky (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dmitry Minkovsky updated KAFKA-5105: Description: Following up with this thread

[jira] [Commented] (KAFKA-5105) ReadOnlyKeyValueStore range scans are not ordered

2018-02-02 Thread Dmitry Minkovsky (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16350970#comment-16350970 ] Dmitry Minkovsky commented on KAFKA-5105: - Specifically, from the mailing list archive, Damien

[jira] [Comment Edited] (KAFKA-5105) ReadOnlyKeyValueStore range scans are not ordered

2018-02-02 Thread Dmitry Minkovsky (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16350970#comment-16350970 ] Dmitry Minkovsky edited comment on KAFKA-5105 at 2/2/18 9:52 PM: -

[jira] [Updated] (KAFKA-5946) Give connector method parameter better name

2018-02-02 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-5946: -- Labels: connector newbie (was: connector newbie usability) > Give connector method parameter better name >

[jira] [Created] (KAFKA-6530) Use actual first offset of messages when rolling log segment for magic v2

2018-02-02 Thread Jason Gustafson (JIRA)
Jason Gustafson created KAFKA-6530: -- Summary: Use actual first offset of messages when rolling log segment for magic v2 Key: KAFKA-6530 URL: https://issues.apache.org/jira/browse/KAFKA-6530 Project:

[jira] [Commented] (KAFKA-6529) Broker leaks memory and file descriptors after sudden client disconnects

2018-02-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16351042#comment-16351042 ] ASF GitHub Bot commented on KAFKA-6529: --- parafiend opened a new pull request #4517: KAFKA-6529: Stop

[jira] [Resolved] (KAFKA-6494) Extend ConfigCommand to update broker config using new AdminClient

2018-02-02 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6494. Resolution: Fixed Fix Version/s: (was: 1.2.0) 1.1.0 > Extend

[jira] [Commented] (KAFKA-6502) Kafka streams deserialization handler not committing offsets on error records

2018-02-02 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16351051#comment-16351051 ] Guozhang Wang commented on KAFKA-6502: -- Hello Soby, thanks for reporting this issue. Your reasoning

[jira] [Commented] (KAFKA-6498) Add RocksDB statistics via Streams metrics

2018-02-02 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16351063#comment-16351063 ] Guozhang Wang commented on KAFKA-6498: -- [~james.c] Thanks for your interest and sorry for late

[jira] [Updated] (KAFKA-6476) Document dynamic config update

2018-02-02 Thread Rajini Sivaram (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram updated KAFKA-6476: -- Description: Add documentation for dynamic broker config update. Include:   - Command line

[jira] [Created] (KAFKA-6529) Broker leaks memory and file descriptors after sudden client disconnects

2018-02-02 Thread Graham Campbell (JIRA)
Graham Campbell created KAFKA-6529: -- Summary: Broker leaks memory and file descriptors after sudden client disconnects Key: KAFKA-6529 URL: https://issues.apache.org/jira/browse/KAFKA-6529 Project:

[jira] [Updated] (KAFKA-6529) Broker leaks memory and file descriptors after sudden client disconnects

2018-02-02 Thread Graham Campbell (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Graham Campbell updated KAFKA-6529: --- Flags: Patch > Broker leaks memory and file descriptors after sudden client disconnects >

[jira] [Commented] (KAFKA-6454) Allow timestamp manipulation in Processor API

2018-02-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16351121#comment-16351121 ] ASF GitHub Bot commented on KAFKA-6454: --- mjsax opened a new pull request #4519: KAFKA-6454: Allow

[jira] [Commented] (KAFKA-6524) kafka mirror can't producer internal topic

2018-02-02 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16350186#comment-16350186 ] Manikumar commented on KAFKA-6524: -- exclude.internal.topics only for consumer clients. We can consume

[jira] [Commented] (KAFKA-6522) Retrying leaderEpoch request for partition xxx as the leader reported an error: UNKNOWN_SERVER_ERROR

2018-02-02 Thread Wang Shuxiao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16350123#comment-16350123 ] Wang Shuxiao commented on KAFKA-6522: - all brokers use the same binary file (kafka_2.11-1.0.0.tgz).

[jira] [Created] (KAFKA-6524) kafka mirror can't producer internal topic

2018-02-02 Thread Ahmed Madkour (JIRA)
Ahmed Madkour created KAFKA-6524: Summary: kafka mirror can't producer internal topic Key: KAFKA-6524 URL: https://issues.apache.org/jira/browse/KAFKA-6524 Project: Kafka Issue Type: Bug

[jira] [Comment Edited] (KAFKA-6498) Add RocksDB statistics via Streams metrics

2018-02-02 Thread james chien (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16347963#comment-16347963 ] james chien edited comment on KAFKA-6498 at 2/2/18 9:01 AM: [~guozhang] I want

[jira] [Created] (KAFKA-6523) kafka server not starting

2018-02-02 Thread Sanjeevani Mehra (JIRA)
Sanjeevani Mehra created KAFKA-6523: --- Summary: kafka server not starting Key: KAFKA-6523 URL: https://issues.apache.org/jira/browse/KAFKA-6523 Project: Kafka Issue Type: Bug

[jira] [Comment Edited] (KAFKA-6498) Add RocksDB statistics via Streams metrics

2018-02-02 Thread james chien (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16347963#comment-16347963 ] james chien edited comment on KAFKA-6498 at 2/2/18 8:47 AM: [~guozhang] I want

[jira] [Commented] (KAFKA-6522) Retrying leaderEpoch request for partition xxx as the leader reported an error: UNKNOWN_SERVER_ERROR

2018-02-02 Thread huxihx (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16350061#comment-16350061 ] huxihx commented on KAFKA-6522: --- Is it possible that one broker is actually 0.10.2.x? > Retrying