[jira] [Commented] (KAFKA-6547) group offset reset and begin_offset ignored/no effect

[ https://issues.apache.org/jira/browse/KAFKA-6547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16577856#comment-16577856 ] Nikazu commented on KAFKA-6547: --- Any update on this? I seem to be having the same issue with kafka 2.0 >

[jira] [Created] (KAFKA-7279) partitionsFor implicitly creates topic for the existent topic

huxihx created KAFKA-7279: - Summary: partitionsFor implicitly creates topic for the existent topic Key: KAFKA-7279 URL: https://issues.apache.org/jira/browse/KAFKA-7279 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-7211) MM should handle timeouts in commitSync

[ https://issues.apache.org/jira/browse/KAFKA-7211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16577844#comment-16577844 ] ASF GitHub Bot commented on KAFKA-7211: --- huxihx opened a new pull request #5492: KAFKA-7211: MM

[jira] [Assigned] (KAFKA-7211) MM should handle timeouts in commitSync

[ https://issues.apache.org/jira/browse/KAFKA-7211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx reassigned KAFKA-7211: - Assignee: huxihx > MM should handle timeouts in commitSync > --- >

[jira] [Commented] (KAFKA-7278) replaceSegments() should not call asyncDeleteSegment() for segments which have been removed from segments list

[ https://issues.apache.org/jira/browse/KAFKA-7278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16577735#comment-16577735 ] ASF GitHub Bot commented on KAFKA-7278: --- lindong28 opened a new pull request #5491: KAFKA-7278;

[jira] [Commented] (KAFKA-7278) replaceSegments() should not call asyncDeleteSegment() for segments which have been removed from segments list

[ https://issues.apache.org/jira/browse/KAFKA-7278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16577707#comment-16577707 ] Dong Lin commented on KAFKA-7278: - Yes `segment.changeFileSuffixes("", Log.DeletedFileSuffix)` is

[jira] [Commented] (KAFKA-7278) replaceSegments() should not call asyncDeleteSegment() for segments which have been removed from segments list

[ https://issues.apache.org/jira/browse/KAFKA-7278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16577706#comment-16577706 ] Dong Lin commented on KAFKA-7278: - [~ijuma] The exception is probably thrown from

[jira] [Updated] (KAFKA-7255) Timing issue in SimpleAclAuthorizer with concurrent create/update

[ https://issues.apache.org/jira/browse/KAFKA-7255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram updated KAFKA-7255: -- Reviewer: Jun Rao > Timing issue in SimpleAclAuthorizer with concurrent create/update >

[jira] [Resolved] (KAFKA-7261) Request and response total metrics record bytes instead of request count

[ https://issues.apache.org/jira/browse/KAFKA-7261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-7261. --- Resolution: Fixed Reviewer: Jun Rao Fix Version/s: 2.1.0

[jira] [Resolved] (KAFKA-7255) Timing issue in SimpleAclAuthorizer with concurrent create/update

[ https://issues.apache.org/jira/browse/KAFKA-7255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-7255. --- Resolution: Fixed > Timing issue in SimpleAclAuthorizer with concurrent create/update >

[jira] [Commented] (KAFKA-7261) Request and response total metrics record bytes instead of request count

[ https://issues.apache.org/jira/browse/KAFKA-7261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16577689#comment-16577689 ] ASF GitHub Bot commented on KAFKA-7261: --- rajinisivaram closed pull request #5484: KAFKA-7261: Fix

[jira] [Commented] (KAFKA-7269) KStream.merge is not documented

[ https://issues.apache.org/jira/browse/KAFKA-7269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16577626#comment-16577626 ] Guozhang Wang commented on KAFKA-7269: -- [~lucapette] that is right. More specifically, you'll need

[jira] [Commented] (KAFKA-7269) KStream.merge is not documented

[ https://issues.apache.org/jira/browse/KAFKA-7269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16577507#comment-16577507 ] Luca Pette commented on KAFKA-7269: --- [~mjsax] I'd be happy to write docs for merge (I agree it fits

[jira] [Commented] (KAFKA-7278) replaceSegments() should not call asyncDeleteSegment() for segments which have been removed from segments list

[ https://issues.apache.org/jira/browse/KAFKA-7278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16577484#comment-16577484 ] Ismael Juma commented on KAFKA-7278: Can you please clarify which part of the code is the problem?