[jira] [Created] (KAFKA-9149) Avoid temp byte array creation when use ByteBufferSerializer

2019-11-05 Thread chenxu (Jira)
chenxu created KAFKA-9149: - Summary: Avoid temp byte array creation when use ByteBufferSerializer Key: KAFKA-9149 URL: https://issues.apache.org/jira/browse/KAFKA-9149 Project: Kafka Issue Type:

[jira] [Comment Edited] (KAFKA-9148) Consider forking RocksDB for Streams

2019-11-05 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16968119#comment-16968119 ] Sophie Blee-Goldman edited comment on KAFKA-9148 at 11/6/19 6:37 AM: -

[jira] [Commented] (KAFKA-9148) Consider forking RocksDB for Streams

2019-11-05 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16968119#comment-16968119 ] Sophie Blee-Goldman commented on KAFKA-9148: > seems like this is the kind of problem that

[jira] [Updated] (KAFKA-9148) Consider forking RocksDB for Streams

2019-11-05 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9148: --- Description: We recently upgraded our RocksDB dependency to 5.18 for its

[jira] [Commented] (KAFKA-9148) Consider forking RocksDB for Streams

2019-11-05 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16968097#comment-16968097 ] John Roesler commented on KAFKA-9148: - Thanks for bringing this up, Sophie. It does seem like this

[jira] [Updated] (KAFKA-9148) Consider forking RocksDB for Streams

2019-11-05 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9148: --- Description: We recently upgraded our RocksDB dependency to 5.18 for its

[jira] [Updated] (KAFKA-9148) Consider forking RocksDB for Streams

2019-11-05 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9148: --- Description: We recently upgraded our RocksDB dependency to 5.18 for its

[jira] [Updated] (KAFKA-9148) Consider forking RocksDB for Streams

2019-11-05 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9148: --- Description: We recently upgraded our RocksDB dependency to 5.18 for its

[jira] [Updated] (KAFKA-9148) Consider forking RocksDB for Streams

2019-11-05 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9148: --- Description: We recently upgraded our RocksDB dependency to 5.18 for its

[jira] [Updated] (KAFKA-9148) Consider forking RocksDB for Streams

2019-11-05 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9148: --- Description: We recently upgraded our RocksDB dependency to 5.18 for its

[jira] [Updated] (KAFKA-9148) Consider forking RocksDB for Streams

2019-11-05 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9148: --- Description: We recently upgraded our RocksDB dependency to 5.18 for its

[jira] [Updated] (KAFKA-9148) Consider forking RocksDB for Streams

2019-11-05 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9148: --- Description: We recently upgraded our RocksDB dependency to 5.18 for its

[jira] [Commented] (KAFKA-9137) Maintenance of FetchSession cache causing FETCH_SESSION_ID_NOT_FOUND in live sessions

2019-11-05 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16968003#comment-16968003 ] ASF GitHub Bot commented on KAFKA-9137: --- cmccabe commented on pull request #7640: KAFKA-9137:

[jira] [Updated] (KAFKA-9148) Consider forking RocksDB for Streams

2019-11-05 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9148: --- Description: We recently upgraded our RocksDB dependency to 5.18 for its

[jira] [Updated] (KAFKA-9148) Consider forking RocksDB for Streams

2019-11-05 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9148: --- Description: We recently upgraded our RocksDB dependency to 5.18 for its

[jira] [Created] (KAFKA-9148) Consider forking RocksDB for Streams

2019-11-05 Thread Sophie Blee-Goldman (Jira)
Sophie Blee-Goldman created KAFKA-9148: -- Summary: Consider forking RocksDB for Streams Key: KAFKA-9148 URL: https://issues.apache.org/jira/browse/KAFKA-9148 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-9147) zookeeper service not running

2019-11-05 Thread parimal (Jira)
parimal created KAFKA-9147: -- Summary: zookeeper service not running Key: KAFKA-9147 URL: https://issues.apache.org/jira/browse/KAFKA-9147 Project: Kafka Issue Type: Test Affects Versions:

[jira] [Resolved] (KAFKA-8367) Non-heap memory leak in Kafka Streams

2019-11-05 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman resolved KAFKA-8367. Resolution: Fixed > Non-heap memory leak in Kafka Streams >

[jira] [Commented] (KAFKA-8367) Non-heap memory leak in Kafka Streams

2019-11-05 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16967981#comment-16967981 ] Sophie Blee-Goldman commented on KAFKA-8367: [~pavelsavov] I am going to close this as the

[jira] [Commented] (KAFKA-9133) LogCleaner thread dies with: currentLog cannot be empty on an unexpected exception

