[jira] [Commented] (KAFKA-6489) Fetcher.retrieveOffsetsByTimes() should add all the topics to the metadata refresh topics set.

2018-01-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16340588#comment-16340588 ] ASF GitHub Bot commented on KAFKA-6489: --- becketqin opened a new pull request #4478:

[jira] [Commented] (KAFKA-6489) Fetcher.retrieveOffsetsByTimes() should add all the topics to the metadata refresh topics set.

2018-01-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16340587#comment-16340587 ] ASF GitHub Bot commented on KAFKA-6489: --- becketqin closed pull request #4478: KAFKA-

[jira] [Commented] (KAFKA-6321) ConsumerGroupCommand should use the new consumer to query the log end offsets.

2018-01-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16340567#comment-16340567 ] ASF GitHub Bot commented on KAFKA-6321: --- becketqin closed pull request #4344: KAFKA-

[jira] [Commented] (KAFKA-4897) LogCleaner#cleanSegments should not ignore failures to delete files

2018-01-25 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16340560#comment-16340560 ] Ismael Juma commented on KAFKA-4897: [~hachikuji], looks like the PR had the wrong Jir

[jira] [Created] (KAFKA-6489) Fetcher.retrieveOffsetsByTimes() should add all the topics to the metadata refresh topics set.

2018-01-25 Thread Jiangjie Qin (JIRA)
Jiangjie Qin created KAFKA-6489: --- Summary: Fetcher.retrieveOffsetsByTimes() should add all the topics to the metadata refresh topics set. Key: KAFKA-6489 URL: https://issues.apache.org/jira/browse/KAFKA-6489

[jira] [Updated] (KAFKA-6486) TimeWindows causes unordered calls to windowed aggregation functions

2018-01-25 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6486: --- Issue Type: Improvement (was: Bug) > TimeWindows causes unordered calls to windowed aggregati

[jira] [Commented] (KAFKA-6451) Simplify KStreamReduce

