[jira] [Created] (KAFKA-8436) Replace AddOffsetsToTxn request/response with automated protocol

2019-05-26 Thread Boyang Chen (JIRA)
Boyang Chen created KAFKA-8436: -- Summary: Replace AddOffsetsToTxn request/response with automated protocol Key: KAFKA-8436 URL: https://issues.apache.org/jira/browse/KAFKA-8436 Project: Kafka I

[jira] [Created] (KAFKA-8435) Replace DeleteGroups request/response with automated protocol

2019-05-26 Thread Boyang Chen (JIRA)
Boyang Chen created KAFKA-8435: -- Summary: Replace DeleteGroups request/response with automated protocol Key: KAFKA-8435 URL: https://issues.apache.org/jira/browse/KAFKA-8435 Project: Kafka Issu

[jira] [Commented] (KAFKA-7788) Support null defaults in KAFKA-7609 RPC specifications

2019-05-26 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16848646#comment-16848646 ] Boyang Chen commented on KAFKA-7788: [~hachikuji] Is this being solved by  [https://g

[jira] [Commented] (KAFKA-7994) Improve Stream-Time for rebalances and restarts

2019-05-26 Thread Richard Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16848610#comment-16848610 ] Richard Yu commented on KAFKA-7994: --- cc [~mjsax] Made the change. > Improve Stream-Tim

[jira] [Commented] (KAFKA-7994) Improve Stream-Time for rebalances and restarts

2019-05-26 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16848607#comment-16848607 ] Matthias J. Sax commented on KAFKA-7994: Yes. Please rebase the PR to only includ

[jira] [Commented] (KAFKA-8433) Give the opportunity to use serializers and deserializers with IntegrationTestUtils

2019-05-26 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16848605#comment-16848605 ] Matthias J. Sax commented on KAFKA-8433: I seems you are using this class for you

[jira] [Updated] (KAFKA-7994) Improve Stream-Time for rebalances and restarts

2019-05-26 Thread Richard Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Richard Yu updated KAFKA-7994: -- Description: We compute a per-partition partition-time as the maximum timestamp over all records proce

[jira] [Comment Edited] (KAFKA-7994) Improve Stream-Time for rebalances and restarts

2019-05-26 Thread Richard Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16848534#comment-16848534 ] Richard Yu edited comment on KAFKA-7994 at 5/26/19 9:32 PM: S

[jira] [Resolved] (KAFKA-8434) Make global stream time consistent over all stream tasks

2019-05-26 Thread Richard Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Richard Yu resolved KAFKA-8434. --- Resolution: Fixed > Make global stream time consistent over all stream tasks > --

[jira] [Created] (KAFKA-8434) Make global stream time consistent over all stream tasks

2019-05-26 Thread Richard Yu (JIRA)
Richard Yu created KAFKA-8434: - Summary: Make global stream time consistent over all stream tasks Key: KAFKA-8434 URL: https://issues.apache.org/jira/browse/KAFKA-8434 Project: Kafka Issue Type:

[jira] [Updated] (KAFKA-8434) Make global stream time consistent over all stream tasks

2019-05-26 Thread Richard Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Richard Yu updated KAFKA-8434: -- Labels: kip needs-discussion (was: ) > Make global stream time consistent over all stream tasks >

[jira] [Updated] (KAFKA-8434) Make global stream time consistent over all stream tasks

2019-05-26 Thread Richard Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Richard Yu updated KAFKA-8434: -- Component/s: streams > Make global stream time consistent over all stream tasks > -

[jira] [Commented] (KAFKA-7994) Improve Stream-Time for rebalances and restarts

2019-05-26 Thread Richard Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16848534#comment-16848534 ] Richard Yu commented on KAFKA-7994: --- Sure [~mjsax] I'm all for it, since it looks like

[jira] [Commented] (KAFKA-8433) Give the opportunity to use serializers and deserializers with IntegrationTestUtils

2019-05-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16848535#comment-16848535 ] ASF GitHub Bot commented on KAFKA-8433: --- callaertanthony commented on pull request

