Sample JSON Payloads Reference

{
  "name": "Journey Events to Kafka",
  "description": "Publishes journey events to Kafka topic",
  "templateId": 1,
  "messageConfig": {
    "payloadEntrySourceCode": "ES-001"
  },
  "feedAttributeMapping": [
    {
      "feedId": 1,
      "attributes": {
        "profile": {
          "customerId": "CUSTOMER_ID",
          "email": "EMAIL_ADDRESS"
        },
        "tuple": {
          "eventId": "EVENT_ID",
          "timestamp": "EVENT_TIMESTAMP"
        }
      }
    }
  ],
  "connectorConfig": {
    "kafka": {
      "connectorType": "KAFKA",
      "topic": "journey-events-topic",
      "clusterName": "primary-kafka-cluster"
    }
  }
}

{
  "name": "Interact Offers Multi-Connector",
  "description": "Sends offers to Interact via Kafka and logs to database",
  "templateId": 2,
  "messageConfig": {
    "audienceIdAttributeName": "ACCOUNTID",
    "campaignIdAttributeName": "offerCode",
    "customerKeyFieldName": "MSISDN",
"dateTimeAttributeName" : "ts",
    "eventParamEventName": "event",
    "eventParamInboundChannelName": "inbound_channel",
    "eventParamInboundChannelValue": "mobile",
    "payloadChDebugValue": "false",
    "payloadGatewayValue": "InboundGateway",
    "payloadIcNameValue": "InteractProd"
  },
  "feedAttributeMapping": [
    {
      "feedId": "MobileEngagementFeed",
      "attributes": {
        "profile": {
          "accountId": "ACCOUNT_ID",
          "msisdn": "MOBILE_NUMBER"
        },
        "tuple": {
          "eventId": "EVENT_ID",
          "offerCode": "OFFER_CODE",
          "channel": "CHANNEL"
        }
      }
    }
  ],
  "connectorConfig": {
    "kafka": {
      "connectorType": "KAFKA",
      "topic": "interact-offers",
      "clusterName": "prod-kafka-cluster"
    },
    "mariaDb": {
      "connectorType": "MARIADB",
      "datasourceName": "INTERACT_DATASOURCE",
      "databaseName": "interact_audit"
    }
  }
}

{
  "name": "Omnichannel Event Publisher",
  "description": "Publishes events to Kafka and database simultaneously",
  "templateId": 1,
  "messageConfig": {
    "payloadEntrySourceCode": "ES-OMNI"
  },
  "feedAttributeMapping": [
    {
      "feedId": "OmnichannelFeed",
      "attributes": {
        "profile": {
          "userId": "USER_ID",
          "userName": "USER_NAME",
          "email": "EMAIL"
        },
        "tuple": {
          "eventId": "EVENT_ID",
          "eventType": "TYPE",
          "channel": "CHANNEL",
          "timestamp": "TIMESTAMP"
        }
      }
    }
  ],
  "connectorConfig": {
    "kafka": {
      "connectorType": "KAFKA",
      "topic": "omnichannel-events",
      "clusterName": "primary-kafka-cluster"
    },
    "mariaDb": {
      "connectorType": "MARIADB",
      "datasourceName": "AUDIT_DATASOURCE",
      "databaseName": "event_audit_db"
    }
  }
}