diff --git a/src/cdk/v2/destinations/ninetailed/config.js b/src/cdk/v2/destinations/ninetailed/config.js
new file mode 100644
index 0000000000..d7e6cb9cfa
--- /dev/null
+++ b/src/cdk/v2/destinations/ninetailed/config.js
@@ -0,0 +1,17 @@
+const { getMappingConfig } = require('../../../../v0/util');
+
+const ConfigCategories = {
+  GENERAL: {
+    type: 'general',
+    name: 'generalPayloadMapping',
+  },
+  CONTEXT: {
+    type: 'context',
+    name: 'contextMapping',
+  },
+};
+const MAX_BATCH_SIZE = 200; // Maximum number of events to send in a single batch
+const mappingConfig = getMappingConfig(ConfigCategories, __dirname);
+const batchEndpoint =
+  'https://experience.ninetailed.co/v2/organizations/{{organisationId}}/environments/{{environment}}/events';
+module.exports = { ConfigCategories, mappingConfig, batchEndpoint, MAX_BATCH_SIZE };
diff --git a/src/cdk/v2/destinations/ninetailed/data/contextMapping.json b/src/cdk/v2/destinations/ninetailed/data/contextMapping.json
new file mode 100644
index 0000000000..c08a092b32
--- /dev/null
+++ b/src/cdk/v2/destinations/ninetailed/data/contextMapping.json
@@ -0,0 +1,43 @@
+[
+  {
+    "sourceKeys": "context.app.name",
+    "required": true,
+    "destKey": "context.app.name"
+  },
+  {
+    "sourceKeys": "context.app.version",
+    "required": true,
+    "destKey": "context.app.version"
+  },
+  {
+    "sourceKeys": "context.campaign",
+    "destKey": "context.campaign"
+  },
+  {
+    "sourceKeys": "context.library.name",
+    "required": true,
+    "destKey": "context.library.name"
+  },
+  {
+    "sourceKeys": "context.library.version",
+    "required": true,
+    "destKey": "context.library.version"
+  },
+  {
+    "sourceKeys": "context.locale",
+    "destKey": "context.locale"
+  },
+  {
+    "sourceKeys": "context.page",
+    "destKey": "context.page"
+  },
+  {
+    "sourceKeys": "context.userAgent",
+    "destKey": "context.userAgent"
+  },
+  {
+    "sourceKeys": "context.location",
+    "required": true,
+    "destKey": "context.location"
+  }
+]
diff --git a/src/cdk/v2/destinations/ninetailed/data/generalPayloadMapping.json b/src/cdk/v2/destinations/ninetailed/data/generalPayloadMapping.json
new file mode 100644
index 0000000000..d25c3959f4
--- /dev/null
+++ b/src/cdk/v2/destinations/ninetailed/data/generalPayloadMapping.json
@@ -0,0 +1,35 @@
+[
+  {
+    "sourceKeys": "anonymousId",
+    "required": true,
+    "destKey": "anonymousId"
+  },
+  {
+    "sourceKeys": "messageId",
+    "required": true,
+    "destKey": "messageId"
+  },
+  {
+    "sourceKeys": "channel",
+    "required": true,
+    "destKey": "channel"
+  },
+  {
+    "sourceKeys": "properties",
+    "destKey": "properties"
+  },
+  {
+    "sourceKeys": "traits",
+    "sourceFromGenericMap": true,
+    "destKey": "traits"
+  },
+  {
+    "sourceKeys": "userIdOnly",
+    "sourceFromGenericMap": true,
+    "destKey": "userId"
+  },
+  {
+    "sourceKeys": "type",
+    "destKey": "type"
+  }
+]
diff --git a/src/cdk/v2/destinations/ninetailed/procWorkflow.yaml b/src/cdk/v2/destinations/ninetailed/procWorkflow.yaml
new file mode 100644
index 0000000000..7612abf49d
--- /dev/null
+++ b/src/cdk/v2/destinations/ninetailed/procWorkflow.yaml
@@ -0,0 +1,32 @@
+bindings:
+  - name: EventType
+    path: ../../../../constants
+  - path: ../../bindings/jsontemplate
+  - name: defaultRequestConfig
+    path: ../../../../v0/util
+  - name: removeUndefinedAndNullValues
+    path: ../../../../v0/util
+  - path: ./utils
+
+steps:
+  - name: messageType
+    template: |
+      .message.type.toLowerCase();
+  - name: validateInput
+    template: |
+      let messageType = $.outputs.messageType;
+      $.assert(messageType, "message Type is not present. Aborting");
+      $.assert(messageType in {{$.EventType.([.TRACK,.IDENITFY,.PAGE])}}, "message type " + messageType + " is not supported");
+      $.assertConfig(.destination.Config.organisationId, "Organisation ID is not present. Aborting");
+      $.assertConfig(.destination.Config.environment, "Environment is not present. Aborting");
+  - name: preparePayload
+    template: |
+      const payload = $.constructFullPayload(.message);
+      $.context.payload = $.removeUndefinedAndNullValues(payload);
+
+  - name: buildResponse
+    template: |
+      const response = $.defaultRequestConfig();
+      response.body.JSON = $.context.payload;
+      response.method = "POST";
+      response
diff --git a/src/cdk/v2/destinations/ninetailed/rtWorkflow.yaml b/src/cdk/v2/destinations/ninetailed/rtWorkflow.yaml
new file mode 100644
index 0000000000..2a3f760ccd
--- /dev/null
+++ b/src/cdk/v2/destinations/ninetailed/rtWorkflow.yaml
@@ -0,0 +1,58 @@
+bindings:
+  - path: ./config
+  - name: handleRtTfSingleEventError
+    path: ../../../../v0/util/index
+
+steps:
+  - name: validateInput
+    template: |
+      $.assert(Array.isArray(^) && ^.length > 0, "Invalid event array")
+
+  - name: transform
+    externalWorkflow:
+      path: ./procWorkflow.yaml
+    loopOverInput: true
+
+  - name: successfulEvents
+    template: |
+      $.outputs.transform#idx.output.({
+        "output": .,
+        "destination": ^[idx].destination,
+        "metadata": ^[idx].metadata
+      })[]
+  - name: failedEvents
+    template: |
+      $.outputs.transform#idx.error.(
+        $.handleRtTfSingleEventError(^[idx], .originalError ?? ., {})
+      )[]
+  - name: batchSuccessfulEvents
+    description: Batches the successfulEvents
+    template: |
+      let batches = $.chunk($.outputs.successfulEvents, $.MAX_BATCH_SIZE);
+      batches@batch.({
+        "batchedRequest": {
+          "body": {
+            "JSON": {"events": ~r batch.output[]},
+            "JSON_ARRAY": {},
+            "XML": {},
+            "FORM": {}
+          },
+          "version": "1",
+          "type": "REST",
+          "method": "POST",
+          "endpoint": {{$.ENDPOINT}},
+          "headers": batch[0].destination.Config.().({
+            "X-Algolia-Application-Id": .applicationId,
+            "X-Algolia-API-Key": .apiKey
+          }),
+          "params": {},
+          "files": {}
+        },
+        "metadata": ~r batch.metadata[],
+        "batched": true,
+        "statusCode": 200,
+        "destination": batch[0].destination
+      })[];
+  - name: finalPayload
+    template: |
+      [...$.outputs.failedEvents, ...$.outputs.batchSuccessfulEvents]
diff --git a/src/cdk/v2/destinations/ninetailed/utils.js b/src/cdk/v2/destinations/ninetailed/utils.js
new file mode 100644
index 0000000000..6240bd1f7a
--- /dev/null
+++ b/src/cdk/v2/destinations/ninetailed/utils.js
@@ -0,0 +1,17 @@
+const { mappingConfig, ConfigCategories } = require('./config');
+const { constructPayload } = require('../../../../v0/util');
+
+/**
+ * This fucntion constructs payloads based upon mappingConfig for all calls
+ * We build context as it has some specific payloads with default values so just breaking them down
+ * @param {*} message
+ * @returns
+ */
+const constructFullPayload = (message) => {
+  const context = constructPayload(message, mappingConfig[ConfigCategories.CONTEXT.name]);
+  const payload = constructPayload(message, mappingConfig[ConfigCategories.GENERAL.name]);
+  payload.context = context;
+  return payload;
+};
+
+module.exports = { constructFullPayload };