diff --git a/mod-pubsub-server/src/main/java/org/folio/services/impl/StartupServiceImpl.java b/mod-pubsub-server/src/main/java/org/folio/services/impl/StartupServiceImpl.java
index ed4814b6..00caa1b9 100644
--- a/mod-pubsub-server/src/main/java/org/folio/services/impl/StartupServiceImpl.java
+++ b/mod-pubsub-server/src/main/java/org/folio/services/impl/StartupServiceImpl.java
@@ -13,6 +13,7 @@
 import org.springframework.stereotype.Component;
 
 import java.util.Collections;
+import java.util.HashMap;
 
 import static org.folio.rest.jaxrs.model.MessagingModule.ModuleRole.SUBSCRIBER;
 
@@ -45,6 +46,7 @@ public void initSubscribers() {
           OkapiConnectionParams params = new OkapiConnectionParams(vertx);
           params.setOkapiUrl(kafkaConfig.getOkapiUrl());
           params.setTenantId(messagingModule.getTenantId());
+          params.setHeaders(new HashMap<>());
           kafkaTopicService.createTopics(Collections.singletonList(messagingModule.getEventType()), messagingModule.getTenantId())
             .compose(ar -> consumerService.subscribe(Collections.singletonList(messagingModule.getEventType()), params));
         });