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

Neha Narkhede commented on KAFKA-560:
-------------------------------------

OffsetRequest will not give you the time, but the offsets since a time 
(approximately). 

However, the original proposal for TopicMetadataRequest had a field for last 
modified timestamp per partition - 


/**
 * topic (2 bytes + topic.length)
 * number of partitions (4 bytes)
 *
 * partition id (4 bytes)
 *
 * does leader exist (1 byte)
 * leader info (4 + creator.length + host.length + 4 (port) + 4 (id))
 * number of replicas (2 bytes)
 * replica info (4 + creator.length + host.length + 4 (port) + 4 (id))
 * number of in sync replicas (2 bytes)
 * replica info (4 + creator.length + host.length + 4 (port) + 4 (id))
 *
 * does log metadata exist (1 byte)
 * number of log segments (4 bytes)
 * total size of log in bytes (8 bytes)
 *
 * number of log segments (4 bytes)
 * beginning offset (8 bytes)
 * last modified timestamp (8 bytes)
 * size of log segment (8 bytes)
 *
 */

However, we haven't really implemented the last few fields of this request, 
simply because we couldn't think of a use case. But what you describe seems 
useful and maybe we should file a JIRA to get the log segment portion of 
TopicMetadatRequest. 

                
> Garbage Collect obsolete topics
> -------------------------------
>
>                 Key: KAFKA-560
>                 URL: https://issues.apache.org/jira/browse/KAFKA-560
>             Project: Kafka
>          Issue Type: New Feature
>            Reporter: Jay Kreps
>
> Old junk topics tend to accumulate over time. Code may migrate to use new 
> topics leaving the old ones orphaned. Likewise there are some use cases for 
> temporary transient topics. It would be good to have a tool that could delete 
> any topic that had not been written to in a configurable period of time and 
> had no active consumer groups. Something like
>    ./bin/delete-unused-topics.sh --last-write [date] --zookeeper [zk_connect]
> This requires API support to get the last update time. I think it may be 
> possible to do this through the OffsetRequest now?

--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira

Reply via email to