[jira] [Commented] (KAFKA-8207) StickyPartitionAssignor for KStream

2019-05-19 Thread neeraj (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16843677#comment-16843677 ] neeraj commented on KAFKA-8207: --- [~mjsax] KIP 345 seems is not a part of 2.3 release as giv

[jira] [Commented] (KAFKA-7869) Refactor RocksDBConfigSetter API to separate DBOptions and CFOptions

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

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

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

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

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

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

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

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

2019-05-19 Thread Richard Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16843540#comment-16843540 ] Richard Yu commented on KAFKA-7994: --- Ok, after digging around, I figured this much out:

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

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

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

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

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

2019-05-19 Thread Richard Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16843534#comment-16843534 ] Richard Yu commented on KAFKA-7994: --- Oh, just realized what was wrong with my approach.

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

2019-05-19 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: -- Comment: was deleted (was: Yeah, those are some nice points. ProcessorContext is indeed restricted to

[jira] [Comment Edited] (KAFKA-8206) A consumer can't discover new group coordinator when the cluster was partly restarted

2019-05-19 Thread Ivan Yurchenko (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16843529#comment-16843529 ] Ivan Yurchenko edited comment on KAFKA-8206 at 5/19/19 7:17 PM: ---

[jira] [Commented] (KAFKA-8206) A consumer can't discover new group coordinator when the cluster was partly restarted

2019-05-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16843528#comment-16843528 ] ASF GitHub Bot commented on KAFKA-8206: --- ivanyu commented on pull request #6765: KA

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

2019-05-19 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16843517#comment-16843517 ] Matthias J. Sax commented on KAFKA-7994: > So this might handle how partition tim

[jira] [Commented] (KAFKA-8388) Add methods to query for entries in KTable using timestamp

2019-05-19 Thread Richard Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16843510#comment-16843510 ] Richard Yu commented on KAFKA-8388: --- The idea for this issue stemmed from a problem tha

[jira] [Comment Edited] (KAFKA-8388) Add methods to query for entries in KTable using timestamp

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

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

2019-05-19 Thread Richard Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16843463#comment-16843463 ] Richard Yu commented on KAFKA-7994: --- Yeah, those are some nice points. ProcessorContext

[jira] [Created] (KAFKA-8392) Kafka broker leaks metric when partition leader moves to another node.

2019-05-19 Thread Kamal Chandraprakash (JIRA)
Kamal Chandraprakash created KAFKA-8392: --- Summary: Kafka broker leaks metric when partition leader moves to another node. Key: KAFKA-8392 URL: https://issues.apache.org/jira/browse/KAFKA-8392 Pr

[jira] [Created] (KAFKA-8391) Flaky Test RebalanceSourceConnectorsIntegrationTest#testDeleteConnector

2019-05-19 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created KAFKA-8391: -- Summary: Flaky Test RebalanceSourceConnectorsIntegrationTest#testDeleteConnector Key: KAFKA-8391 URL: https://issues.apache.org/jira/browse/KAFKA-8391 Project: Ka

[jira] [Commented] (KAFKA-7647) Flaky test LogCleanerParameterizedIntegrationTest.testCleansCombinedCompactAndDeleteTopic

2019-05-19 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16843411#comment-16843411 ] Matthias J. Sax commented on KAFKA-7647: Failed again:  [https://builds.apache.or

[jira] [Commented] (KAFKA-8347) Choose next record to process by timestamp

2019-05-19 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16843405#comment-16843405 ] Matthias J. Sax commented on KAFKA-8347: I think, the cherry pick happened after

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

2019-05-19 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16843402#comment-16843402 ] Matthias J. Sax commented on KAFKA-7994: Adding partition time to the context mig

[jira] [Commented] (KAFKA-8388) Add methods to query for entries in KTable using timestamp

2019-05-19 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16843394#comment-16843394 ] Matthias J. Sax commented on KAFKA-8388: I was thinking about TTL, because the ti