[jira] [Created] (KAFKA-8433) Give the opportunity to use serializers and deserializers with IntegrationTestUtils

2019-05-26 Thread Anthony Callaert (JIRA)
Anthony Callaert created KAFKA-8433: --- Summary: Give the opportunity to use serializers and deserializers with IntegrationTestUtils Key: KAFKA-8433 URL: https://issues.apache.org/jira/browse/KAFKA-8433

[jira] [Resolved] (KAFKA-8246) refactor topic/group instance id validation condition

2019-05-26 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-8246. Resolution: Not A Problem Since it's only one time validation, we don't need to refactor. > refact

[jira] [Assigned] (KAFKA-8432) Add static membership to Sticky assignor

2019-05-26 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-8432: -- Assignee: Boyang Chen > Add static membership to Sticky assignor > ---

[jira] [Assigned] (KAFKA-8355) Add static membership to Range assignor

2019-05-26 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-8355: -- Assignee: Boyang Chen > Add static membership to Range assignor >

[jira] [Created] (KAFKA-8432) Add static membership to Sticky assignor

2019-05-26 Thread Boyang Chen (JIRA)
Boyang Chen created KAFKA-8432: -- Summary: Add static membership to Sticky assignor Key: KAFKA-8432 URL: https://issues.apache.org/jira/browse/KAFKA-8432 Project: Kafka Issue Type: Sub-task

[jira] [Comment Edited] (KAFKA-8297) Kafka Streams ConsumerRecordFactory yields difficult compiler error about generics

2019-05-26 Thread Rens Groothuijsen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16848480#comment-16848480 ] Rens Groothuijsen edited comment on KAFKA-8297 at 5/26/19 4:42 PM:

[jira] [Comment Edited] (KAFKA-8297) Kafka Streams ConsumerRecordFactory yields difficult compiler error about generics

2019-05-26 Thread Rens Groothuijsen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16848480#comment-16848480 ] Rens Groothuijsen edited comment on KAFKA-8297 at 5/26/19 4:42 PM:

[jira] [Commented] (KAFKA-8297) Kafka Streams ConsumerRecordFactory yields difficult compiler error about generics

2019-05-26 Thread Rens Groothuijsen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16848480#comment-16848480 ] Rens Groothuijsen commented on KAFKA-8297: -- Would it break the existing interfac

[jira] [Created] (KAFKA-8431) Add a onTimeoutExpired callback to Kafka Consumer

2019-05-26 Thread Richard Yu (JIRA)
Richard Yu created KAFKA-8431: - Summary: Add a onTimeoutExpired callback to Kafka Consumer Key: KAFKA-8431 URL: https://issues.apache.org/jira/browse/KAFKA-8431 Project: Kafka Issue Type: Improve

[jira] [Updated] (KAFKA-8431) Add a onTimeoutExpired callback to Kafka Consumer

2019-05-26 Thread Richard Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Richard Yu updated KAFKA-8431: -- Labels: needs-kip (was: ) > Add a onTimeoutExpired callback to Kafka Consumer > --

[jira] [Commented] (KAFKA-8187) State store record loss across multiple reassignments when using standby tasks

2019-05-26 Thread Lifei Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16848458#comment-16848458 ] Lifei Chen commented on KAFKA-8187: --- Hi, I'm also interested about the issue,  and fill

[jira] [Commented] (KAFKA-8187) State store record loss across multiple reassignments when using standby tasks

2019-05-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16848456#comment-16848456 ] ASF GitHub Bot commented on KAFKA-8187: --- hustclf commented on pull request #6818: K

[jira] [Commented] (KAFKA-2939) Make AbstractConfig.logUnused() tunable for clients

2019-05-26 Thread Rens Groothuijsen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16848414#comment-16848414 ] Rens Groothuijsen commented on KAFKA-2939: -- Took a shot at implementing the bool

[jira] [Commented] (KAFKA-7245) Deprecate WindowStore#put(key, value)

2019-05-26 Thread Omkar Mestry (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16848387#comment-16848387 ] Omkar Mestry commented on KAFKA-7245: - Thread:- [https://www.mail-archive.com/dev@kaf