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

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-6498) Add RocksDB statistics via Streams metrics

[ https://issues.apache.org/jira/browse/KAFKA-6498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16351245#comment-16351245 ] james chien commented on KAFKA-6498: [~guozhang] Thank for your summarization, I will

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

[ 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] [Updated] (KAFKA-6476) Document dynamic config update

[ 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 opt

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

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

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

[ 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 C

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

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

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

[ https://issues.apache.org/jira/browse/KAFKA-6502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16351051#comment-16351051 ] Guozhang Wang commented on KAFKA-6502: -- Hello Soby, thanks for reporting this issue.

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

[ 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-6529) Broker leaks memory and file descriptors after sudden client disconnects

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

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

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: K

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

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

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

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

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

[ https://issues.apache.org/jira/browse/KAFKA-5105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16350970#comment-16350970 ] Dmitry Minkovsky commented on KAFKA-5105: - Specifically, from the mailing list arc

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

[ https://issues.apache.org/jira/browse/KAFKA-5105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16350952#comment-16350952 ] Dmitry Minkovsky commented on KAFKA-5105: - Wondering if anyone knows whether 1.0.0

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

[ 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 https://www.mail-archive.com/users@kafka.apache.

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

[ 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] [Updated] (KAFKA-6354) Update KStream JavaDoc with regard to KIP-182

[ 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] [Commented] (KAFKA-6354) Update KStream JavaDoc with regard to KIP-182

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

[jira] [Assigned] (KAFKA-6519) Change log level from ERROR to WARN for not leader for this partition exception

[ https://issues.apache.org/jira/browse/KAFKA-6519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reassigned KAFKA-6519: -- Assignee: Jason Gustafson > Change log level from ERROR to WARN for not leader for this

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

Jason Gustafson created KAFKA-6528: -- Summary: Transient failure in DynamicBrokerReconfigurationTest.testThreadPoolResize Key: KAFKA-6528 URL: https://issues.apache.org/jira/browse/KAFKA-6528 Project:

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

Jason Gustafson created KAFKA-6527: -- Summary: Transient failure in DynamicBrokerReconfigurationTest.testDefaultTopicConfig Key: KAFKA-6527 URL: https://issues.apache.org/jira/browse/KAFKA-6527 Projec

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

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

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

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] [Resolved] (KAFKA-6496) NAT and Kafka

[ 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: KAFKA-6

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

[ 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

[ https://issues.apache.org/jira/browse/KAFKA-6496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16350715#comment-16350715 ] Ronald van de Kuil commented on KAFKA-6496: --- Hey Manikumar! That was a very goo

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

[ 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 doe

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

[ 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 init

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

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 Typ

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

[ 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 opt

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

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] [Commented] (KAFKA-6522) Retrying leaderEpoch request for partition xxx as the leader reported an error: UNKNOWN_SERVER_ERROR

[ https://issues.apache.org/jira/browse/KAFKA-6522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16350123#comment-16350123 ] Wang Shuxiao commented on KAFKA-6522: - all brokers use the same binary file (kafka_2.1

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

[ https://issues.apache.org/jira/browse/KAFKA-6524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16350186#comment-16350186 ] Manikumar commented on KAFKA-6524: -- exclude.internal.topics only for consumer clients. We

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

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

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

[ https://issues.apache.org/jira/browse/KAFKA-6498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16347963#comment-16347963 ] james chien edited comment on KAFKA-6498 at 2/2/18 9:01 AM: [~

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

[ https://issues.apache.org/jira/browse/KAFKA-6498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16347963#comment-16347963 ] james chien edited comment on KAFKA-6498 at 2/2/18 8:47 AM: [~

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

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 Rep