[
https://issues.apache.org/jira/browse/KAFKA-7190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16947188#comment-16947188
]
ASF GitHub Bot commented on KAFKA-7190:
---
hachikuji commented on pull request #7388: KAFKA-7190:
[
https://issues.apache.org/jira/browse/KAFKA-7190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16937858#comment-16937858
]
ASF GitHub Bot commented on KAFKA-7190:
---
bob-barrett commented on pull request #7388: KAFKA-7190:
[
https://issues.apache.org/jira/browse/KAFKA-7190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16892046#comment-16892046
]
Bob Barrett commented on KAFKA-7190:
The periodic producer expiration check expires producers if 1)
[
https://issues.apache.org/jira/browse/KAFKA-7190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16891992#comment-16891992
]
Raman Gupta commented on KAFKA-7190:
> Did you override message.timestamp.difference.max.ms?
No.
>
[
https://issues.apache.org/jira/browse/KAFKA-7190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16891976#comment-16891976
]
Guozhang Wang commented on KAFKA-7190:
--
Hmm interesting, in this case the topic is not a repartition
[
https://issues.apache.org/jira/browse/KAFKA-7190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16891537#comment-16891537
]
Raman Gupta commented on KAFKA-7190:
[~mjsax] [~guozhang] I want to point out that the behavior I saw
[
https://issues.apache.org/jira/browse/KAFKA-7190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16891455#comment-16891455
]
Guozhang Wang commented on KAFKA-7190:
--
[~rocketraman] just to clarify:
* In general producer id
[
https://issues.apache.org/jira/browse/KAFKA-7190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16891211#comment-16891211
]
Matthias J. Sax commented on KAFKA-7190:
Thanks for your comment [~rocketraman] – KIP-360 will
[
https://issues.apache.org/jira/browse/KAFKA-7190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16888543#comment-16888543
]
Raman Gupta commented on KAFKA-7190:
I want to mention another case in which this happened. I'm not
[
https://issues.apache.org/jira/browse/KAFKA-7190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16808246#comment-16808246
]
ASF GitHub Bot commented on KAFKA-7190:
---
guozhangwang commented on pull request #6511: KAFKA-7190:
[
https://issues.apache.org/jira/browse/KAFKA-7190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16803424#comment-16803424
]
ASF GitHub Bot commented on KAFKA-7190:
---
guozhangwang commented on pull request #6511: KAFKA-7190:
[
https://issues.apache.org/jira/browse/KAFKA-7190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16803180#comment-16803180
]
Guozhang Wang commented on KAFKA-7190:
--
Will file a KIP / PR for this discussion, but this ticket
[
https://issues.apache.org/jira/browse/KAFKA-7190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16803153#comment-16803153
]
Guozhang Wang commented on KAFKA-7190:
--
I agree. I think we shall at least increase `segment.ms` at
[
https://issues.apache.org/jira/browse/KAFKA-7190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16773259#comment-16773259
]
Matthias J. Sax commented on KAFKA-7190:
[~guozhang] It seems that a workaround would be to
[
https://issues.apache.org/jira/browse/KAFKA-7190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16589573#comment-16589573
]
lambdaliu commented on KAFKA-7190:
--
Hi [~guozhang] As far as I am concerned , the follower also
[
https://issues.apache.org/jira/browse/KAFKA-7190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16588383#comment-16588383
]
Matthias J. Sax commented on KAFKA-7190:
[~guozhang] From my understanding, if
[
https://issues.apache.org/jira/browse/KAFKA-7190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16588370#comment-16588370
]
Guozhang Wang commented on KAFKA-7190:
--
[~lambdaliu] As Jason's proposal #5 mentioned, we do plan to
[
https://issues.apache.org/jira/browse/KAFKA-7190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16586903#comment-16586903
]
lambdaliu commented on KAFKA-7190:
--
Hi [~mjsax], Changing the log level to DEBUG can't avoid the
[
https://issues.apache.org/jira/browse/KAFKA-7190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16586886#comment-16586886
]
lambdaliu commented on KAFKA-7190:
--
Hi [~hachikuji], sorry for the later reply.
I have thought about
[
https://issues.apache.org/jira/browse/KAFKA-7190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16586359#comment-16586359
]
Jason Gustafson commented on KAFKA-7190:
Posted a KIP here:
[
https://issues.apache.org/jira/browse/KAFKA-7190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16584462#comment-16584462
]
Jason Gustafson commented on KAFKA-7190:
Sorry, this will be lengthy comment because this is a
[
https://issues.apache.org/jira/browse/KAFKA-7190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16582931#comment-16582931
]
Matthias J. Sax commented on KAFKA-7190:
I want to through out another thought:
Given the
[
https://issues.apache.org/jira/browse/KAFKA-7190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16572763#comment-16572763
]
Jason Gustafson commented on KAFKA-7190:
This is a tough one. To guarantee transaction semantics,
[
https://issues.apache.org/jira/browse/KAFKA-7190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1658#comment-1658
]
ASF GitHub Bot commented on KAFKA-7190:
---
lambdaliu opened a new pull request #5448: KAFKA-7190:
[
https://issues.apache.org/jira/browse/KAFKA-7190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16564694#comment-16564694
]
lambdaliu commented on KAFKA-7190:
--
Hi [~hachikuji], What do you think about the solution of the
[
https://issues.apache.org/jira/browse/KAFKA-7190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16560409#comment-16560409
]
Guozhang Wang commented on KAFKA-7190:
--
What you described looks reasonable to me. I'd like to have
[
https://issues.apache.org/jira/browse/KAFKA-7190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16558265#comment-16558265
]
lambdaliu commented on KAFKA-7190:
--
Hello [~guozhang]. My team developed a cloud version Kafka and I am
[
https://issues.apache.org/jira/browse/KAFKA-7190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16556289#comment-16556289
]
Dong Lin commented on KAFKA-7190:
-
Thanks you [~mjsax] [~guozhang] for the discussion.
> Under low
[
https://issues.apache.org/jira/browse/KAFKA-7190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16556238#comment-16556238
]
Guozhang Wang commented on KAFKA-7190:
--
[~lindong] That's a good point. I think maybe we would not
[
https://issues.apache.org/jira/browse/KAFKA-7190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16556070#comment-16556070
]
Matthias J. Sax commented on KAFKA-7190:
Good point. You are right, consumers in
[
https://issues.apache.org/jira/browse/KAFKA-7190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16556053#comment-16556053
]
Dong Lin commented on KAFKA-7190:
-
[~mjsax] I guess one question is, if LSO is defined for a
[
https://issues.apache.org/jira/browse/KAFKA-7190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16556042#comment-16556042
]
Matthias J. Sax commented on KAFKA-7190:
> The main reason we need to prevent client from
[
https://issues.apache.org/jira/browse/KAFKA-7190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16556011#comment-16556011
]
Dong Lin commented on KAFKA-7190:
-
[~guozhang] Certainly, I am happy to make the modification after we
[
https://issues.apache.org/jira/browse/KAFKA-7190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16555990#comment-16555990
]
Guozhang Wang commented on KAFKA-7190:
--
I've discussed about this with [~hachikuji] and here are our
[
https://issues.apache.org/jira/browse/KAFKA-7190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16555730#comment-16555730
]
lambdaliu commented on KAFKA-7190:
--
Hello [~mjsax] [~guozhang], sorry for the late reply. I also agree
[
https://issues.apache.org/jira/browse/KAFKA-7190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16553134#comment-16553134
]
Guozhang Wang commented on KAFKA-7190:
--
Hello [~lambdaliu], before you start picking up this ticket,
[
https://issues.apache.org/jira/browse/KAFKA-7190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16553095#comment-16553095
]
Matthias J. Sax commented on KAFKA-7190:
Thanks for picking this up [~lambdaliu].
I would like
37 matches
Mail list logo