[ 
https://issues.apache.org/jira/browse/KAFKA-10889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17255480#comment-17255480
 ] 

Wenbing Shen edited comment on KAFKA-10889 at 12/28/20, 9:24 AM:
-----------------------------------------------------------------

The problem appears to be related to this kip:

[https://cwiki.apache.org/confluence/display/KAFKA/KIP-32+-+Add+timestamps+to+Kafka+message]

Related to these two configurations:

message.timestamp.type=CreateTime

message.timestamp.difference.max.ms=Long.MAXVALUE

The client generated messages which timestamp is 2020-12-26 14:49:32,this 
results in a period before 2021-01-02 14:49:32,all log segments of this 
partition will not be deleted.

 

!image-2020-12-28-17-17-15-947.png!


was (Author: wenbing.shen):
[https://cwiki.apache.org/confluence/display/KAFKA/KIP-32+-+Add+timestamps+to+Kafka+message]

message.timestamp.type
max.message.time.difference.ms

> The log cleaner is not working for topic partitions
> ---------------------------------------------------
>
>                 Key: KAFKA-10889
>                 URL: https://issues.apache.org/jira/browse/KAFKA-10889
>             Project: Kafka
>          Issue Type: Bug
>          Components: log cleaner
>    Affects Versions: 2.0.0
>            Reporter: Wenbing Shen
>            Assignee: Wenbing Shen
>            Priority: Blocker
>         Attachments: 0880c08b0110fcdd9b0c.png, 0880c08b0110fcddfb0b.png, 
> image-2020-12-28-17-17-15-947.png
>
>
> * I have a topic that is reserved for the default of 7 days, but the log 
> exists from October 26th to December 25th today.The log cleaner doesn't seem 
> to be working on it.This seems to be an underlying problem in Kafka.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to