[jira] [Commented] (KAFKA-8386) Use COORDINATOR_NOT_AVAILABLE to replace UNKNOWN_MEMBER_ID when the group is not available

[ https://issues.apache.org/jira/browse/KAFKA-8386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16843323#comment-16843323 ] ASF GitHub Bot commented on KAFKA-8386: --- abbccdda commented on pull request #6762:

[jira] [Resolved] (KAFKA-8373) Add group.instance.id field into Sync/Heartbeat/OffsetCommit protocols

[ https://issues.apache.org/jira/browse/KAFKA-8373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-8373. Resolution: Fixed Addressed in [https://github.com/apache/kafka/pull/6650/] > Add group.instance.i

[jira] [Resolved] (KAFKA-8225) Handle conflicting static member id

[ https://issues.apache.org/jira/browse/KAFKA-8225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-8225. Resolution: Fixed > Handle conflicting static member id > --- > >

[jira] [Assigned] (KAFKA-8389) Duplicated MockProcessorSupplier / MockProcessor in TopologyTestDriverTest

[ https://issues.apache.org/jira/browse/KAFKA-8389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-8389: Assignee: Guozhang Wang > Duplicated MockProcessorSupplier / MockProcessor in TopologyTest

[jira] [Commented] (KAFKA-8389) Duplicated MockProcessorSupplier / MockProcessor in TopologyTestDriverTest

[ https://issues.apache.org/jira/browse/KAFKA-8389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16843296#comment-16843296 ] ASF GitHub Bot commented on KAFKA-8389: --- guozhangwang commented on pull request #67

[jira] [Resolved] (KAFKA-6474) Rewrite test to use new public TopologyTestDriver

[ https://issues.apache.org/jira/browse/KAFKA-6474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6474. -- Resolution: Fixed Fix Version/s: 2.3.0 > Rewrite test to use new public TopologyTestDriv

[jira] [Commented] (KAFKA-6474) Rewrite test to use new public TopologyTestDriver

[ https://issues.apache.org/jira/browse/KAFKA-6474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16843287#comment-16843287 ] ASF GitHub Bot commented on KAFKA-6474: --- guozhangwang commented on pull request #67

[jira] [Commented] (KAFKA-8349) Add Windows batch files corresponding to kafka-delete-records.sh and kafka-log-dirs.sh

[ https://issues.apache.org/jira/browse/KAFKA-8349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16843260#comment-16843260 ] ASF GitHub Bot commented on KAFKA-8349: --- hachikuji commented on pull request #6709:

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

[ https://issues.apache.org/jira/browse/KAFKA-7994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16843223#comment-16843223 ] Richard Yu edited comment on KAFKA-7994 at 5/18/19 8:44 PM: O

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

[ https://issues.apache.org/jira/browse/KAFKA-7994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16843223#comment-16843223 ] Richard Yu edited comment on KAFKA-7994 at 5/18/19 8:44 PM: O

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

[ https://issues.apache.org/jira/browse/KAFKA-8388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16843233#comment-16843233 ] Richard Yu edited comment on KAFKA-8388 at 5/18/19 8:02 PM: T

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

[ https://issues.apache.org/jira/browse/KAFKA-8388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16843233#comment-16843233 ] Richard Yu edited comment on KAFKA-8388 at 5/18/19 8:02 PM: T

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

[ https://issues.apache.org/jira/browse/KAFKA-8388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16843233#comment-16843233 ] Richard Yu edited comment on KAFKA-8388 at 5/18/19 8:01 PM: T

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

[ https://issues.apache.org/jira/browse/KAFKA-8388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16843233#comment-16843233 ] Richard Yu edited comment on KAFKA-8388 at 5/18/19 7:59 PM: T

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

[ https://issues.apache.org/jira/browse/KAFKA-8388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16843233#comment-16843233 ] Richard Yu edited comment on KAFKA-8388 at 5/18/19 7:58 PM: T

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

[ https://issues.apache.org/jira/browse/KAFKA-8388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16843233#comment-16843233 ] Richard Yu edited comment on KAFKA-8388 at 5/18/19 7:55 PM: T

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

[ https://issues.apache.org/jira/browse/KAFKA-8388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16843233#comment-16843233 ] Richard Yu edited comment on KAFKA-8388 at 5/18/19 7:53 PM: T

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

[ https://issues.apache.org/jira/browse/KAFKA-8388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16843233#comment-16843233 ] Richard Yu commented on KAFKA-8388: --- To your first question, the answer I think is yes.

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

[ 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

[ https://issues.apache.org/jira/browse/KAFKA-7994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16843223#comment-16843223 ] Richard Yu edited comment on KAFKA-7994 at 5/18/19 7:28 PM: O

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

[ https://issues.apache.org/jira/browse/KAFKA-7994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16843223#comment-16843223 ] Richard Yu commented on KAFKA-7994: --- Oh, just realized that there should be more change

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

[ 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: Hi all, could we get some reviews on the PR? There hasn't been too much act

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

[ https://issues.apache.org/jira/browse/KAFKA-8388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16843221#comment-16843221 ] Matthias J. Sax commented on KAFKA-8388: Just to clarify: this ticket is not abou

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

[ https://issues.apache.org/jira/browse/KAFKA-8388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16843212#comment-16843212 ] Richard Yu commented on KAFKA-8388: --- [~guozhang] and [~vvcephei] Thoughts? > Add metho

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

[ https://issues.apache.org/jira/browse/KAFKA-8388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Richard Yu updated KAFKA-8388: -- Description: Currently, in Kafka Streams, KTable API does not allow users to query for entries with a

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

[ https://issues.apache.org/jira/browse/KAFKA-8388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16843211#comment-16843211 ] Richard Yu commented on KAFKA-8388: --- Sure, in that case, we probably will go with optio

[jira] [Created] (KAFKA-8390) Replace CreateDelegationToken request/response with automated protocol

Mickael Maison created KAFKA-8390: - Summary: Replace CreateDelegationToken request/response with automated protocol Key: KAFKA-8390 URL: https://issues.apache.org/jira/browse/KAFKA-8390 Project: Kafka

[jira] [Commented] (KAFKA-8225) Handle conflicting static member id

[ https://issues.apache.org/jira/browse/KAFKA-8225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16843177#comment-16843177 ] ASF GitHub Bot commented on KAFKA-8225: --- guozhangwang commented on pull request #66

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

[ https://issues.apache.org/jira/browse/KAFKA-8388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16843159#comment-16843159 ] Matthias J. Sax commented on KAFKA-8388: Thanks for creating this ticket. {quote}

[jira] [Resolved] (KAFKA-6455) Improve timestamp propagation at DSL level

[ https://issues.apache.org/jira/browse/KAFKA-6455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6455. Resolution: Fixed Fix Version/s: 2.3.0 > Improve timestamp propagation at DSL level