Make KafkaSource getFilteredTopics method protected
The method was originally private, and it is useful to be able to
override it in subclasses, to redefine how to get topics to be processed.
@@ -792,7 +792,7 @@ public abstract class KafkaSource<S, D> extends EventBasedSource<S, D> {
/**
* Return topics to be processed filtered by job-level whitelist and blacklist.
*/
- private List<KafkaTopic> getFilteredTopics(SourceState state) {
+ protected List<KafkaTopic> getFilteredTopics(SourceState state) {
List<Pattern> blacklist = DatasetFilterUtils.getPatternList(state, TOPIC_BLACKLIST);
List<Pattern> whitelist = DatasetFilterUtils.getPatternList(state, TOPIC_WHITELIST);
return this.kafkaConsumerClient.get().getFilteredTopics(blacklist, whitelist);
