[
https://issues.apache.org/jira/browse/SAMZA-2676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jon Bringhurst updated SAMZA-2676:
----------------------------------
Description:
{{noformat}}
public Set<SystemStream> getSerdeStreams(String systemName) {
Config subConf = subset(String.format("systems.%s.streams.", systemName,
true));
Set<SystemStream> legacySystemStreams = subConf.keySet().stream()
.filter(k -> k.endsWith(MSG_SERDE) || k.endsWith(KEY_SERDE))
{{noformat}}
Note the extra unused parameter.
was:
{{ public Set<SystemStream> getSerdeStreams(String systemName) {
Config subConf = subset(String.format("systems.%s.streams.", systemName,
true));
Set<SystemStream> legacySystemStreams = subConf.keySet().stream()
.filter(k -> k.endsWith(MSG_SERDE) || k.endsWith(KEY_SERDE))}}
Note the extra unused parameter.
> Remove unused format string param (StreamConfig.getSerdeStreams)
> ----------------------------------------------------------------
>
> Key: SAMZA-2676
> URL: https://issues.apache.org/jira/browse/SAMZA-2676
> Project: Samza
> Issue Type: Improvement
> Reporter: Jon Bringhurst
> Assignee: Jon Bringhurst
> Priority: Trivial
>
> {{noformat}}
> public Set<SystemStream> getSerdeStreams(String systemName) {
> Config subConf = subset(String.format("systems.%s.streams.", systemName,
> true));
> Set<SystemStream> legacySystemStreams = subConf.keySet().stream()
> .filter(k -> k.endsWith(MSG_SERDE) || k.endsWith(KEY_SERDE))
> {{noformat}}
> Note the extra unused parameter.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
