Filter topics out based on committer (#2)

* Filter topics out based on committer

* Deleting topic filter factory, renaming variables

src/main/scala/com/box/castle/committer/api/CommitterFactory.scala

@@ -112,6 +112,15 @@ trait CommitterFactory extends Closeable {
    */
   def createCommitterExceptionRetryStrategy: RetryStrategy = DefaultRecoverableExceptionRetryStrategy
 
+  /**
+    * Creates a filter which would filter topics that the committer should process
+    *
+    * @return
+    */
+  def createTopicFilter(): TopicFilter = {
+    new TopicFilter()
+  }
+
   val DefaultNoDataBackoffStrategy =
     RandomMinMaxStrategy(FiniteDuration(5, TimeUnit.SECONDS), FiniteDuration(10, TimeUnit.SECONDS))
 

src/main/scala/com/box/castle/committer/api/TopicFilter.scala

@@ -0,0 +1,11 @@
+package com.box.castle.committer.api
+
+/**
+  * Created by bravishanker on 7/7/17.
+  */
+class TopicFilter {
+
+  def matches(topic: String): Boolean = {
+    true
+  }
+}

version.sbt

@@ -1 +1 @@
-version := "1.0.0"
+version := "1.0.1"