2018-01-25 Thread Tanvi Jaywant (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16340336#comment-16340336 ] Tanvi Jaywant commented on KAFKA-6451: -- [https://github.com/apache/kafka/pull/4477]

[jira] [Commented] (KAFKA-6451) Simplify KStreamReduce

2018-01-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16340333#comment-16340333 ] ASF GitHub Bot commented on KAFKA-6451: --- tanvijaywant31 opened a new pull request #4

[jira] [Commented] (KAFKA-5886) Introduce delivery.timeout.ms producer config (KIP-91)

2018-01-25 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16340295#comment-16340295 ] Jun Rao commented on KAFKA-5886: https://github.com/apache/kafka/pull/3849 > Introduce de

[jira] [Updated] (KAFKA-6483) Support ExtendedSerializer in Kafka Streams

2018-01-25 Thread Tamas Cserveny (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tamas Cserveny updated KAFKA-6483: -- Affects Version/s: (was: 0.11.0.0) 1.0.0 Fix Version/s: (w

[jira] [Updated] (KAFKA-6483) Support ExtendedSerializer in Kafka Streams

2018-01-25 Thread Tamas Cserveny (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tamas Cserveny updated KAFKA-6483: -- Flags: (was: Patch) > Support ExtendedSerializer in Kafka Streams > --

[jira] [Created] (KAFKA-6488) Prevent log corruption in case of OOM

2018-01-25 Thread Dong Lin (JIRA)
Dong Lin created KAFKA-6488: --- Summary: Prevent log corruption in case of OOM Key: KAFKA-6488 URL: https://issues.apache.org/jira/browse/KAFKA-6488 Project: Kafka Issue Type: Bug Reporte

[jira] [Updated] (KAFKA-6487) ChangeLoggingKeyValueBytesStore.all() returns null

2018-01-25 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-6487: --- Description: The  {{ChangeLoggingKeyValueBytesStore}} implements the {{KeyValueStore}} interface whic

[jira] [Updated] (KAFKA-4897) LogCleaner#cleanSegments should not ignore failures to delete files

2018-01-25 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-4897: --- Fix Version/s: 1.1.0 > LogCleaner#cleanSegments should not ignore failures to delete files > -

[jira] [Resolved] (KAFKA-4897) LogCleaner#cleanSegments should not ignore failures to delete files

2018-01-25 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-4897. Resolution: Fixed > LogCleaner#cleanSegments should not ignore failures to delete files > --

[jira] [Commented] (KAFKA-4897) LogCleaner#cleanSegments should not ignore failures to delete files

2018-01-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16339844#comment-16339844 ] ASF GitHub Bot commented on KAFKA-4897: --- hachikuji closed pull request #4393: KAFKA-

[jira] [Commented] (KAFKA-6254) Introduce Incremental FetchRequests to Increase Partition Scalability

2018-01-25 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16339830#comment-16339830 ] Jun Rao commented on KAFKA-6254: https://github.com/apache/kafka/pull/4418 > Introduce In

[jira] [Created] (KAFKA-6487) ChangeLoggingKeyValueBytesStore.all() returns null

2018-01-25 Thread Bill Bejeck (JIRA)
Bill Bejeck created KAFKA-6487: -- Summary: ChangeLoggingKeyValueBytesStore.all() returns null Key: KAFKA-6487 URL: https://issues.apache.org/jira/browse/KAFKA-6487 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-6388) Error while trying to roll a segment that already exists

2018-01-25 Thread Paul Davidson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16339667#comment-16339667 ] Paul Davidson commented on KAFKA-6388: -- We saw the same issue after an upgrade from 0

[jira] [Resolved] (KAFKA-6429) dirtyNonActiveSegments in `cleanableOffsets` should only be created when log.cleaner.min.compaction.lag.ms > 0

2018-01-25 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6429. Resolution: Fixed > dirtyNonActiveSegments in `cleanableOffsets` should only be created when

[jira] [Resolved] (KAFKA-6091) Authorization API is called hundred's of times when there are no privileges

2018-01-25 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6091. -- Resolution: Fixed Fixed via KAFKA-5547. Please reopen if you think the issue still exists > Authorizati

[jira] [Resolved] (KAFKA-4185) Abstract out password verifier in SaslServer as an injectable dependency

2018-01-25 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-4185. -- Resolution: Duplicate Closing this in favor of KIP-86/KAFKA-4292. Please reopen if you think otherwise

[jira] [Resolved] (KAFKA-3408) consumer rebalance fail

2018-01-25 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3408. -- Resolution: Auto Closed Closing inactive issue. The old consumer is no longer supported, please upgrade

[jira] [Resolved] (KAFKA-5617) Update to the list of third-party clients

2018-01-25 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-5617. -- Resolution: Fixed > Update to the list of third-party clients >

[jira] [Resolved] (KAFKA-5500) it is impossible to have custom Login Modules for PLAIN SASL mechanism

2018-01-25 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-5500. -- Resolution: Duplicate Closing in favor of KIP-88/KAFKA-4292.  Please reopen if you think otherwise. > i

[jira] [Created] (KAFKA-6486) TimeWindows causes unordered calls to windowed aggregation functions

2018-01-25 Thread Valentino Proietti (JIRA)
Valentino Proietti created KAFKA-6486: - Summary: TimeWindows causes unordered calls to windowed aggregation functions Key: KAFKA-6486 URL: https://issues.apache.org/jira/browse/KAFKA-6486 Project:

[jira] [Resolved] (KAFKA-1458) kafka hanging on shutdown

2018-01-25 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1458. -- Resolution: Auto Closed {color:#00}Closing inactive issue. Please reopen if you think the issue sti

[jira] [Resolved] (KAFKA-1475) Kafka consumer stops LeaderFinder/FetcherThreads, but application does not know

2018-01-25 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1475. -- Resolution: Auto Closed Closing inactive issue. The old consumer is no longer supported. > Kafka consum

[jira] [Resolved] (KAFKA-4256) Use IP for ZK broker register

2018-01-25 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-4256. -- Resolution: Won't Fix Closing as per above comment. Pls reopen If the issue still exists. > Use IP for

[jira] [Commented] (KAFKA-6485) 'ConsumerGroupCommand' performance optimization for old consumer describe group

2018-01-25 Thread HongLiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16339313#comment-16339313 ] HongLiang commented on KAFKA-6485: -- https://github.com/apache/kafka/pull/4475#partial-pul

[jira] [Updated] (KAFKA-6485) 'ConsumerGroupCommand' performance optimization for old consumer describe group

2018-01-25 Thread HongLiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] HongLiang updated KAFKA-6485: - Description: ConsumerGroupCommand describegroup performance optimization. performance improvement 3 times

[jira] [Updated] (KAFKA-6485) 'ConsumerGroupCommand' performance optimization for old consumer describe group

2018-01-25 Thread HongLiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] HongLiang updated KAFKA-6485: - External issue URL: https://github.com/apache/kafka/pull/4475 > 'ConsumerGroupCommand' performance optimiz

[jira] [Updated] (KAFKA-6485) 'ConsumerGroupCommand' performance optimization for old consumer describe group

2018-01-25 Thread HongLiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] HongLiang updated KAFKA-6485: - Attachment: 75a51a9f-d2c3-47fa-81d3-519343aa4d84.png 1ada9efa5-850a-4495-83b6-9a28f8885512.

[jira] [Created] (KAFKA-6485) 'ConsumerGroupCommand' performance optimization for old consumer describe group

2018-01-25 Thread HongLiang (JIRA)
HongLiang created KAFKA-6485: Summary: 'ConsumerGroupCommand' performance optimization for old consumer describe group Key: KAFKA-6485 URL: https://issues.apache.org/jira/browse/KAFKA-6485 Project: Kafka

[jira] [Created] (KAFKA-6484) 'ConsumerGroupCommand' performance optimization for old consumer describe group

2018-01-25 Thread HongLiang (JIRA)
HongLiang created KAFKA-6484: Summary: 'ConsumerGroupCommand' performance optimization for old consumer describe group Key: KAFKA-6484 URL: https://issues.apache.org/jira/browse/KAFKA-6484 Project: Kafka

[jira] [Updated] (KAFKA-6482) when produce send a invalidity timestamps, broker will be not delete retention files

2018-01-25 Thread HongLiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] HongLiang updated KAFKA-6482: - Issue Type: Bug (was: Improvement) > when produce send a invalidity timestamps, broker will be not delete

[jira] [Updated] (KAFKA-6482) when produce send a invalidity timestamps, broker will be not delete retention files

2018-01-25 Thread HongLiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] HongLiang updated KAFKA-6482: - Issue Type: Improvement (was: Bug) > when produce send a invalidity timestamps, broker will be not delete

