EmptyFilter.java

package kafka_tweetoscope.tweetsFilter;

import com.twitter.clientlib.model.Tweet;

public class EmptyFilter extends AbstractTweetFilter {

    public EmptyFilter(String inputTopic, String outputTopic, String bootstrapServer) {
        super(inputTopic, outputTopic, bootstrapServer);
    }

    @Override
    protected boolean filterTweet(Tweet tweet) {
        return true;
    }
    
}