2019-11-05 Thread Karolis Pocius (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16967976#comment-16967976 ] Karolis Pocius commented on KAFKA-9133: --- Ended up downgrading to 2.3.0 and the issue went away.

[jira] [Commented] (KAFKA-9044) Brokers occasionally (randomly?) dropping out of clusters

2019-11-05 Thread Peter Bukowinski (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16967975#comment-16967975 ] Peter Bukowinski commented on KAFKA-9044: - The broker doesn't actually shut down. It continues to

[jira] [Commented] (KAFKA-9044) Brokers occasionally (randomly?) dropping out of clusters

2019-11-05 Thread Ismael Juma (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16967963#comment-16967963 ] Ismael Juma commented on KAFKA-9044: Is it possible that something in the infrastructure is causing

[jira] [Commented] (KAFKA-9142) topic __transaction_state disk space grows too big

2019-11-05 Thread Francesca Capochiani (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16967944#comment-16967944 ] Francesca Capochiani commented on KAFKA-9142: - Same issue too! > topic __transaction_state

[jira] [Created] (KAFKA-9146) Add option to force delete members in stream reset tool

2019-11-05 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-9146: -- Summary: Add option to force delete members in stream reset tool Key: KAFKA-9146 URL: https://issues.apache.org/jira/browse/KAFKA-9146 Project: Kafka Issue

[jira] [Commented] (KAFKA-8769) Consider computing stream time independently per key

2019-11-05 Thread Richard Yu (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8769?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16967926#comment-16967926 ] Richard Yu commented on KAFKA-8769: --- [~vvcephei] Do you have any ideas on advancing stream time? It

[jira] [Commented] (KAFKA-9044) Brokers occasionally (randomly?) dropping out of clusters

2019-11-05 Thread Peter Bukowinski (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16967879#comment-16967879 ] Peter Bukowinski commented on KAFKA-9044: - I downgraded one of the affected clusters to version

[jira] [Updated] (KAFKA-9044) Brokers occasionally (randomly?) dropping out of clusters

2019-11-05 Thread Peter Bukowinski (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Peter Bukowinski updated KAFKA-9044: Affects Version/s: 2.3.0 > Brokers occasionally (randomly?) dropping out of clusters >

[jira] [Created] (KAFKA-9145) AbstractCoordinator should respect retry backoff between rebalances

2019-11-05 Thread Jason Gustafson (Jira)
Jason Gustafson created KAFKA-9145: -- Summary: AbstractCoordinator should respect retry backoff between rebalances Key: KAFKA-9145 URL: https://issues.apache.org/jira/browse/KAFKA-9145 Project: Kafka

[jira] [Updated] (KAFKA-7061) Enhanced log compaction

2019-11-05 Thread Senthilnathan Muthusamy (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Senthilnathan Muthusamy updated KAFKA-7061: --- Description: Enhance log compaction to support more than just offset

[jira] [Updated] (KAFKA-7061) Enhanced log compaction

2019-11-05 Thread Senthilnathan Muthusamy (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Senthilnathan Muthusamy updated KAFKA-7061: --- Description: Enhance log compaction to support more than just offset

[jira] [Commented] (KAFKA-7987) a broker's ZK session may die on transient auth failure

2019-11-05 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16967806#comment-16967806 ] Jun Rao commented on KAFKA-7987: [~gcampbell], we could try calling scheduleSessionExpiryHandler() in 

[jira] [Commented] (KAFKA-7987) a broker's ZK session may die on transient auth failure

2019-11-05 Thread Graham Campbell (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16967790#comment-16967790 ] Graham Campbell commented on KAFKA-7987: [~junrao] We're starting to see these errors more

[jira] [Created] (KAFKA-9144) Early expiration of producer state can cause coordinator epoch to regress

2019-11-05 Thread Jason Gustafson (Jira)
Jason Gustafson created KAFKA-9144: -- Summary: Early expiration of producer state can cause coordinator epoch to regress Key: KAFKA-9144 URL: https://issues.apache.org/jira/browse/KAFKA-9144 Project:

[jira] [Commented] (KAFKA-8977) Remove MockStreamsMetrics Since it is not a Mock

2019-11-05 Thread bibin sebastian (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16967683#comment-16967683 ] bibin sebastian commented on KAFKA-8977: [~cadonna] do you think that my PR above is up for

[jira] [Commented] (KAFKA-9143) DistributedHerder misleadingly log error on connector task reconfiguration

2019-11-05 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16967661#comment-16967661 ] ASF GitHub Bot commented on KAFKA-9143: --- ivanyu commented on pull request #7648: KAFKA-9143: Log

[jira] [Created] (KAFKA-9143) DistributedHerder misleadingly log error on connector task reconfiguration

2019-11-05 Thread Ivan Yurchenko (Jira)
Ivan Yurchenko created KAFKA-9143: - Summary: DistributedHerder misleadingly log error on connector task reconfiguration Key: KAFKA-9143 URL: https://issues.apache.org/jira/browse/KAFKA-9143 Project:

[jira] [Comment Edited] (KAFKA-9133) LogCleaner thread dies with: currentLog cannot be empty on an unexpected exception

2019-11-05 Thread Tim Van Laer (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16967572#comment-16967572 ] Tim Van Laer edited comment on KAFKA-9133 at 11/5/19 2:37 PM: -- [~Karolis]

[jira] [Commented] (KAFKA-9133) LogCleaner thread dies with: currentLog cannot be empty on an unexpected exception

2019-11-05 Thread Tim Van Laer (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16967572#comment-16967572 ] Tim Van Laer commented on KAFKA-9133: - [~Karolis] and i did a couple of code changes in an attempt to

[jira] [Commented] (KAFKA-9110) Improve efficiency of disk reads when TLS is enabled

2019-11-05 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16967499#comment-16967499 ] ASF GitHub Bot commented on KAFKA-9110: --- ijuma commented on pull request #7604: KAFKA-9110: Improve

[jira] [Commented] (KAFKA-9133) LogCleaner thread dies with: currentLog cannot be empty on an unexpected exception

2019-11-05 Thread Karolis Pocius (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16967451#comment-16967451 ] Karolis Pocius commented on KAFKA-9133: --- Combing through the logs of the latest instance that