CustomNamedSubscription.java

Go to the documentation of this file.

package org.openkilda.wfm.kafka;

import org.apache.commons.lang.StringUtils;
import org.apache.storm.kafka.spout.NamedSubscription;

import java.util.Collection;

public class CustomNamedSubscription extends NamedSubscription {

    public CustomNamedSubscription(Collection<String> topics) {
        super(topics);
    }

    public CustomNamedSubscription(String... topics) {
        super(topics);
    }

    @Override
    public String getTopicsString() {
        return StringUtils.join(this.topics, ",");
    }
}