[
https://issues.apache.org/jira/browse/KAFKA-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14540793#comment-14540793
]
Jiangjie Qin commented on KAFKA-1660:
-
Updated reviewboard
[
https://issues.apache.org/jira/browse/KAFKA-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14526902#comment-14526902
]
Jiangjie Qin commented on KAFKA-1660:
-
[~jkreps] [~jjkoshy] ping for a review :)
[
https://issues.apache.org/jira/browse/KAFKA-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14526939#comment-14526939
]
Jiangjie Qin commented on KAFKA-1660:
-
Thanks for the quick response, [~jkreps].
[
https://issues.apache.org/jira/browse/KAFKA-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14520141#comment-14520141
]
Jiangjie Qin commented on KAFKA-1660:
-
Hi [~jkreps], I prefer the counter as well
[
https://issues.apache.org/jira/browse/KAFKA-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14520341#comment-14520341
]
Joel Koshy commented on KAFKA-1660:
---
(There also needs to be a {{batch.done()}} in the
[
https://issues.apache.org/jira/browse/KAFKA-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14520557#comment-14520557
]
Jiangjie Qin commented on KAFKA-1660:
-
Updated reviewboard
[
https://issues.apache.org/jira/browse/KAFKA-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14520619#comment-14520619
]
Jiangjie Qin commented on KAFKA-1660:
-
Updated reviewboard
[
https://issues.apache.org/jira/browse/KAFKA-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14518314#comment-14518314
]
Jay Kreps commented on KAFKA-1660:
--
Here was the source of my paranoia about r/w locks
[
https://issues.apache.org/jira/browse/KAFKA-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14518484#comment-14518484
]
Jiangjie Qin commented on KAFKA-1660:
-
Thanks for the reference, Jay. Totally agreed.
[
https://issues.apache.org/jira/browse/KAFKA-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14504039#comment-14504039
]
Jiangjie Qin commented on KAFKA-1660:
-
Updated reviewboard
[
https://issues.apache.org/jira/browse/KAFKA-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14498469#comment-14498469
]
Jiangjie Qin commented on KAFKA-1660:
-
Updated reviewboard
[
https://issues.apache.org/jira/browse/KAFKA-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14490445#comment-14490445
]
Jiangjie Qin commented on KAFKA-1660:
-
Updated reviewboard
[
https://issues.apache.org/jira/browse/KAFKA-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14486022#comment-14486022
]
Jiangjie Qin commented on KAFKA-1660:
-
Updated reviewboard
[
https://issues.apache.org/jira/browse/KAFKA-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14484498#comment-14484498
]
Jiangjie Qin commented on KAFKA-1660:
-
Updated reviewboard
[
https://issues.apache.org/jira/browse/KAFKA-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14390958#comment-14390958
]
Jiangjie Qin commented on KAFKA-1660:
-
[~jkreps] Ping to see if you could help review
[
https://issues.apache.org/jira/browse/KAFKA-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14384895#comment-14384895
]
Jiangjie Qin commented on KAFKA-1660:
-
Updated reviewboard
[
https://issues.apache.org/jira/browse/KAFKA-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14380359#comment-14380359
]
Jiangjie Qin commented on KAFKA-1660:
-
Updated reviewboard
[
https://issues.apache.org/jira/browse/KAFKA-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14369878#comment-14369878
]
Steven Zhen Wu commented on KAFKA-1660:
---
when this patch is merged, would it be
[
https://issues.apache.org/jira/browse/KAFKA-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14353478#comment-14353478
]
Jiangjie Qin commented on KAFKA-1660:
-
Updated reviewboard
[
https://issues.apache.org/jira/browse/KAFKA-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14352515#comment-14352515
]
Jiangjie Qin commented on KAFKA-1660:
-
Created reviewboard
[
https://issues.apache.org/jira/browse/KAFKA-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14352525#comment-14352525
]
Jiangjie Qin commented on KAFKA-1660:
-
Updated reviewboard
[
https://issues.apache.org/jira/browse/KAFKA-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14351186#comment-14351186
]
Jiangjie Qin commented on KAFKA-1660:
-
Thanks for the quick response
[
https://issues.apache.org/jira/browse/KAFKA-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14351159#comment-14351159
]
Jiangjie Qin commented on KAFKA-1660:
-
[~parth.brahmbhatt] Have you got a chance to
[
https://issues.apache.org/jira/browse/KAFKA-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14351179#comment-14351179
]
Parth Brahmbhatt commented on KAFKA-1660:
-
No and I wont be able to do it for
[
https://issues.apache.org/jira/browse/KAFKA-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14345918#comment-14345918
]
Guozhang Wang commented on KAFKA-1660:
--
+1 on creating a new KIP. Especially, I think
[
https://issues.apache.org/jira/browse/KAFKA-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14344481#comment-14344481
]
Jay Kreps commented on KAFKA-1660:
--
[~parth.brahmbhatt] Yeah this was exactly what I was
[
https://issues.apache.org/jira/browse/KAFKA-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14343552#comment-14343552
]
Parth Brahmbhatt commented on KAFKA-1660:
-
Updated reviewboard
[
https://issues.apache.org/jira/browse/KAFKA-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14335546#comment-14335546
]
Guozhang Wang commented on KAFKA-1660:
--
Parth, I am wondering if this new API can be
[
https://issues.apache.org/jira/browse/KAFKA-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14325210#comment-14325210
]
Parth Brahmbhatt commented on KAFKA-1660:
-
[~jkreps] I have updated the review
[
https://issues.apache.org/jira/browse/KAFKA-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14325207#comment-14325207
]
Parth Brahmbhatt commented on KAFKA-1660:
-
Updated reviewboard
[
https://issues.apache.org/jira/browse/KAFKA-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14317171#comment-14317171
]
Parth Brahmbhatt commented on KAFKA-1660:
-
I am not aware of any clean way to
[
https://issues.apache.org/jira/browse/KAFKA-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14317335#comment-14317335
]
Jay Kreps commented on KAFKA-1660:
--
Yeah I'm not proposing calling thread.stop(), we
[
https://issues.apache.org/jira/browse/KAFKA-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14311699#comment-14311699
]
Jay Kreps commented on KAFKA-1660:
--
This is very similar to KAFKA-1659 and KAFKA-1934.
[
https://issues.apache.org/jira/browse/KAFKA-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14260510#comment-14260510
]
Parth Brahmbhatt commented on KAFKA-1660:
-
Created reviewboard
[
https://issues.apache.org/jira/browse/KAFKA-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14260511#comment-14260511
]
Parth Brahmbhatt commented on KAFKA-1660:
-
https://reviews.apache.org/r/29467/
[
https://issues.apache.org/jira/browse/KAFKA-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14154809#comment-14154809
]
Andrew Stein commented on KAFKA-1660:
-
Hi [~jkreps],
I don't think that this (the
[
https://issues.apache.org/jira/browse/KAFKA-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14154882#comment-14154882
]
Jay Kreps commented on KAFKA-1660:
--
Gotcha, so if I understand close(time) is effectively
[
https://issues.apache.org/jira/browse/KAFKA-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14155625#comment-14155625
]
Andrew Stein commented on KAFKA-1660:
-
Yes, {{close(timeout)}} is
38 matches
Mail list logo