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
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
> --
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:
[
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
>
[
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
> -
[
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
[
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
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
[
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
[
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
> ---
[
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
>
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
[
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:
[
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:
[
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
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
[
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
> --
[
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
[
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
[
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
[
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
28 matches
Mail list logo