[jira] [Resolved] (KAFKA-7140) Remove deprecated poll usages

[ https://issues.apache.org/jira/browse/KAFKA-7140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7140. Resolution: Fixed > Remove deprecated poll usages > - > >

[jira] [Commented] (KAFKA-7140) Remove deprecated poll usages

[ https://issues.apache.org/jira/browse/KAFKA-7140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16577062#comment-16577062 ] ASF GitHub Bot commented on KAFKA-7140: --- hachikuji closed pull request #5319: KAFKA-7140: Remove

[jira] [Commented] (KAFKA-7225) Kafka Connect ConfigProvider not invoked before validation

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

[jira] [Resolved] (KAFKA-6966) Extend `TopologyDescription.Sink` to return `TopicNameExtractor`

[ https://issues.apache.org/jira/browse/KAFKA-6966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6966. Resolution: Fixed > Extend `TopologyDescription.Sink` to return `TopicNameExtractor` >

[jira] [Updated] (KAFKA-6966) Extend `TopologyDescription.Sink` to return `TopicNameExtractor`

[ https://issues.apache.org/jira/browse/KAFKA-6966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6966: --- Fix Version/s: 2.1.0 > Extend `TopologyDescription.Sink` to return `TopicNameExtractor` >

[jira] [Updated] (KAFKA-6966) Extend `TopologyDescription.Sink` to return `TopicNameExtractor`

[ https://issues.apache.org/jira/browse/KAFKA-6966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6966: --- Description: With KIP-303, a dynamic routing feature was added and

[jira] [Updated] (KAFKA-6966) Extend `TopologyDescription.Sink` to return `TopicNameExtractor`

[ https://issues.apache.org/jira/browse/KAFKA-6966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6966: --- Labels: beginner kip newbie (was: beginner needs-kip newbie) > Extend

[jira] [Commented] (KAFKA-6966) Extend `TopologyDescription.Sink` to return `TopicNameExtractor`

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

[jira] [Comment Edited] (KAFKA-6571) KafkaProducer.close(0) should be non-blocking

[ https://issues.apache.org/jira/browse/KAFKA-6571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16576931#comment-16576931 ] Ahmed Al-Mehdi edited comment on KAFKA-6571 at 8/10/18 10:35 PM: - After

[jira] [Commented] (KAFKA-6571) KafkaProducer.close(0) should be non-blocking

[ https://issues.apache.org/jira/browse/KAFKA-6571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16576931#comment-16576931 ] Ahmed Al-Mehdi commented on KAFKA-6571: --- After discussion with Dong, assigning bug to self. >

[jira] [Assigned] (KAFKA-6571) KafkaProducer.close(0) should be non-blocking

[ https://issues.apache.org/jira/browse/KAFKA-6571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ahmed Al-Mehdi reassigned KAFKA-6571: - Assignee: Ahmed Al-Mehdi (was: Dong Lin) > KafkaProducer.close(0) should be

[jira] [Commented] (KAFKA-6998) Remove caching wrapper stores if cache-size is configured to zero bytes

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

[jira] [Commented] (KAFKA-7147) Allow kafka-reassign-partitions.sh and kafka-log-dirs.sh to take admin client property file

[ https://issues.apache.org/jira/browse/KAFKA-7147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16576871#comment-16576871 ] ASF GitHub Bot commented on KAFKA-7147: --- lindong28 closed pull request #5355: KAFKA-7147;

[jira] [Resolved] (KAFKA-7147) Allow kafka-reassign-partitions.sh and kafka-log-dirs.sh to take admin client property file

[ https://issues.apache.org/jira/browse/KAFKA-7147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin resolved KAFKA-7147. - Resolution: Fixed > Allow kafka-reassign-partitions.sh and kafka-log-dirs.sh to take admin client >

[jira] [Updated] (KAFKA-7277) Migrate Streams API to Duration instead of longMs times

[ https://issues.apache.org/jira/browse/KAFKA-7277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7277: --- Labels: beginner needs-kip newbie (was: needs-kip) > Migrate Streams API to Duration

[jira] [Updated] (KAFKA-7277) Migrate Streams API to Duration instead of longMs times

[ https://issues.apache.org/jira/browse/KAFKA-7277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7277: --- Description: Right now Streams API unversally represents time as ms-since-unix-epoch.

[jira] [Updated] (KAFKA-7277) Migrate Streams API to Duration instead of longMs times

[ https://issues.apache.org/jira/browse/KAFKA-7277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7277: --- Labels: needs-kip (was: ) > Migrate Streams API to Duration instead of longMs times >

[jira] [Updated] (KAFKA-7277) Migrate Streams API to Duration instead of longMs times

[ https://issues.apache.org/jira/browse/KAFKA-7277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7277: --- Component/s: streams > Migrate Streams API to Duration instead of longMs times >

[jira] [Commented] (KAFKA-7277) Migrate Streams API to Duration instead of longMs times

[ https://issues.apache.org/jira/browse/KAFKA-7277?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16576854#comment-16576854 ] John Roesler commented on KAFKA-7277: - I recommend that we validate each duration argument using a

[jira] [Created] (KAFKA-7277) Migrate Streams API to Duration instead of longMs times

John Roesler created KAFKA-7277: --- Summary: Migrate Streams API to Duration instead of longMs times Key: KAFKA-7277 URL: https://issues.apache.org/jira/browse/KAFKA-7277 Project: Kafka Issue

[jira] [Commented] (KAFKA-6998) Remove caching wrapper stores if cache-size is configured to zero bytes

[ https://issues.apache.org/jira/browse/KAFKA-6998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16576701#comment-16576701 ] Guozhang Wang commented on KAFKA-6998: -- Actually when I was looking into the code, I realized it is

[jira] [Created] (KAFKA-7276) Consider using re2j to speed up regex operations

Ted Yu created KAFKA-7276: - Summary: Consider using re2j to speed up regex operations Key: KAFKA-7276 URL: https://issues.apache.org/jira/browse/KAFKA-7276 Project: Kafka Issue Type: Task

[jira] [Created] (KAFKA-7275) Prototype lock-free metrics

John Roesler created KAFKA-7275: --- Summary: Prototype lock-free metrics Key: KAFKA-7275 URL: https://issues.apache.org/jira/browse/KAFKA-7275 Project: Kafka Issue Type: Improvement

[jira] [Commented] (KAFKA-6998) Remove caching wrapper stores if cache-size is configured to zero bytes

[ https://issues.apache.org/jira/browse/KAFKA-6998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16576462#comment-16576462 ] Guozhang Wang commented on KAFKA-6998: -- Yes, that's exactly my plan :) > Remove caching wrapper

[jira] [Commented] (KAFKA-6998) Remove caching wrapper stores if cache-size is configured to zero bytes

[ https://issues.apache.org/jira/browse/KAFKA-6998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16576459#comment-16576459 ] Matthias J. Sax commented on KAFKA-6998: Just realized, that with the new optimization layer, we

[jira] [Commented] (KAFKA-7269) KStream.merge is not documented

[ https://issues.apache.org/jira/browse/KAFKA-7269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16576449#comment-16576449 ] Matthias J. Sax commented on KAFKA-7269: I am not sure about "union" – union is a set operation,

[jira] [Commented] (KAFKA-7269) KStream.merge is not documented

[ https://issues.apache.org/jira/browse/KAFKA-7269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16576361#comment-16576361 ] John Roesler commented on KAFKA-7269: - Hi [~virgilp],  Thanks for the tip! It's not in scope to

[jira] [Commented] (KAFKA-7119) Intermittent test failure with GSSAPI authentication failure

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

[jira] [Assigned] (KAFKA-7119) Intermittent test failure with GSSAPI authentication failure

[ https://issues.apache.org/jira/browse/KAFKA-7119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram reassigned KAFKA-7119: - Assignee: Rajini Sivaram > Intermittent test failure with GSSAPI authentication failure

[jira] [Comment Edited] (KAFKA-6701) synchronize Log modification between delete cleanup and async delete

[ https://issues.apache.org/jira/browse/KAFKA-6701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16575873#comment-16575873 ] M. Manna edited comment on KAFKA-6701 at 8/10/18 7:30 AM: -- [~lindong] I believe

[jira] [Commented] (KAFKA-6701) synchronize Log modification between delete cleanup and async delete

[ https://issues.apache.org/jira/browse/KAFKA-6701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16575873#comment-16575873 ] M. Manna commented on KAFKA-6701: - [~lindong] I believe this might also be a fix for

[jira] [Resolved] (KAFKA-6701) synchronize Log modification between delete cleanup and async delete

[ https://issues.apache.org/jira/browse/KAFKA-6701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin resolved KAFKA-6701. - Resolution: Fixed The issue appears to have been fixed in

[jira] [Commented] (KAFKA-7269) KStream.merge is not documented

[ https://issues.apache.org/jira/browse/KAFKA-7269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16575845#comment-16575845 ] Virgil Palanciuc commented on KAFKA-7269: - Might I suggest to add "union" as an alternative to