[jira] [Assigned] (KAFKA-5581) Avoid creating changelog topics for state stores that are materialized from a source topic

2018-01-25 Thread Jeyhun Karimov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeyhun Karimov reassigned KAFKA-5581: - Assignee: Jeyhun Karimov > Avoid creating changelog topics for state stores that are mate

[jira] [Commented] (KAFKA-6483) Support ExtendedSerializer in Kafka Streams

2018-01-25 Thread Tamas Cserveny (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16339204#comment-16339204 ] Tamas Cserveny commented on KAFKA-6483: --- This is one spot which does not use upcast

[jira] [Updated] (KAFKA-6483) Support ExtendedSerializer in Kafka Streams

2018-01-25 Thread Tamas Cserveny (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tamas Cserveny updated KAFKA-6483: -- Description: KIP-82 introduced the concept of message headers and introduced an ExtendedDeseria

[jira] [Created] (KAFKA-6483) Support ExtendedSerializer in Kafka Streams

2018-01-25 Thread Tamas Cserveny (JIRA)
Tamas Cserveny created KAFKA-6483: - Summary: Support ExtendedSerializer in Kafka Streams Key: KAFKA-6483 URL: https://issues.apache.org/jira/browse/KAFKA-6483 Project: Kafka Issue Type: Impro

[jira] [Comment Edited] (KAFKA-6035) Avoid creating changelog topics for state stores that are directly piped to a sink topic

2018-01-25 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16339071#comment-16339071 ] Ted Yu edited comment on KAFKA-6035 at 1/25/18 11:26 AM: - Since th

[jira] [Commented] (KAFKA-6482) when produce send a invalidity timestamps, broker will be not delete retention files

2018-01-25 Thread HongLiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16339100#comment-16339100 ] HongLiang commented on KAFKA-6482: -- [~huxi_2b] 谢谢你的回复,但我觉得modifyfileitme至少比客户端传过来的timesta

[jira] [Commented] (KAFKA-6035) Avoid creating changelog topics for state stores that are directly piped to a sink topic

2018-01-25 Thread Jeyhun Karimov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16339090#comment-16339090 ] Jeyhun Karimov commented on KAFKA-6035: --- it is already attached to the issue.  > Av

[jira] [Commented] (KAFKA-6035) Avoid creating changelog topics for state stores that are directly piped to a sink topic

2018-01-25 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16339071#comment-16339071 ] Ted Yu commented on KAFKA-6035: --- Can you post the link to the pull request ? > Avoid creati

[jira] [Closed] (KAFKA-6180) Add a Validator for NonNull configurations and remove redundant null checks on lists

2018-01-25 Thread Charly Molter (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Charly Molter closed KAFKA-6180. > Add a Validator for NonNull configurations and remove redundant null checks > on lists >

[jira] [Commented] (KAFKA-6482) when produce send a invalidity timestamps, broker will be not delete retention files

2018-01-25 Thread huxihx (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16339007#comment-16339007 ] huxihx commented on KAFKA-6482: --- [~HongLiang] AFAIK, lastModified is vulnerable whereas time

[jira] [Commented] (KAFKA-6482) when produce send a invalidity timestamps, broker will be not delete retention files

2018-01-25 Thread HongLiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16339001#comment-16339001 ] HongLiang commented on KAFKA-6482: -- when producer set timestamp's unit is Microsecond. bu

[jira] [Comment Edited] (KAFKA-6482) when produce send a invalidity timestamps, broker will be not delete retention files

2018-01-25 Thread HongLiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16338977#comment-16338977 ] HongLiang edited comment on KAFKA-6482 at 1/25/18 9:47 AM: --- [~hu

[jira] [Comment Edited] (KAFKA-6482) when produce send a invalidity timestamps, broker will be not delete retention files

2018-01-25 Thread HongLiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16338977#comment-16338977 ] HongLiang edited comment on KAFKA-6482 at 1/25/18 9:36 AM: --- [~hu

[jira] [Comment Edited] (KAFKA-6482) when produce send a invalidity timestamps, broker will be not delete retention files

2018-01-25 Thread HongLiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16338977#comment-16338977 ] HongLiang edited comment on KAFKA-6482 at 1/25/18 9:27 AM: --- [~hu

[jira] [Commented] (KAFKA-6035) Avoid creating changelog topics for state stores that are directly piped to a sink topic

2018-01-25 Thread Jeyhun Karimov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16338981#comment-16338981 ] Jeyhun Karimov commented on KAFKA-6035: --- [~Yohan123] I don't know why jira didnt't a

[jira] [Commented] (KAFKA-6482) when produce send a invalidity timestamps, broker will be not delete retention files

2018-01-25 Thread HongLiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16338977#comment-16338977 ] HongLiang commented on KAFKA-6482: -- [~huxi_2b] data retention is 48 hours, but 5 days's d

[jira] [Commented] (KAFKA-6482) when produce send a invalidity timestamps, broker will be not delete retention files

2018-01-25 Thread huxihx (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16338976#comment-16338976 ] huxihx commented on KAFKA-6482: --- Do you mean that the log segment after being appended a mes

[jira] [Updated] (KAFKA-6482) when produce send a invalidity timestamps, broker will be not delete retention files

2018-01-25 Thread HongLiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] HongLiang updated KAFKA-6482: - Attachment: delete_retention_bug.diff > when produce send a invalidity timestamps, broker will be not dele

[jira] [Commented] (KAFKA-6482) when produce send a invalidity timestamps, broker will be not delete retention files

2018-01-25 Thread HongLiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16338947#comment-16338947 ] HongLiang commented on KAFKA-6482: -- https://github.com/apache/kafka/pull/4473/files > wh

[jira] [Updated] (KAFKA-6482) when produce send a invalidity timestamps, broker will be not delete retention files

2018-01-25 Thread HongLiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] HongLiang updated KAFKA-6482: - External issue URL: https://github.com/apache/kafka/pull/4473 > when produce send a invalidity timestamps,

[jira] [Created] (KAFKA-6482) when produce send a invalidity timestamps, broker will be not delete retention files

2018-01-25 Thread HongLiang (JIRA)
HongLiang created KAFKA-6482: Summary: when produce send a invalidity timestamps, broker will be not delete retention files Key: KAFKA-6482 URL: https://issues.apache.org/jira/browse/KAFKA-6482 Project: K