[ 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