[
https://issues.apache.org/jira/browse/SAMZA-223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13962271#comment-13962271
]
Martin Kleppmann commented on SAMZA-223:
----------------------------------------
Oops, rebasing this commit onto master broke the build (sorry), because of the
different version of ScalaTest. I've pushed a follow-up commit to fix it.
> Add a cache for stream metadata
> -------------------------------
>
> Key: SAMZA-223
> URL: https://issues.apache.org/jira/browse/SAMZA-223
> Project: Samza
> Issue Type: Improvement
> Reporter: Martin Kleppmann
> Assignee: Martin Kleppmann
> Attachments: SAMZA-223.1.patch
>
>
> As part of SAMZA-179 I wrote a cache to reduce the number of calls to
> SystemAdmin.getSystemStreamMetadata (which go to the broker). It's currently
> unclear whether we still want to use the stream metadata to determine whether
> a task is caught up, so I've split the StreamMetadataCache out of SAMZA-179,
> and made it a standalone patch. This patch doesn't contain any of the job
> shutdown stuff, only the metadata caching.
> Admittedly there's less of a need for this cache if we're not requesting
> stream metadata within tasks, so perhaps we should just throw this code away.
> But it may also be useful, and certainly shouldn't do any harm. What do you
> think?
--
This message was sent by Atlassian JIRA
(v6.2#6252)
