first commit

src/main/java/microservice/service/pubsub/common/microservice/params/KafkaParams.java

+package common.microservice.params;
+
+public class KafkaParams {
+
+}

src/main/java/microservice/service/pubsub/service/microservice/IPubSubServiceKafkaImpl.java

+package service.microservice;
+
+import common.microservice.io.iface.IApp;
+import common.microservice.io.iface.IServiceDiscovery;
+import common.microservice.params.KafkaParams;
+import common.microservice.services.CommonServices;
+
+import java.util.function.Consumer;
+
+public class IPubSubServiceKafkaImpl extends CommonServices.IPubSubService {
+
+    private KafkaParams kafkaParams;
+
+    @Override
+    public boolean init(IApp app) {
+        return false;
+    }
+
+    @Override
+    public void run() {
+
+    }
+
+    @Override
+    public void shutdown() {
+
+    }
+
+    @Override
+    public void handleNotImplmented(CommonServices.IMsgContext msgContext) {
+
+    }
+
+    @Override
+    public void register(IServiceDiscovery serviceDiscovery, String id) {
+
+    }
+
+    @Override
+    public void subscribe(String topic, Consumer<PubSubMsgContext> notifyFunc, Consumer<String> errorFunc) {
+
+    }
+
+    @Override
+    public void unsubscribe(String topic) {
+
+    }
+
+    @Override
+    public void publish(PubSubMsgContext pubSubMsgContext) {
+
+    }
+}