diff --git a/commons/src/main/java/com/stratio/streaming/commons/kafka/service/TopicService.java b/commons/src/main/java/com/stratio/streaming/commons/kafka/service/TopicService.java
index <HASH>..<HASH> 100644
--- a/commons/src/main/java/com/stratio/streaming/commons/kafka/service/TopicService.java
+++ b/commons/src/main/java/com/stratio/streaming/commons/kafka/service/TopicService.java
@@ -15,7 +15,9 @@
  */
 package com.stratio.streaming.commons.kafka.service;
 
-public interface TopicService {
+import java.io.Closeable;
+
+public interface TopicService extends Closeable {
 
     void createTopicIfNotExist(String topic, int replicationFactor, int partitions);
added new nethods to IStratioStreamingApi trait: withServerConfig, init, and close.