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

[ https://issues.apache.org/jira/browse/KAFKA-6498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] james chien reassigned KAFKA-6498: -- Assignee: james chien > Add RocksDB statistics via Streams metrics >

[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=16347963#comment-16347963 ] james chien commented on KAFKA-6498: [~guozhang] I want to pick it up! As my comprehension is that we

[jira] [Commented] (KAFKA-5876) IQ should throw different exceptions for different errors

[ https://issues.apache.org/jira/browse/KAFKA-5876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16347957#comment-16347957 ] Vito Jeng commented on KAFKA-5876: -- [~Pegerto] Thanks! > IQ should throw different exceptions for

[jira] [Updated] (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:all-tabpanel ] Soby Chacko updated KAFKA-6502: --- Description: See this StackOverflow issue:

[jira] [Updated] (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:all-tabpanel ] Soby Chacko updated KAFKA-6502: --- Description: See this StackOverflow issue:

[jira] [Updated] (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:all-tabpanel ] Soby Chacko updated KAFKA-6502: --- Description: See this StackOverflow issue:

[jira] [Created] (KAFKA-6514) Add API version as a tag for the RequestsPerSec metric

Allen Wang created KAFKA-6514: - Summary: Add API version as a tag for the RequestsPerSec metric Key: KAFKA-6514 URL: https://issues.apache.org/jira/browse/KAFKA-6514 Project: Kafka Issue Type:

[jira] [Comment Edited] (KAFKA-5802) ScramServerCallbackHandler#handle should check username not being null before calling credentialCache.get()

[ https://issues.apache.org/jira/browse/KAFKA-5802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16302643#comment-16302643 ] Ted Yu edited comment on KAFKA-5802 at 2/1/18 1:24 AM: --- +1 was (Author:

[jira] [Commented] (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:comment-tabpanel=16347856#comment-16347856 ] ASF GitHub Bot commented on KAFKA-6494: --- rajinisivaram opened a new pull request #4503: KAFKA-6494;

[jira] [Commented] (KAFKA-3625) Move kafka-streams test fixtures into a published package

[ https://issues.apache.org/jira/browse/KAFKA-3625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16347850#comment-16347850 ] ASF GitHub Bot commented on KAFKA-3625: --- mjsax opened a new pull request #4502: KAFKA-3625:

[jira] [Comment Edited] (KAFKA-6024) Consider moving validation in KafkaConsumer ahead of call to acquireAndEnsureOpen()

[ https://issues.apache.org/jira/browse/KAFKA-6024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16222620#comment-16222620 ] Ted Yu edited comment on KAFKA-6024 at 2/1/18 1:16 AM: --- lgtm was (Author:

[jira] [Created] (KAFKA-6513) New Connect header support doesn't define `converter.type` property correctly

Randall Hauch created KAFKA-6513: Summary: New Connect header support doesn't define `converter.type` property correctly Key: KAFKA-6513 URL: https://issues.apache.org/jira/browse/KAFKA-6513 Project:

[jira] [Commented] (KAFKA-6492) LogSemgent.truncateTo() should always resize the index file

[ https://issues.apache.org/jira/browse/KAFKA-6492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16347816#comment-16347816 ] Jason Gustafson commented on KAFKA-6492: [~becket_qin] Beat you to it. Let me know if the PR I 

[jira] [Updated] (KAFKA-6512) Java Producer: Excessive memory usage with compression enabled

[ https://issues.apache.org/jira/browse/KAFKA-6512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-6512: --- Fix Version/s: 1.1.0 > Java Producer: Excessive memory usage with compression enabled >

[jira] [Created] (KAFKA-6512) Java Producer: Excessive memory usage with compression enabled

Kyle Tinker created KAFKA-6512: -- Summary: Java Producer: Excessive memory usage with compression enabled Key: KAFKA-6512 URL: https://issues.apache.org/jira/browse/KAFKA-6512 Project: Kafka

[jira] [Updated] (KAFKA-5863) Potential null dereference in DistributedHerder#reconfigureConnector()

[ https://issues.apache.org/jira/browse/KAFKA-5863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-5863: -- Description: Here is the call chain: {code} RestServer.httpRequest(reconfigUrl,

[jira] [Updated] (KAFKA-6138) Simplify StreamsBuilder#addGlobalStore

[ https://issues.apache.org/jira/browse/KAFKA-6138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6138: --- Fix Version/s: 1.1.0 > Simplify StreamsBuilder#addGlobalStore >

[jira] [Resolved] (KAFKA-6138) Simplify StreamsBuilder#addGlobalStore

[ https://issues.apache.org/jira/browse/KAFKA-6138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6138. Resolution: Fixed > Simplify StreamsBuilder#addGlobalStore >

[jira] [Commented] (KAFKA-6138) Simplify StreamsBuilder#addGlobalStore

[ https://issues.apache.org/jira/browse/KAFKA-6138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16347672#comment-16347672 ] ASF GitHub Bot commented on KAFKA-6138: --- mjsax closed pull request #4430: KAFKA-6138 Simplify

[jira] [Updated] (KAFKA-6492) LogSemgent.truncateTo() should always resize the index file

[ https://issues.apache.org/jira/browse/KAFKA-6492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-6492: Affects Version/s: 0.10.0.2 0.10.1.1 0.10.2.1

[jira] [Commented] (KAFKA-6492) LogSemgent.truncateTo() should always resize the index file

[ https://issues.apache.org/jira/browse/KAFKA-6492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16347670#comment-16347670 ] Jiangjie Qin commented on KAFKA-6492: - [~hachikuji] You are right. This issue will affect earlier

[jira] [Commented] (KAFKA-6492) LogSemgent.truncateTo() should always resize the index file

[ https://issues.apache.org/jira/browse/KAFKA-6492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16347612#comment-16347612 ] ASF GitHub Bot commented on KAFKA-6492: --- hachikuji opened a new pull request #4498: KAFKA-6492: Fix

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

[ https://issues.apache.org/jira/browse/KAFKA-6511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-6511: - Fix Version/s: 1.1.0 > Connect header parser incorrectly parses arrays >

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

[ https://issues.apache.org/jira/browse/KAFKA-6511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-6511: - Priority: Blocker (was: Critical) > Connect header parser incorrectly parses arrays >

[jira] [Commented] (KAFKA-5882) NullPointerException in StreamTask

[ https://issues.apache.org/jira/browse/KAFKA-5882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16347502#comment-16347502 ] Guozhang Wang commented on KAFKA-5882: -- Are the exception error message during crashes exactly the

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

Arjun Satish created KAFKA-6511: --- Summary: Connect header parser incorrectly parses arrays Key: KAFKA-6511 URL: https://issues.apache.org/jira/browse/KAFKA-6511 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-2334) Prevent HW from going back during leader failover

[ https://issues.apache.org/jira/browse/KAFKA-2334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16347426#comment-16347426 ] Colin P. McCabe commented on KAFKA-2334: [~guozhang]: The fix here is not KIP-101, but KIP-207.

[jira] [Commented] (KAFKA-6492) LogSemgent.truncateTo() should always resize the index file

[ https://issues.apache.org/jira/browse/KAFKA-6492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16347394#comment-16347394 ] Jason Gustafson commented on KAFKA-6492: [~becket_qin] Does this only affect 1.0.0? As far as I

[jira] [Resolved] (KAFKA-5142) KIP-145 - Expose Record Headers in Kafka Connect

[ https://issues.apache.org/jira/browse/KAFKA-5142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-5142. -- Resolution: Fixed Fix Version/s: 1.1.0 Issue resolved by pull request

[jira] [Commented] (KAFKA-2404) Delete config znode when config values are empty

[ https://issues.apache.org/jira/browse/KAFKA-2404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16347310#comment-16347310 ] Manikumar commented on KAFKA-2404: -- looks like this is tricky to implement. We can only remove a config

[jira] [Commented] (KAFKA-6503) Connect: Plugin scan is very slow

[ https://issues.apache.org/jira/browse/KAFKA-6503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16347234#comment-16347234 ] Randall Hauch commented on KAFKA-6503: -- Specifically, we're not using an executor when scanning:

[jira] [Comment Edited] (KAFKA-6503) Connect: Plugin scan is very slow

[ https://issues.apache.org/jira/browse/KAFKA-6503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16347021#comment-16347021 ] Randall Hauch edited comment on KAFKA-6503 at 1/31/18 5:15 PM: --- Very similar

[jira] [Commented] (KAFKA-6487) ChangeLoggingKeyValueBytesStore.all() returns null

[ https://issues.apache.org/jira/browse/KAFKA-6487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16347199#comment-16347199 ] Matthias J. Sax commented on KAFKA-6487: @bdevylde I added you to the list of contributors. You

[jira] [Assigned] (KAFKA-6487) ChangeLoggingKeyValueBytesStore.all() returns null

[ https://issues.apache.org/jira/browse/KAFKA-6487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-6487: -- Assignee: Bart De Vylder > ChangeLoggingKeyValueBytesStore.all() returns null >

[jira] [Updated] (KAFKA-6510) WARN: Failed to send SSL Close message java.io.IOException: Unexpected status returned by SSLEngine.wrap, expected CLOSED, received OK.

[ https://issues.apache.org/jira/browse/KAFKA-6510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Chu updated KAFKA-6510: Summary: WARN: Failed to send SSL Close message java.io.IOException: Unexpected status returned by

[jira] [Updated] (KAFKA-6510) WARN: Fail to send SSL Close message

[ https://issues.apache.org/jira/browse/KAFKA-6510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Chu updated KAFKA-6510: Description: I have a thread which once in a while is going to list the topics on the Message Hub. But

[jira] [Comment Edited] (KAFKA-6487) ChangeLoggingKeyValueBytesStore.all() returns null

[ https://issues.apache.org/jira/browse/KAFKA-6487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16347165#comment-16347165 ] Bill Bejeck edited comment on KAFKA-6487 at 1/31/18 4:55 PM: - No worries

[jira] [Assigned] (KAFKA-6487) ChangeLoggingKeyValueBytesStore.all() returns null

[ https://issues.apache.org/jira/browse/KAFKA-6487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-6487: -- Assignee: (was: Bill Bejeck) > ChangeLoggingKeyValueBytesStore.all() returns null >

[jira] [Commented] (KAFKA-6487) ChangeLoggingKeyValueBytesStore.all() returns null

[ https://issues.apache.org/jira/browse/KAFKA-6487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16347165#comment-16347165 ] Bill Bejeck commented on KAFKA-6487: No worries [~bdevylde] I'll re-assign the ticket to you >

[jira] [Created] (KAFKA-6510) WARN: Fail to send SSL Close message

John Chu created KAFKA-6510: --- Summary: WARN: Fail to send SSL Close message Key: KAFKA-6510 URL: https://issues.apache.org/jira/browse/KAFKA-6510 Project: Kafka Issue Type: Bug Affects

[jira] [Commented] (KAFKA-4930) Connect Rest API allows creating connectors with an empty name - KIP-212

[ https://issues.apache.org/jira/browse/KAFKA-4930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16347164#comment-16347164 ] ASF GitHub Bot commented on KAFKA-4930: --- ewencp closed pull request #2755: KAFKA-4930: Added

[jira] [Commented] (KAFKA-6503) Connect: Plugin scan is very slow

[ https://issues.apache.org/jira/browse/KAFKA-6503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16347021#comment-16347021 ] Randall Hauch commented on KAFKA-6503: -- Very similar to KAFKA-6208, but the latter actually proposes

[jira] [Updated] (KAFKA-6503) Connect: Plugin scan is very slow

[ https://issues.apache.org/jira/browse/KAFKA-6503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-6503: - Priority: Critical (was: Major) > Connect: Plugin scan is very slow >

[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=16347019#comment-16347019 ] james chien commented on KAFKA-6498: I have interest to this, but need to figure out how to do this.

[jira] [Commented] (KAFKA-6312) Add documentation about kafka-consumer-groups.sh's ability to set/change offsets

[ https://issues.apache.org/jira/browse/KAFKA-6312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16347005#comment-16347005 ] ASF GitHub Bot commented on KAFKA-6312: --- tankhiwale opened a new pull request #4496: KAFKA-6312:

[jira] [Created] (KAFKA-6509) Add additional tests for validating store restoration completes before Topology is intitalized

Bill Bejeck created KAFKA-6509: -- Summary: Add additional tests for validating store restoration completes before Topology is intitalized Key: KAFKA-6509 URL: https://issues.apache.org/jira/browse/KAFKA-6509

[jira] [Created] (KAFKA-6508) Look into optimizing StreamPartitionAssignor StandbyTask Assignment

Bill Bejeck created KAFKA-6508: -- Summary: Look into optimizing StreamPartitionAssignor StandbyTask Assignment Key: KAFKA-6508 URL: https://issues.apache.org/jira/browse/KAFKA-6508 Project: Kafka

[jira] [Commented] (KAFKA-6312) Add documentation about kafka-consumer-groups.sh's ability to set/change offsets

[ https://issues.apache.org/jira/browse/KAFKA-6312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346938#comment-16346938 ] ASF GitHub Bot commented on KAFKA-6312: --- tankhiwale closed pull request #123: KAFKA-6312: Update

[jira] [Commented] (KAFKA-6312) Add documentation about kafka-consumer-groups.sh's ability to set/change offsets

[ https://issues.apache.org/jira/browse/KAFKA-6312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346889#comment-16346889 ] ASF GitHub Bot commented on KAFKA-6312: --- tankhiwale opened a new pull request #123: KAFKA-6312:

[jira] [Created] (KAFKA-6507) NPE in KafkaStatusBackingStore

Itay Cohai created KAFKA-6507: - Summary: NPE in KafkaStatusBackingStore Key: KAFKA-6507 URL: https://issues.apache.org/jira/browse/KAFKA-6507 Project: Kafka Issue Type: Bug Components:

[jira] [Commented] (KAFKA-6487) ChangeLoggingKeyValueBytesStore.all() returns null

[ https://issues.apache.org/jira/browse/KAFKA-6487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346831#comment-16346831 ] Bart De Vylder commented on KAFKA-6487: --- [~bbejeck] i started working on this issue before I saw

[jira] [Commented] (KAFKA-6487) ChangeLoggingKeyValueBytesStore.all() returns null

[ https://issues.apache.org/jira/browse/KAFKA-6487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346824#comment-16346824 ] ASF GitHub Bot commented on KAFKA-6487: --- bartdevylder opened a new pull request #4495: KAFKA-6487:

[jira] [Commented] (KAFKA-6505) Add simple raw "offset-commit-failures", "offset-commits" and "offset-commit-successes" count metric

[ https://issues.apache.org/jira/browse/KAFKA-6505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346777#comment-16346777 ] Per Steffensen commented on KAFKA-6505: --- This ticket was labeled "needs-kip". I guess adding metrics

[jira] [Commented] (KAFKA-6378) NullPointerException on KStream-GlobalKTable leftJoin when KeyValueMapper returns null

[ https://issues.apache.org/jira/browse/KAFKA-6378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346626#comment-16346626 ] ASF GitHub Bot commented on KAFKA-6378: --- andybryant opened a new pull request #4494: KAFKA-6378

[jira] [Comment Edited] (KAFKA-5882) NullPointerException in StreamTask

[ https://issues.apache.org/jira/browse/KAFKA-5882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346563#comment-16346563 ] Seweryn Habdank-Wojewodzki edited comment on KAFKA-5882 at 1/31/18 10:40 AM:

[jira] [Commented] (KAFKA-5882) NullPointerException in StreamTask

[ https://issues.apache.org/jira/browse/KAFKA-5882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346563#comment-16346563 ] Seweryn Habdank-Wojewodzki commented on KAFKA-5882: --- Answers: # v. 1.0.0 it is exatly

[jira] [Updated] (KAFKA-6378) NullPointerException on KStream-GlobalKTable leftJoin when KeyValueMapper returns null

[ https://issues.apache.org/jira/browse/KAFKA-6378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-6378: -- Fix Version/s: (was: 1.1.0) 1.0.1 > NullPointerException on KStream-GlobalKTable

[jira] [Resolved] (KAFKA-6378) NullPointerException on KStream-GlobalKTable leftJoin when KeyValueMapper returns null

[ https://issues.apache.org/jira/browse/KAFKA-6378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy resolved KAFKA-6378. --- Resolution: Fixed Fix Version/s: 1.1.0 Issue resolved by pull request 4424