[jira] [Commented] (KAFKA-6145) Warm up new KS instances before migrating tasks - potentially a two phase rebalance

2020-03-13 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17059168#comment-17059168 ] ASF GitHub Bot commented on KAFKA-6145: --- vvcephei commented on pull request #8246: KAFKA-6145: Pt

[jira] [Assigned] (KAFKA-9568) Kstreams APPLICATION_SERVER_CONFIG is not updated with static membership

2020-03-13 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-9568: -- Assignee: Sophie Blee-Goldman > Kstreams APPLICATION_SERVER_CONFIG is not updated with static

[jira] [Commented] (KAFKA-9568) Kstreams APPLICATION_SERVER_CONFIG is not updated with static membership

2020-03-13 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17059137#comment-17059137 ] ASF GitHub Bot commented on KAFKA-9568: --- ableegoldman commented on pull request #8299: KAFKA-9568:

[jira] [Commented] (KAFKA-9678) Introduce bounded exponential backoff in clients

2020-03-13 Thread Sanjana Kaundinya (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17059128#comment-17059128 ] Sanjana Kaundinya commented on KAFKA-9678: -- I have a KIP out for this here:

[jira] [Commented] (KAFKA-9720) Update gradle to 6.0+

2020-03-13 Thread Ismael Juma (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17059123#comment-17059123 ] Ismael Juma commented on KAFKA-9720: There's a blocking regression, see 

[jira] [Updated] (KAFKA-9381) kafka-streams-scala: Javadocs + Scaladocs not published on maven central

2020-03-13 Thread David Arthur (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Arthur updated KAFKA-9381: Fix Version/s: 2.6.0 > kafka-streams-scala: Javadocs + Scaladocs not published on maven central >

[jira] [Updated] (KAFKA-9381) kafka-streams-scala: Javadocs + Scaladocs not published on maven central

2020-03-13 Thread David Arthur (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Arthur updated KAFKA-9381: Labels: (was: rc-ignored) > kafka-streams-scala: Javadocs + Scaladocs not published on maven

[jira] [Commented] (KAFKA-9381) kafka-streams-scala: Javadocs + Scaladocs not published on maven central

2020-03-13 Thread David Arthur (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17059121#comment-17059121 ] David Arthur commented on KAFKA-9381: - kafka-streams-scala has published an empty scaladoc jar since

[jira] [Created] (KAFKA-9720) Update gradle to 6.0+

2020-03-13 Thread David Arthur (Jira)
David Arthur created KAFKA-9720: --- Summary: Update gradle to 6.0+ Key: KAFKA-9720 URL: https://issues.apache.org/jira/browse/KAFKA-9720 Project: Kafka Issue Type: Improvement

[jira] [Commented] (KAFKA-9568) Kstreams APPLICATION_SERVER_CONFIG is not updated with static membership

2020-03-13 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17059093#comment-17059093 ] Sophie Blee-Goldman commented on KAFKA-9568: In KIP-568/KAFKA-9525 we added a new

[jira] [Commented] (KAFKA-9533) JavaDocs of KStream#ValueTransform incorrect

2020-03-13 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17059088#comment-17059088 ] ASF GitHub Bot commented on KAFKA-9533: --- mjsax commented on pull request #8298: KAFKA-9533: Fix

[jira] [Commented] (KAFKA-9533) JavaDocs of KStream#ValueTransform incorrect

2020-03-13 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17059086#comment-17059086 ] Matthias J. Sax commented on KAFKA-9533: The incorrect JavaDocs were introduced via 

[jira] [Updated] (KAFKA-9533) JavaDocs of KStream#ValueTransform incorrect

2020-03-13 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9533: --- Description: According to the documentation for `KStream#transformValues`, nulls returned

[jira] [Updated] (KAFKA-9533) JavaDocs of KStream#ValueTransform incorrect

2020-03-13 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9533: --- Summary: JavaDocs of KStream#ValueTransform incorrect (was: ValueTransform forwards `null`

[jira] [Updated] (KAFKA-9533) JavaDocs of KStream#ValueTransform incorrect

2020-03-13 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9533: --- Affects Version/s: (was: 2.3.1) (was: 2.4.0)

[jira] [Assigned] (KAFKA-9533) JavaDocs of KStream#ValueTransform incorrect

2020-03-13 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-9533: -- Assignee: Matthias J. Sax (was: Michael Viamari) > JavaDocs of

[jira] [Commented] (KAFKA-9568) Kstreams APPLICATION_SERVER_CONFIG is not updated with static membership

2020-03-13 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17059081#comment-17059081 ] John Roesler commented on KAFKA-9568: - I think the idea is that the member is still logically the

[jira] [Assigned] (KAFKA-9584) Removing headers causes ConcurrentModificationException

2020-03-13 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-9584: -- Assignee: Micah Ramos > Removing headers causes ConcurrentModificationException >

[jira] [Updated] (KAFKA-9371) Disk space is not released after Kafka clears data due to retention settings

2020-03-13 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9371: --- Component/s: (was: streams) > Disk space is not released after Kafka clears data due to

[jira] [Commented] (KAFKA-9568) Kstreams APPLICATION_SERVER_CONFIG is not updated with static membership

2020-03-13 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17059069#comment-17059069 ] Boyang Chen commented on KAFKA-9568: The current design of static membership will not kick-off

[jira] [Resolved] (KAFKA-9715) TransactionStateManager: Eliminate unused reference to interBrokerProtocolVersion

2020-03-13 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9715. Resolution: Fixed > TransactionStateManager: Eliminate unused reference to >

[jira] [Commented] (KAFKA-9715) TransactionStateManager: Eliminate unused reference to interBrokerProtocolVersion

2020-03-13 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17059051#comment-17059051 ] ASF GitHub Bot commented on KAFKA-9715: --- hachikuji commented on pull request #8293: KAFKA-9715:

[jira] [Commented] (KAFKA-9381) kafka-streams-scala: Javadocs + Scaladocs not published on maven central

2020-03-13 Thread David Arthur (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17059017#comment-17059017 ] David Arthur commented on KAFKA-9381: - Also, looks like this affects all scaladoc jars, not just

[jira] [Commented] (KAFKA-9381) kafka-streams-scala: Javadocs + Scaladocs not published on maven central

2020-03-13 Thread David Arthur (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17058991#comment-17058991 ] David Arthur commented on KAFKA-9381: - Got the streams-scala scaladoc jar to build, but now getting

[jira] [Commented] (KAFKA-9636) Simple join of two KTables fails

2020-03-13 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17058990#comment-17058990 ] John Roesler commented on KAFKA-9636: - Aha! You gave me a clue. The serde in your code doesn't do

[jira] [Commented] (KAFKA-9718) Don't log passwords for AlterConfigs requests in request logs

2020-03-13 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17058977#comment-17058977 ] ASF GitHub Bot commented on KAFKA-9718: --- rajinisivaram commented on pull request #8294: KAFKA-9718;

[jira] [Resolved] (KAFKA-9718) Don't log passwords for AlterConfigs requests in request logs

2020-03-13 Thread Rajini Sivaram (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-9718. --- Reviewer: Manikumar Resolution: Fixed > Don't log passwords for AlterConfigs requests

[jira] [Commented] (KAFKA-9717) KafkaStreams#metrics() method randomly throws NullPointerException

2020-03-13 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17058972#comment-17058972 ] Bruno Cadonna commented on KAFKA-9717: -- FYI: All metrics are also exposed to JMX. >

[jira] [Commented] (KAFKA-8768) Replace DeleteRecords request/response with automated protocol

2020-03-13 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17058953#comment-17058953 ] ASF GitHub Bot commented on KAFKA-8768: --- mimaison commented on pull request #7957: KAFKA-8768:

[jira] [Commented] (KAFKA-9717) KafkaStreams#metrics() method randomly throws NullPointerException

2020-03-13 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17058929#comment-17058929 ] Bruno Cadonna commented on KAFKA-9717: -- [~Bataitis] Thank you for the bug report! Judging from the

[jira] [Created] (KAFKA-9719) Add Integration Test For ensuring the EOS-beta app would crash with broker downgrade

2020-03-13 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-9719: -- Summary: Add Integration Test For ensuring the EOS-beta app would crash with broker downgrade Key: KAFKA-9719 URL: https://issues.apache.org/jira/browse/KAFKA-9719

[jira] [Assigned] (KAFKA-9657) Add configurable throw on unsupported protocol

2020-03-13 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-9657: -- Assignee: Boyang Chen > Add configurable throw on unsupported protocol >

[jira] [Resolved] (KAFKA-9657) Add configurable throw on unsupported protocol

2020-03-13 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-9657. Resolution: Fixed > Add configurable throw on unsupported protocol >

[jira] [Assigned] (KAFKA-9689) Automatic broker version detection to initialize stream client

2020-03-13 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-9689: -- Assignee: (was: Boyang Chen) > Automatic broker version detection to initialize stream

[jira] [Commented] (KAFKA-9636) Simple join of two KTables fails

2020-03-13 Thread Paul Snively (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17058870#comment-17058870 ] Paul Snively commented on KAFKA-9636: - John, Thanks for digging into this so thoroughly. While I

[jira] [Assigned] (KAFKA-9685) Solve Set concatenation perf issue in AclAuthorizer

2020-03-13 Thread Manikumar (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar reassigned KAFKA-9685: Assignee: Jiao Zhang > Solve Set concatenation perf issue in AclAuthorizer >

[jira] [Resolved] (KAFKA-9685) Solve Set concatenation perf issue in AclAuthorizer

2020-03-13 Thread Manikumar (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-9685. -- Fix Version/s: 2.6.0 Resolution: Fixed Issue resolved by pull request 8261

[jira] [Commented] (KAFKA-9685) Solve Set concatenation perf issue in AclAuthorizer

2020-03-13 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17058836#comment-17058836 ] ASF GitHub Bot commented on KAFKA-9685: --- omkreddy commented on pull request #8261: KAFKA-9685:

[jira] [Commented] (KAFKA-9636) Simple join of two KTables fails

2020-03-13 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17058813#comment-17058813 ] John Roesler commented on KAFKA-9636: - Hi [~psnively] ,   I'm sorry to hear that; I certainly wish

[jira] [Commented] (KAFKA-9604) Kafka cluster crash

2020-03-13 Thread Maksim Larionov (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17058773#comment-17058773 ] Maksim Larionov commented on KAFKA-9604: Sorry to bother you . Can we expect any answer? > Kafka

[jira] [Assigned] (KAFKA-3903) Convert tests to use static helper methods for Consumer/Producer/StreamsConfigs setup

2020-03-13 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-3903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-3903: -- Assignee: Evelyn Bayes (was: Bill Bejeck) > Convert tests to use static helper methods for

[jira] [Resolved] (KAFKA-7908) retention.ms and message.timestamp.difference.max.ms are tied

2020-03-13 Thread Andras Katona (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andras Katona resolved KAFKA-7908. -- Resolution: Fixed > retention.ms and message.timestamp.difference.max.ms are tied >

[jira] [Updated] (KAFKA-7908) retention.ms and message.timestamp.difference.max.ms are tied

2020-03-13 Thread Andras Katona (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andras Katona updated KAFKA-7908: - Fix Version/s: 2.3.0 > retention.ms and message.timestamp.difference.max.ms are tied >

[jira] [Commented] (KAFKA-9627) Replace ListOffset request/response with automated protocol

2020-03-13 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17058663#comment-17058663 ] ASF GitHub Bot commented on KAFKA-9627: --- mimaison commented on pull request #8295: KAFKA-9627:

[jira] [Commented] (KAFKA-9718) Don't log passwords for AlterConfigs requests in request logs

2020-03-13 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17058649#comment-17058649 ] ASF GitHub Bot commented on KAFKA-9718: --- rajinisivaram commented on pull request #8294: KAFKA-9718;

[jira] [Comment Edited] (KAFKA-9603) Number of open files keeps increasing in Streams application

2020-03-13 Thread Bruno Iljazovic (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17058646#comment-17058646 ] Bruno Iljazovic edited comment on KAFKA-9603 at 3/13/20, 11:28 AM: ---

[jira] [Commented] (KAFKA-9603) Number of open files keeps increasing in Streams application

2020-03-13 Thread Bruno Iljazovic (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17058646#comment-17058646 ] Bruno Iljazovic commented on KAFKA-9603: [~ableegoldman] Unfortunately no new info. Problems are

[jira] [Created] (KAFKA-9718) Don't log passwords for AlterConfigs requests in request logs

2020-03-13 Thread Rajini Sivaram (Jira)
Rajini Sivaram created KAFKA-9718: - Summary: Don't log passwords for AlterConfigs requests in request logs Key: KAFKA-9718 URL: https://issues.apache.org/jira/browse/KAFKA-9718 Project: Kafka

[jira] [Created] (KAFKA-9717) KafkaStreams#metrics() method randomly throws NullPointerException

2020-03-13 Thread Zygimantas (Jira)
Zygimantas created KAFKA-9717: - Summary: KafkaStreams#metrics() method randomly throws NullPointerException Key: KAFKA-9717 URL: https://issues.apache.org/jira/browse/KAFKA-9717 Project: Kafka

[jira] [Updated] (KAFKA-9716) Values of compression-rate and compression-rate-avg are misleading

2020-03-13 Thread Christian Kosmowski (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Christian Kosmowski updated KAFKA-9716: --- Description: The values of the following metrics: compression-rate and

[jira] [Updated] (KAFKA-9716) Values of compression-rate and compression-rate-avg are misleading

2020-03-13 Thread Christian Kosmowski (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Christian Kosmowski updated KAFKA-9716: --- Priority: Minor (was: Major) > Values of compression-rate and compression-rate-avg

[jira] [Created] (KAFKA-9716) Values of compression-rate and compression-rate-avg are misleading

2020-03-13 Thread Christian Kosmowski (Jira)
Christian Kosmowski created KAFKA-9716: -- Summary: Values of compression-rate and compression-rate-avg are misleading Key: KAFKA-9716 URL: https://issues.apache.org/jira/browse/KAFKA-9716