[jira] [Commented] (KAFKA-8630) Unit testing a streams processor with a WindowStore throws a ClassCastException

2019-07-08 Thread Justin Fetherolf (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16880923#comment-16880923 ] Justin Fetherolf commented on KAFKA-8630: - The `ProcessorContext` interface already offers a

[jira] [Commented] (KAFKA-4212) Add a key-value store that is a TTL persistent cache

2019-07-08 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16880893#comment-16880893 ] Sophie Blee-Goldman commented on KAFKA-4212: I agree with Matthias that, if we do want to go

[jira] [Created] (KAFKA-8640) Replace OffsetFetch request/response with automated protocol

2019-07-08 Thread Boyang Chen (JIRA)
Boyang Chen created KAFKA-8640: -- Summary: Replace OffsetFetch request/response with automated protocol Key: KAFKA-8640 URL: https://issues.apache.org/jira/browse/KAFKA-8640 Project: Kafka

[jira] [Issue Comment Deleted] (KAFKA-8630) Unit testing a streams processor with a WindowStore throws a ClassCastException

2019-07-08 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8630: --- Comment: was deleted (was: I agree with Justin. Testing using internal classes should be

[jira] [Commented] (KAFKA-8630) Unit testing a streams processor with a WindowStore throws a ClassCastException

2019-07-08 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16880891#comment-16880891 ] Matthias J. Sax commented on KAFKA-8630: I agree with Justin. Testing using internal classes

[jira] [Commented] (KAFKA-8630) Unit testing a streams processor with a WindowStore throws a ClassCastException

2019-07-08 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16880886#comment-16880886 ] Sophie Blee-Goldman commented on KAFKA-8630: You're right, I overlooked that

[jira] [Updated] (KAFKA-8620) Race condition in StreamThread state change

2019-07-08 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8620: --- Summary: Race condition in StreamThread state change (was: Fix potential race condition in

[jira] [Commented] (KAFKA-8630) Unit testing a streams processor with a WindowStore throws a ClassCastException

2019-07-08 Thread Justin Fetherolf (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16880831#comment-16880831 ] Justin Fetherolf commented on KAFKA-8630: - [~ableegoldman] I personally feel that this is still a

[jira] [Commented] (KAFKA-8615) Change to track partition time breaks TimestampExtractor

2019-07-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16880820#comment-16880820 ] ASF GitHub Bot commented on KAFKA-8615: --- ableegoldman commented on pull request #7054: KAFKA-8615:

[jira] [Created] (KAFKA-8639) Replace AddPartitionsToTxn request/response with automated protocol

2019-07-08 Thread Boyang Chen (JIRA)
Boyang Chen created KAFKA-8639: -- Summary: Replace AddPartitionsToTxn request/response with automated protocol Key: KAFKA-8639 URL: https://issues.apache.org/jira/browse/KAFKA-8639 Project: Kafka

[jira] [Commented] (KAFKA-8616) Replace ApiVersionsRequest request/response with automated protocol

2019-07-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8616?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16880789#comment-16880789 ] ASF GitHub Bot commented on KAFKA-8616: --- abbccdda commented on pull request #7052: KAFKA-8616:

[jira] [Commented] (KAFKA-8630) Unit testing a streams processor with a WindowStore throws a ClassCastException

2019-07-08 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16880771#comment-16880771 ] Sophie Blee-Goldman commented on KAFKA-8630: Yes, you're likely to hit this problem with some

[jira] [Commented] (KAFKA-4212) Add a key-value store that is a TTL persistent cache

2019-07-08 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16880761#comment-16880761 ] Matthias J. Sax commented on KAFKA-4212: \cc [~guozhang] [~bbejeck] WDYT? [~ctoomey]: just to

[jira] [Commented] (KAFKA-8026) Flaky Test RegexSourceIntegrationTest#testRegexMatchesTopicsAWhenDeleted

2019-07-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16880756#comment-16880756 ] ASF GitHub Bot commented on KAFKA-8026: --- emschwar commented on pull request #7051: KAFKA-8026: Fix

[jira] [Commented] (KAFKA-8637) WriteBatch objects leak off-heap memory

2019-07-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16880748#comment-16880748 ] ASF GitHub Bot commented on KAFKA-8637: --- ableegoldman commented on pull request #7050: KAFKA-8637:

[jira] [Updated] (KAFKA-8638) Preferred Leader Blacklist (deprioritized list)

2019-07-08 Thread GEORGE LI (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] GEORGE LI updated KAFKA-8638: - Description: Currently, the kafka preferred leader election will pick the broker_id in the

[jira] [Created] (KAFKA-8638) Preferred Leader Blacklist (deprioritized list)

2019-07-08 Thread GEORGE LI (JIRA)
GEORGE LI created KAFKA-8638: Summary: Preferred Leader Blacklist (deprioritized list) Key: KAFKA-8638 URL: https://issues.apache.org/jira/browse/KAFKA-8638 Project: Kafka Issue Type:

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

2019-07-08 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16880745#comment-16880745 ] Sophie Blee-Goldman commented on KAFKA-8367: Hey [~pavelsavov]! Sorry for the long silence. I

[jira] [Commented] (KAFKA-8637) WriteBatch objects leak off-heap memory

2019-07-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16880729#comment-16880729 ] ASF GitHub Bot commented on KAFKA-8637: --- ableegoldman commented on pull request #7049: KAFKA-8637:

[jira] [Resolved] (KAFKA-6771) Make specifying partitions in RoundTripWorkload, ProduceBench more flexible

2019-07-08 Thread Colin P. McCabe (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe resolved KAFKA-6771. Resolution: Fixed > Make specifying partitions in RoundTripWorkload, ProduceBench more

[jira] [Updated] (KAFKA-6263) Expose metric for group metadata loading duration

2019-07-08 Thread Anastasia Vela (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anastasia Vela updated KAFKA-6263: -- Component/s: core > Expose metric for group metadata loading duration >

[jira] [Updated] (KAFKA-6263) Expose metric for group metadata loading duration

2019-07-08 Thread Anastasia Vela (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anastasia Vela updated KAFKA-6263: -- Labels: (was: needs-kip) > Expose metric for group metadata loading duration >

[jira] [Commented] (KAFKA-8629) Kafka Streams Apps to support small native images through GraalVM

2019-07-08 Thread Andy Muir (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16880711#comment-16880711 ] Andy Muir commented on KAFKA-8629: -- I've blogged about my efforts so far here:

[jira] [Updated] (KAFKA-8637) WriteBatch objects leak off-heap memory

2019-07-08 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8637: --- Description: In 2.1 we did some refactoring that led to the WriteBatch objects in

[jira] [Created] (KAFKA-8637) WriteBatch objects leak off-heap memory

2019-07-08 Thread Sophie Blee-Goldman (JIRA)
Sophie Blee-Goldman created KAFKA-8637: -- Summary: WriteBatch objects leak off-heap memory Key: KAFKA-8637 URL: https://issues.apache.org/jira/browse/KAFKA-8637 Project: Kafka Issue

[jira] [Commented] (KAFKA-8636) Document behavior change for static members with `max.poll.interval.ms`

2019-07-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16880642#comment-16880642 ] ASF GitHub Bot commented on KAFKA-8636: --- abbccdda commented on pull request #7048: KAFKA-8636: add

[jira] [Created] (KAFKA-8636) Document behavior change for static members with `max.poll.interval.ms`

2019-07-08 Thread Boyang Chen (JIRA)
Boyang Chen created KAFKA-8636: -- Summary: Document behavior change for static members with `max.poll.interval.ms` Key: KAFKA-8636 URL: https://issues.apache.org/jira/browse/KAFKA-8636 Project: Kafka

[jira] [Commented] (KAFKA-6263) Expose metric for group metadata loading duration

2019-07-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16880501#comment-16880501 ] ASF GitHub Bot commented on KAFKA-6263: --- anatasiavela commented on pull request #7045: KAFKA-6263:

[jira] [Assigned] (KAFKA-8635) Unnecessary wait when looking up coordinator before transactional request

2019-07-08 Thread Bob Barrett (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bob Barrett reassigned KAFKA-8635: -- Assignee: Bob Barrett > Unnecessary wait when looking up coordinator before transactional

[jira] [Commented] (KAFKA-5998) /.checkpoint.tmp Not found exception

2019-07-08 Thread Di Campo (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16880482#comment-16880482 ] Di Campo commented on KAFKA-5998: - Thanks Patrik. So, if for some reason an application is stopped for

[jira] [Comment Edited] (KAFKA-8624) 这边是服务端的kafka,版本是 kafka_2.11-1.0.0.2,当客户端向主题发送消息的时候抛出如下异常,客户端跟服务端的版本不一致吗?

2019-07-08 Thread 李志涛
[ https://issues.apache.org/jira/browse/KAFKA-8624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16878387#comment-16878387 ] Zhitao Li(李志涛) edited comment on KAFKA-8624 at 7/8/19 3:35 PM: ---

[jira] [Commented] (KAFKA-8630) Unit testing a streams processor with a WindowStore throws a ClassCastException

2019-07-08 Thread Denis Washington (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16880227#comment-16880227 ] Denis Washington commented on KAFKA-8630: - Looks like the {{InMemoryWindowStore}} needs the extra

[jira] [Commented] (KAFKA-8345) Create an Administrative API for Replica Reassignment

2019-07-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16880195#comment-16880195 ] ASF GitHub Bot commented on KAFKA-8345: --- stanislavkozlovski commented on pull request #7041:

[jira] [Commented] (KAFKA-8635) Unnecessary wait when looking up coordinator before transactional request

2019-07-08 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16880162#comment-16880162 ] Ismael Juma commented on KAFKA-8635: Nice investigation, thanks for the report. cc [~hachikuji]

[jira] [Updated] (KAFKA-8635) Unnecessary wait when looking up coordinator before transactional request

2019-07-08 Thread Denis Washington (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Denis Washington updated KAFKA-8635: Description: In our Kafka Streams applications (with EOS enabled), we were seeing

[jira] [Updated] (KAFKA-8635) Unnecessary wait when looking up coordinator before transactional request

2019-07-08 Thread Denis Washington (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Denis Washington updated KAFKA-8635: Description: In our Kafka Streams applications (with EOS enabled), we were seeing

[jira] [Created] (KAFKA-8635) Unnecessary wait when looking up coordinator before transactional request

2019-07-08 Thread Denis Washington (JIRA)
Denis Washington created KAFKA-8635: --- Summary: Unnecessary wait when looking up coordinator before transactional request Key: KAFKA-8635 URL: https://issues.apache.org/jira/browse/KAFKA-8635

[jira] [Updated] (KAFKA-8634) Update ZooKeeper to 3.5.5

2019-07-08 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-8634: --- Fix Version/s: 2.4.0 > Update ZooKeeper to 3.5.5 > - > >

[jira] [Resolved] (KAFKA-7178) Is kafka compatible with zookeeper 3.5.x ?

2019-07-08 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-7178. Resolution: Duplicate KAFKA-8634 tracks updating to ZK 3.5.x. > Is kafka compatible with

[jira] [Created] (KAFKA-8634) Update ZooKeeper to 3.5.5

2019-07-08 Thread Ismael Juma (JIRA)
Ismael Juma created KAFKA-8634: -- Summary: Update ZooKeeper to 3.5.5 Key: KAFKA-8634 URL: https://issues.apache.org/jira/browse/KAFKA-8634 Project: Kafka Issue Type: Improvement

[jira] [Commented] (KAFKA-7447) Consumer offsets lost during leadership rebalance after bringing node back from clean shutdown

2019-07-08 Thread Sebastjanas Vaisovas (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16880134#comment-16880134 ] Sebastjanas Vaisovas commented on KAFKA-7447: - I experience the same on 2.0.0. Any plans to

[jira] [Commented] (KAFKA-7563) Single broker sends incorrect metadata for topic partitions

2019-07-08 Thread Martin Kamp Jensen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16880079#comment-16880079 ] Martin Kamp Jensen commented on KAFKA-7563: --- After upgrading to 2.3.0 clients (and currently

[jira] [Commented] (KAFKA-4212) Add a key-value store that is a TTL persistent cache

2019-07-08 Thread Chris Toomey (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16880077#comment-16880077 ] Chris Toomey commented on KAFKA-4212: - [~mjsax] there are at least 3 different teams (I'm working