diff --git a/data-layers/data-layer-api-caller/pom.xml b/data-layers/data-layer-api-caller/pom.xml
new file mode 100644
index 0000000..b1a81ad
--- /dev/null
+++ b/data-layers/data-layer-api-caller/pom.xml
@@ -0,0 +1,65 @@
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+    <parent>
+        <artifactId>aesop</artifactId>
+        <groupId>com.flipkart.aesop</groupId>
+        <version>1.2.1-SNAPSHOT</version>
+        <relativePath>../../pom.xml</relativePath>
+    </parent>
+    <artifactId>data-layer-api-caller</artifactId>
+    <dependencies>
+        <dependency>
+            <groupId>org.springframework</groupId>
+            <artifactId>spring-jdbc</artifactId>
+            <version>${org.springframework.version}</version>
+        </dependency>
+        <!-- aesop dependencies -->
+        <dependency>
+            <groupId>com.flipkart.aesop</groupId>
+            <artifactId>runtime-client-cluster</artifactId>
+            <version>1.2.1-SNAPSHOT</version>
+        </dependency>
+        <dependency>
+            <groupId>com.flipkart.aesop</groupId>
+            <artifactId>client-event-consumer</artifactId>
+            <version>1.2.1-SNAPSHOT</version>
+        </dependency>
+        <dependency>
+            <groupId>com.google.code.gson</groupId>
+            <artifactId>gson</artifactId>
+            <version>2.2.2</version>
+        </dependency>
+        <dependency>
+            <groupId>flipkart.scm</groupId>
+            <artifactId>java-cas-client</artifactId>
+            <version>0.0.17.4-auth</version>
+        </dependency>
+        <dependency>
+            <groupId>com.ning</groupId>
+            <artifactId>async-http-client</artifactId>
+            <version>1.8.15</version>
+        </dependency>
+        <dependency>
+            <groupId>com.flipkart.kloud.authn</groupId>
+            <artifactId>client</artifactId>
+            <version>15.07.17.1</version>
+        </dependency>
+        <dependency>
+            <groupId>com.flipkart.kloud.authn</groupId>
+            <artifactId>dropwizard8-relying-party</artifactId>
+            <version>15.07.17.1</version>
+        </dependency>
+        <dependency>
+            <groupId>javax.ws.rs</groupId>
+            <artifactId>javax.ws.rs-api</artifactId>
+            <version>2.0</version>
+        </dependency>
+        <dependency>
+            <groupId>flipkart.platform</groupId>
+            <artifactId>prometheus</artifactId>
+            <version>2.3.2</version>
+        </dependency>
+    </dependencies>
+
+
+</project>
\ No newline at end of file
diff --git a/data-layers/data-layer-api-caller/src/main/java/com/flipkart/aesop/apicallerdatalayer/ApiCallerDataLayer.java b/data-layers/data-layer-api-caller/src/main/java/com/flipkart/aesop/apicallerdatalayer/ApiCallerDataLayer.java
new file mode 100644
index 0000000..87c6a2a
--- /dev/null
+++ b/data-layers/data-layer-api-caller/src/main/java/com/flipkart/aesop/apicallerdatalayer/ApiCallerDataLayer.java
@@ -0,0 +1,73 @@
+package com.flipkart.aesop.apicallerdatalayer;
+
+import com.flipkart.aesop.apicallerdatalayer.client.HttpPostClient;
+import com.flipkart.aesop.apicallerdatalayer.headers.ContextualHeaderProvider;
+import com.flipkart.aesop.apicallerdatalayer.headers.StaticHeaderProvider;
+import com.flipkart.aesop.event.AbstractEvent;
+import com.flipkart.aesop.processor.DestinationEventProcessor;
+import com.google.gson.Gson;
+import com.google.gson.GsonBuilder;
+import com.linkedin.databus.client.pub.ConsumerCallbackResult;
+import org.trpr.platform.core.impl.logging.LogFactory;
+import org.trpr.platform.core.spi.logging.Logger;
+
+import javax.naming.OperationNotSupportedException;
+import javax.ws.rs.core.Response;
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * Created by aman.gupta on 08/12/15.
+ */
+public class ApiCallerDataLayer implements DestinationEventProcessor{
+    private String url;
+    private StaticHeaderProvider staticHeaderProvider;
+    private ContextualHeaderProvider contextualHeaderProvider;
+    private HttpPostClient httpPostClient;
+    private static final Logger LOGGER = LogFactory.getLogger(ApiCallerDataLayer.class);
+
+    public void setStaticHeaderProvider(StaticHeaderProvider staticHeaderProvider) {
+        this.staticHeaderProvider = staticHeaderProvider;
+    }
+
+    public void setContextualHeaderProvider(ContextualHeaderProvider contextualHeaderProvider) {
+        this.contextualHeaderProvider = contextualHeaderProvider;
+    }
+
+    public void setHttpPostClient(HttpPostClient httpPostClient) {
+        this.httpPostClient = httpPostClient;
+    }
+
+    public void setUrl(String url) {
+        this.url = url;
+    }
+
+
+    @Override
+    public ConsumerCallbackResult processDestinationEvent(AbstractEvent destinationEvent) throws OperationNotSupportedException {
+        try {
+            Map<String, Object> eventMap = destinationEvent.getFieldMapPair();
+            Gson gson = new GsonBuilder().serializeNulls().create();
+            String payload = gson.toJson(eventMap);
+            Map<String, String> headers = new HashMap<String, String>();
+            headers.putAll(staticHeaderProvider.getHeaders());
+            headers.putAll(contextualHeaderProvider.getHeaders(eventMap));
+            headers.put("Content-Type", "application/json");
+            LOGGER.info("Making a post call to url: " + url + " with payload as: " + payload + " and headers as: " + headers);
+            Response response = httpPostClient.post(url, payload, headers);
+            int responseCode = response.getStatus();
+            if (responseCode >= 200 && responseCode < 300) {
+                LOGGER.info("Call successful with response code as " + responseCode + " for payload: " + payload);
+                return ConsumerCallbackResult.SUCCESS;
+            } else {
+                LOGGER.info("Call unsuccessful with response code as " + responseCode + " and message as " + response.readEntity(String.class) + " for payload: " + payload);
+                return ConsumerCallbackResult.ERROR;
+            }
+        }catch(Exception e){
+            LOGGER.error("Call unsuccessful with error: ",e);
+            return ConsumerCallbackResult.ERROR;
+        }
+    }
+
+
+}
diff --git a/data-layers/data-layer-api-caller/src/main/java/com/flipkart/aesop/apicallerdatalayer/client/HttpPostClient.java b/data-layers/data-layer-api-caller/src/main/java/com/flipkart/aesop/apicallerdatalayer/client/HttpPostClient.java
new file mode 100644
index 0000000..ab62fbc
--- /dev/null
+++ b/data-layers/data-layer-api-caller/src/main/java/com/flipkart/aesop/apicallerdatalayer/client/HttpPostClient.java
@@ -0,0 +1,15 @@
+package com.flipkart.aesop.apicallerdatalayer.client;
+
+
+import javax.ws.rs.core.Response;
+import java.util.Map;
+
+/**
+ * Created by aman.gupta on 09/12/15.
+ */
+public interface HttpPostClient {
+    //Request request = new Request(url,payload,headers);
+    //Response response = client.executePost(request);
+
+    public Response post(String url, String payload, Map<String,String> headers);
+}
diff --git a/data-layers/data-layer-api-caller/src/main/java/com/flipkart/aesop/apicallerdatalayer/client/implementation/HttpCASPostClientImpl.java b/data-layers/data-layer-api-caller/src/main/java/com/flipkart/aesop/apicallerdatalayer/client/implementation/HttpCASPostClientImpl.java
new file mode 100644
index 0000000..5d61f40
--- /dev/null
+++ b/data-layers/data-layer-api-caller/src/main/java/com/flipkart/aesop/apicallerdatalayer/client/implementation/HttpCASPostClientImpl.java
@@ -0,0 +1,37 @@
+package com.flipkart.aesop.apicallerdatalayer.client.implementation;
+
+import com.flipkart.aesop.apicallerdatalayer.client.HttpPostClient;
+import com.flipkart.casclient.client.HttpAuthClient;
+import com.flipkart.casclient.entity.Request;
+import flipkart.platform.cachefarm.Cache;
+import org.trpr.platform.core.impl.logging.LogFactory;
+import org.trpr.platform.core.spi.logging.Logger;
+
+import javax.ws.rs.core.Response;
+import java.io.IOException;
+import java.util.Map;
+
+/**
+ * Created by aman.gupta on 09/12/15.
+ */
+public class HttpCASPostClientImpl implements HttpPostClient {
+    private HttpAuthClient httpAuthClient;
+    private static final Logger LOGGER = LogFactory.getLogger(HttpCASPostClientImpl.class);
+    public HttpCASPostClientImpl(String casUrl, String user, String password, boolean enableAuth, Cache cache) {
+        this.httpAuthClient = new HttpAuthClient(casUrl,user,password,enableAuth,cache);
+    }
+
+    @Override
+    public Response post(String url, String payload, Map<String, String> headers) {
+        Request request = new Request(url,payload,headers);
+        com.ning.http.client.Response response = httpAuthClient.executePost(request);
+        String responseBody;
+        try {
+            responseBody = response.getResponseBody();
+        } catch (IOException e) {
+            LOGGER.error("Unable to get response body for payload"+payload+" Keeping it blank.",e);
+            responseBody = "";
+        }
+        return Response.status(response.getStatusCode()).entity(responseBody).build();
+    }
+}
diff --git a/data-layers/data-layer-api-caller/src/main/java/com/flipkart/aesop/apicallerdatalayer/client/implementation/HttpJavaxPostClientImpl.java b/data-layers/data-layer-api-caller/src/main/java/com/flipkart/aesop/apicallerdatalayer/client/implementation/HttpJavaxPostClientImpl.java
new file mode 100644
index 0000000..236cb7a
--- /dev/null
+++ b/data-layers/data-layer-api-caller/src/main/java/com/flipkart/aesop/apicallerdatalayer/client/implementation/HttpJavaxPostClientImpl.java
@@ -0,0 +1,28 @@
+package com.flipkart.aesop.apicallerdatalayer.client.implementation;
+
+
+import com.flipkart.aesop.apicallerdatalayer.client.HttpPostClient;
+import org.trpr.platform.core.impl.logging.LogFactory;
+import org.trpr.platform.core.spi.logging.Logger;
+
+import javax.ws.rs.client.Client;
+import javax.ws.rs.client.ClientBuilder;
+import javax.ws.rs.client.Entity;
+import javax.ws.rs.core.MediaType;
+import javax.ws.rs.core.Response;
+import java.util.Map;
+
+/**
+ * Created by aman.gupta on 10/12/15.
+ */
+public class HttpJavaxPostClientImpl implements HttpPostClient {
+    Client client = ClientBuilder.newClient();
+    private static final Logger LOGGER = LogFactory.getLogger(HttpJavaxPostClientImpl.class);
+    @Override
+    public Response post(String url, String payload, Map<String, String> headers) {
+
+        Response response = client.target(url).request().post(Entity.entity(payload, MediaType.APPLICATION_JSON_TYPE));
+        LOGGER.info(response.readEntity(String.class));
+        return response;
+    }
+}
diff --git a/data-layers/data-layer-api-caller/src/main/java/com/flipkart/aesop/apicallerdatalayer/headers/ContextualHeaderProvider.java b/data-layers/data-layer-api-caller/src/main/java/com/flipkart/aesop/apicallerdatalayer/headers/ContextualHeaderProvider.java
new file mode 100644
index 0000000..574d52b
--- /dev/null
+++ b/data-layers/data-layer-api-caller/src/main/java/com/flipkart/aesop/apicallerdatalayer/headers/ContextualHeaderProvider.java
@@ -0,0 +1,10 @@
+package com.flipkart.aesop.apicallerdatalayer.headers;
+
+import java.util.Map;
+
+/**
+ * Created by aman.gupta on 14/12/15.
+ */
+public interface ContextualHeaderProvider {
+    public Map<String, String> getHeaders(Map<String, Object> event);
+}
diff --git a/data-layers/data-layer-api-caller/src/main/java/com/flipkart/aesop/apicallerdatalayer/headers/StaticHeaderProvider.java b/data-layers/data-layer-api-caller/src/main/java/com/flipkart/aesop/apicallerdatalayer/headers/StaticHeaderProvider.java
new file mode 100644
index 0000000..0cc2c68
--- /dev/null
+++ b/data-layers/data-layer-api-caller/src/main/java/com/flipkart/aesop/apicallerdatalayer/headers/StaticHeaderProvider.java
@@ -0,0 +1,10 @@
+package com.flipkart.aesop.apicallerdatalayer.headers;
+
+import java.util.Map;
+
+/**
+ * Created by aman.gupta on 14/12/15.
+ */
+public interface StaticHeaderProvider {
+    public Map<String, String> getHeaders();
+}
diff --git a/data-layers/data-layer-api-caller/src/main/java/com/flipkart/aesop/apicallerdatalayer/headers/impl/StringBasedContextualHeaderProviderImpl.java b/data-layers/data-layer-api-caller/src/main/java/com/flipkart/aesop/apicallerdatalayer/headers/impl/StringBasedContextualHeaderProviderImpl.java
new file mode 100644
index 0000000..12f8888
--- /dev/null
+++ b/data-layers/data-layer-api-caller/src/main/java/com/flipkart/aesop/apicallerdatalayer/headers/impl/StringBasedContextualHeaderProviderImpl.java
@@ -0,0 +1,27 @@
+package com.flipkart.aesop.apicallerdatalayer.headers.impl;
+
+import com.flipkart.aesop.apicallerdatalayer.headers.ContextualHeaderProvider;
+import com.google.common.base.Splitter;
+
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * Created by aman.gupta on 14/12/15.
+ */
+public class StringBasedContextualHeaderProviderImpl implements ContextualHeaderProvider {
+    Map<String,String> headers;
+
+    public StringBasedContextualHeaderProviderImpl(String headers) {
+        this.headers = Splitter.on(",").withKeyValueSeparator("=").split(headers);
+    }
+
+    @Override
+    public Map<String, String> getHeaders(Map<String, Object> event) {
+        Map<String,String> map = new HashMap<String,String>();
+        for(Map.Entry<String,String> entry : headers.entrySet()){
+            map.put(entry.getKey(),(String)event.get(entry.getValue()));
+        }
+        return map;
+    }
+}
diff --git a/data-layers/data-layer-api-caller/src/main/java/com/flipkart/aesop/apicallerdatalayer/headers/impl/StringBasedStaticHeaderProviderImpl.java b/data-layers/data-layer-api-caller/src/main/java/com/flipkart/aesop/apicallerdatalayer/headers/impl/StringBasedStaticHeaderProviderImpl.java
new file mode 100644
index 0000000..2b21e7b
--- /dev/null
+++ b/data-layers/data-layer-api-caller/src/main/java/com/flipkart/aesop/apicallerdatalayer/headers/impl/StringBasedStaticHeaderProviderImpl.java
@@ -0,0 +1,22 @@
+package com.flipkart.aesop.apicallerdatalayer.headers.impl;
+
+import com.flipkart.aesop.apicallerdatalayer.headers.StaticHeaderProvider;
+import com.google.common.base.Splitter;
+
+import java.util.Map;
+
+/**
+ * Created by aman.gupta on 14/12/15.
+ */
+public class StringBasedStaticHeaderProviderImpl implements StaticHeaderProvider {
+    Map<String,String> headers;
+
+    public StringBasedStaticHeaderProviderImpl(String headers) {
+        this.headers = Splitter.on(",").withKeyValueSeparator("=").split(headers);
+    }
+
+    @Override
+    public Map<String, String> getHeaders() {
+        return headers;
+    }
+}
diff --git a/pom.xml b/pom.xml
index 3120078..937e6ef 100755
--- a/pom.xml
+++ b/pom.xml
@@ -90,6 +90,7 @@
         <module>data-layers/data-layer-console-appender</module>
         <module>data-layers/data-layer-elastic-search</module>
         <module>data-layers/data-layer-kafka</module>
+        <module>data-layers/data-layer-api-caller</module>
         <module>samples/sample-memory-relay</module>
         <module>samples/sample-hbase-relay</module>
         <module>samples/sample-mysql-mysql-blocking-bootstrap</module>
@@ -100,6 +101,7 @@
         <module>samples/sample-snapshot-serializer</module>
         <module>samples/sample-mysql-relay</module>
         <module>samples/sample-client-common</module>
+        <module>samples/sample-api-caller-client-cluster-consumer</module>
         <module>samples/sample-console-appender-client-cluster-consumer</module>
         <module>samples/sample-elastic-search-client-cluster-consumer</module>
         <module>samples/sample-hbase-client-cluster-consumer</module>
diff --git a/samples/sample-api-caller-client-cluster-consumer/pom.xml b/samples/sample-api-caller-client-cluster-consumer/pom.xml
new file mode 100644
index 0000000..42b4707
--- /dev/null
+++ b/samples/sample-api-caller-client-cluster-consumer/pom.xml
@@ -0,0 +1,186 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <artifactId>aesop</artifactId>
+        <groupId>com.flipkart.aesop</groupId>
+        <version>1.2.1-SNAPSHOT</version>
+        <relativePath>../../pom.xml</relativePath>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+    <groupId>com.flipkart.aesop</groupId>
+    <artifactId>sample-api-caller-client-cluster-consumer</artifactId>
+
+    <dependencies>
+        <dependency>
+            <groupId>com.flipkart.aesop</groupId>
+            <artifactId>runtime-client-cluster</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>com.flipkart.aesop</groupId>
+            <artifactId>client-event-consumer</artifactId>
+            <version>${project.version}</version>
+        </dependency>
+
+        <dependency>
+            <groupId>com.flipkart.aesop</groupId>
+            <artifactId>data-layer-api-caller</artifactId>
+            <version>1.2.1-SNAPSHOT</version>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.httpcomponents</groupId>
+            <artifactId>httpclient</artifactId>
+            <version>4.5</version>
+        </dependency>
+        <dependency>
+            <groupId>ch.qos.logback</groupId>
+            <artifactId>logback-core</artifactId>
+            <version>1.0.5</version>
+        </dependency>
+        <dependency>
+            <groupId>ch.qos.logback</groupId>
+            <artifactId>logback-classic</artifactId>
+            <version>1.0.5</version>
+        </dependency>
+
+    </dependencies>
+
+
+    <build>
+        <resources>
+            <resource>
+                <directory>src/main/resources</directory>
+                <filtering>true</filtering>
+            </resource>
+        </resources>
+
+        <plugins>
+            <plugin>
+                <artifactId>maven-clean-plugin</artifactId>
+                <version>2.5</version>
+                <configuration>
+                    <filesets>
+                        <fileset>
+                            <directory>distribution</directory>
+                            <includes>
+                                <include>**/*</include>
+                                <include>**/*</include>
+                            </includes>
+                            <followSymlinks>false</followSymlinks>
+                        </fileset>
+                    </filesets>
+                </configuration>
+            </plugin>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-jar-plugin</artifactId>
+                <version>${maven-jar-plugin.version}</version>
+                <configuration>
+                    <archive>
+                        <manifest>
+                            <addClasspath>true</addClasspath>
+                        </manifest>
+                    </archive>
+                    <includes>
+                        <include>packaged/**/*</include>
+                        <include>com/**/*</include>
+                        <include>project.properties</include>
+                    </includes>
+                </configuration>
+            </plugin>
+            <plugin>
+                <artifactId>maven-compiler-plugin</artifactId>
+                <version>${maven-compiler-plugin.version}</version>
+                <configuration>
+                    <source>${jdk.version}</source>
+                    <target>${jdk.version}</target>
+                </configuration>
+            </plugin>
+            <plugin>
+                <artifactId>maven-dependency-plugin</artifactId>
+                <executions>
+                    <execution>
+                        <phase>install</phase>
+                        <goals>
+                            <goal>copy-dependencies</goal>
+                        </goals>
+                        <configuration>
+                            <outputDirectory>distribution/lib</outputDirectory>
+                        </configuration>
+                    </execution>
+                </executions>
+            </plugin>
+            <plugin>
+                <artifactId>maven-antrun-plugin</artifactId>
+                <executions>
+                    <execution>
+                        <id>CopyResources</id>
+                        <phase>install</phase>
+                        <configuration>
+                            <tasks>
+                                <copy todir="distribution/resources/external" overwrite="true">
+                                    <fileset dir="target/classes/external" />
+                                </copy>
+                                <copy file="src/main/resources/application.conf" tofile="distribution/resources/application.conf" />
+                                <copy todir="distribution/" overwrite="true">
+                                    <fileset dir="target/classes/scripts" />
+                                </copy>
+                                <copy
+                                        file="target/sample-api-caller-client-cluster-consumer-${project.version}.jar"
+                                        toDir="distribution/lib" overwrite="true" />
+                                <copy file="target/classes/project.properties"
+                                      tofile="distribution/resources/external/project.properties.snapshot"
+                                      overwrite="true" />
+                            </tasks>
+                        </configuration>
+                        <goals>
+                            <goal>run</goal>
+                        </goals>
+                    </execution>
+                </executions>
+            </plugin>
+        </plugins>
+        <pluginManagement>
+            <plugins>
+                <!--This plugin's configuration is used to store Eclipse m2e settings
+                    only. It has no influence on the Maven build itself. -->
+                <plugin>
+                    <groupId>org.eclipse.m2e</groupId>
+                    <artifactId>lifecycle-mapping</artifactId>
+                    <version>1.0.0</version>
+                    <configuration>
+                        <lifecycleMappingMetadata>
+                            <pluginExecutions>
+                                <pluginExecution>
+                                    <pluginExecutionFilter>
+                                        <groupId>
+                                            org.apache.maven.plugins
+                                        </groupId>
+                                        <artifactId>
+                                            maven-dependency-plugin
+                                        </artifactId>
+                                        <versionRange>
+                                            [2.1,)
+                                        </versionRange>
+                                        <goals>
+                                            <goal>
+                                                copy-dependencies
+                                            </goal>
+                                        </goals>
+                                    </pluginExecutionFilter>
+                                    <action>
+                                        <ignore></ignore>
+                                    </action>
+                                </pluginExecution>
+                            </pluginExecutions>
+                        </lifecycleMappingMetadata>
+                    </configuration>
+                </plugin>
+            </plugins>
+        </pluginManagement>
+    </build>
+
+</project>
\ No newline at end of file
diff --git a/samples/sample-api-caller-client-cluster-consumer/src/main/resources/application.conf b/samples/sample-api-caller-client-cluster-consumer/src/main/resources/application.conf
new file mode 100644
index 0000000..1c6ed9a
--- /dev/null
+++ b/samples/sample-api-caller-client-cluster-consumer/src/main/resources/application.conf
@@ -0,0 +1,11 @@
+MAPPER_CONFIG
+  {
+    or_test:
+      {
+        "Person"=[
+          {
+            "mapAll":"true",
+            "groupNo":"1"
+          }]
+      }
+  }
diff --git a/samples/sample-api-caller-client-cluster-consumer/src/main/resources/external/bootstrap.xml b/samples/sample-api-caller-client-cluster-consumer/src/main/resources/external/bootstrap.xml
new file mode 100644
index 0000000..4d4cb66
--- /dev/null
+++ b/samples/sample-api-caller-client-cluster-consumer/src/main/resources/external/bootstrap.xml
@@ -0,0 +1,15 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE beans PUBLIC "-//SPRING//DTD BEAN 2.0//EN" "http://www.springframework.org/dtd/spring-beans-2.0.dtd">
+<beans>
+    <bean id="bootstrapInfo" class="org.trpr.platform.runtime.spi.bootstrap.BootstrapInfo">
+        <property name="projectsRoot" value="$RUNTIME_CONFIG_PATH/../../" />
+        <property name="applicationName" value="Aesop Sample Client Server" />
+        <property name="runtimeNature" value="server" />
+        <property name="container" ref="containerImpl" />
+        <property name="componentContainerClassName" value="com.flipkart.aesop.runtime.spring.ClientRuntimeComponentContainer" />
+    </bean>
+
+    <bean id="containerImpl" class="org.trpr.platform.runtime.impl.container.spring.SpringContainerImpl">
+    </bean>
+
+</beans>
\ No newline at end of file
diff --git a/samples/sample-api-caller-client-cluster-consumer/src/main/resources/external/logback.xml b/samples/sample-api-caller-client-cluster-consumer/src/main/resources/external/logback.xml
new file mode 100644
index 0000000..e491b2c
--- /dev/null
+++ b/samples/sample-api-caller-client-cluster-consumer/src/main/resources/external/logback.xml
@@ -0,0 +1,23 @@
+<configuration>
+
+    <appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">
+        <encoder>
+            <pattern>%d{HH:mm:ss.SSS} [%thread] %-5level %class{36}.%M %L %logger{36} - %msg%n</pattern>
+        </encoder>
+    </appender>
+
+    <appender name="FILE" class="ch.qos.logback.core.FileAppender">
+        <file>/tmp/sample-api-caller-client-cluster-consumer/sample-mysql-relay.log</file>
+        <append>true</append>
+        <encoder>
+            <pattern>%d{HH:mm:ss.SSS} [%thread] %-5level %class{36}.%M %L  %logger{36} - %msg%n</pattern>
+        </encoder>
+    </appender>
+    <!-- Set some of the 3rd party libraries to log only at INFO or higher levels -->
+    <logger name="org.springframework" level="info"/>
+    <root level="info">
+        <appender-ref ref="STDOUT" />
+        <appender-ref ref="FILE" />
+    </root>
+
+</configuration>
\ No newline at end of file
diff --git a/samples/sample-api-caller-client-cluster-consumer/src/main/resources/external/runtime-config.properties b/samples/sample-api-caller-client-cluster-consumer/src/main/resources/external/runtime-config.properties
new file mode 100644
index 0000000..091f49a
--- /dev/null
+++ b/samples/sample-api-caller-client-cluster-consumer/src/main/resources/external/runtime-config.properties
@@ -0,0 +1,4 @@
+# Start Jetty configuration values
+runtime.server.jetty.admin.port=8082
+runtime.server.jetty.maxFormContentSize=60000000
+# End Jetty configuration values
\ No newline at end of file
diff --git a/samples/sample-api-caller-client-cluster-consumer/src/main/resources/external/spring-client-config.xml b/samples/sample-api-caller-client-cluster-consumer/src/main/resources/external/spring-client-config.xml
new file mode 100644
index 0000000..e254ee7
--- /dev/null
+++ b/samples/sample-api-caller-client-cluster-consumer/src/main/resources/external/spring-client-config.xml
@@ -0,0 +1,187 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<beans xmlns="http://www.springframework.org/schema/beans"
+       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:util="http://www.springframework.org/schema/util"
+       xsi:schemaLocation="
+    http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
+    http://www.springframework.org/schema/util
+	http://www.springframework.org/schema/util/spring-util-2.5.xsd">
+
+    <bean
+            class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
+        <property name="location" value="classpath:project.properties" />
+    </bean>
+
+    <bean id="defaultEventConsumerFactory"
+          class="com.flipkart.aesop.eventconsumer.implementation.DefaultEventConsumerFactoryBean">
+        <property name="mapper" ref="defaultMapperImpl" />
+        <property name="destinationProcessorMap">
+            <map>
+                <entry key-ref="upsertDbusOpCode" value-ref="apiCallerDataLayer" />
+                <entry key-ref="deleteDbusOpCode" value-ref="apiCallerDataLayer" />
+            </map>
+        </property>
+        <property name="sourceEventFactory" ref="sourceEventFactory" />
+        <property name="destinationGroupSet">
+            <set>
+                <value>1</value>
+            </set>
+        </property>
+        <property name="totalDestinationGroups" value="1" />
+    </bean>
+
+
+    <util:constant id="upsertDbusOpCode"
+                   static-field="com.linkedin.databus.core.DbusOpcode.UPSERT" />
+    <util:constant id="deleteDbusOpCode"
+                   static-field="com.linkedin.databus.core.DbusOpcode.DELETE" />
+
+    <bean id="mapperConfig"
+          class="com.flipkart.aesop.mapper.config.implementation.MapperConfigImpl"
+          factory-method="getInstance" />
+    <bean id="defaultMapperImpl"
+          class="com.flipkart.aesop.mapper.implementation.DefaultMapperImpl">
+        <property name="configFilePath" value="resources/application.conf" />
+        <property name="configRoot" value="MAPPER_CONFIG" />
+        <property name="mapperConfig" ref="mapperConfig" />
+        <property name="mapperTypeList">
+            <list>
+                <ref bean="noNamespaceEntityMapperType" />
+                <ref bean="noEntityMapperType" />
+                <ref bean="namespaceEntityMapperType" />
+            </list>
+        </property>
+        <property name="eventGroupFinder" ref="defaultEventGroupFinder" />
+        <property name="destinationEventFactory" ref="destinationEventFactory" />
+    </bean>
+
+    <util:constant id="noNamespaceEntityMapperType"
+                   static-field="com.flipkart.aesop.mapper.implementation.MapperType.MAP_WITHOUT_SOURCE_NAMESPACE_ENTITY_CONFIG" />
+    <util:constant id="noEntityMapperType"
+                   static-field="com.flipkart.aesop.mapper.implementation.MapperType.MAP_WITHOUT_SOURCE_ENTITY_CONFIG" />
+    <util:constant id="namespaceEntityMapperType"
+                   static-field="com.flipkart.aesop.mapper.implementation.MapperType.MAP_WITH_SOURCE_ENTITY_CONFIG" />
+
+    <bean id="defaultEventGroupFinder"
+          class="com.flipkart.aesop.mapper.eventGroupFilter.implementation.DefaultEventGroupFinderImpl"
+          factory-method="getInstance" />
+
+    <bean id="destinationEventFactory"
+          class="com.flipkart.aesop.event.implementation.DestinationEventFactory" />
+
+    <bean id="sourceEventFactory"
+          class="com.flipkart.aesop.event.implementation.SourceEventFactory" />
+
+    <bean id="apiCallerDataLayer"
+          class="com.flipkart.aesop.apicallerdatalayer.ApiCallerDataLayer">
+        <property name="url" value="http://localhost:8076/test" />
+        <property name="staticHeaderProvider" ref="stringBasedStaticHeaderProvider" />
+        <property name="contextualHeaderProvider" ref="stringBasedContextualHeaderProvider" />
+        <property name="httpPostClient" ref="CasClient"/>
+    </bean>
+
+    <bean id="stringBasedStaticHeaderProvider" class="com.flipkart.aesop.apicallerdatalayer.headers.impl.StringBasedStaticHeaderProviderImpl">
+        <constructor-arg name="headers" value="header1=value1,header2=value2"/>
+    </bean>
+    <bean id="stringBasedContextualHeaderProvider" class="com.flipkart.aesop.apicallerdatalayer.headers.impl.StringBasedContextualHeaderProviderImpl">
+        <constructor-arg name="headers" value="header3=value3"/>
+    </bean>
+
+    <bean id = "CasClient" class="com.flipkart.aesop.apicallerdatalayer.client.implementation.HttpCASPostClientImpl">
+        <constructor-arg name="cache" ref="inMemoryCache"/>
+        <constructor-arg name="casUrl" value="https://flo-rubycas-server.nm.flipkart.com/"/>
+        <constructor-arg name="enableAuth" value="false"/>
+        <constructor-arg name="password" value="null"/>
+        <constructor-arg name="user" value="null"/>
+    </bean>
+    <bean id = "JavaxClient" class="com.flipkart.aesop.apicallerdatalayer.client.implementation.HttpJavaxPostClientImpl"/>
+    <bean id = "inMemoryCache" class="com.flipkart.casclient.util.InMemoryCache"/>
+    <!--
+    <bean id="apiCallerDeleteDataLayer"
+          class="com.flipkart.aesop.apicallerdatalayer.delete.ApiCallerDeleteDataLayerFactory">
+        <property name="url" value="http://localhost:8080/test" />
+        <property name="headers" value="{'Header1':'value1','header2':'value2'}" />
+    </bean>
+    <bean id = "ApiCallerDataLayer" class="com.flipkart.aesop.apicallerdatalayer.ApiCallerDataLayer">
+        <property name="headers" value="http://localhost:8080/test" />
+        <property name="url" value="{'Header1':'value1','header2':'value2'}" />
+        <property name="casClient" ref="casClient" />
+    </bean>
+    -->
+    <bean id="sampleClient"
+          class="com.flipkart.aesop.runtime.clusterclient.DefaultClusterClientFactory">
+        <property name="clientClusterConfig" ref="clientClusterConfig" />
+        <property name="clusterRegistrations">
+            <list>
+                <bean class="com.flipkart.aesop.runtime.config.ClusterRegistration">
+                    <property name="clusterName" value="pz_api_caller_cluster" />
+                    <property name="consumerFactory">
+                        <bean class="com.flipkart.aesop.eventconsumer.ConsumerFactory">
+                            <property name="eventConsumerFactoryList">
+                                <list>
+                                    <ref bean="defaultEventConsumerFactory" />
+                                </list>
+                            </property>
+                            <property name="totalDestinationGroups" value="1" />
+                        </bean>
+                    </property>
+                    <property name="logicalSources">
+                        <list value-type="java.lang.String">
+                            <value>com.flipkart.aesop.events.ortest.Person</value>
+                        </list>
+                    </property>
+                </bean>
+            </list>
+        </property>
+    </bean>
+
+    <bean id="clientClusterConfig" class="com.flipkart.aesop.runtime.config.ClientClusterConfig">
+        <property name="clientProperties">
+            <bean id="clientPropertiesFactory"
+                  class="org.springframework.beans.factory.config.PropertiesFactoryBean">
+                <property name="singleton" value="true" />
+                <property name="properties">
+                    <props>
+                        <prop key="databus.client.container.httpPort">11125</prop>
+                        <prop key="databus.client.container.jmx.rmiEnabled">false</prop>
+                        <prop key="databus.client.connectionDefaults.pullerRetries.initSleep">1</prop>
+                        <prop
+                                key="databus.client.connectionDefaults.pullerRetries.maxRetryNum">-1</prop>
+                        <prop key="databus.client.checkpointPersistence.clearBeforeUse">false</prop>
+                        <prop
+                                key="databus.client.connectionDefaults.enablePullerMessageQueueLogging">false</prop>
+                    </props>
+                </property>
+            </bean>
+        </property>
+        <property name="relayClientConfigs">
+            <list>
+                <bean class="com.flipkart.aesop.runtime.config.RelayClientConfig">
+                    <property name="relayId" value="1" />
+                    <property name="relayHost" value="localhost" />
+                    <property name="relayPort" value="25021" />
+                    <property name="relayLogicalSourceNames">
+                        <list value-type="java.lang.String">
+                            <value>com.flipkart.aesop.events.ortest.Person</value>
+                        </list>
+                    </property>
+                </bean>
+            </list>
+        </property>
+        <property name="clusterInfoConfigs">
+            <list>
+                <bean class="com.flipkart.aesop.runtime.config.ClusterInfoConfig">
+                    <property name="id" value="1" />
+                    <property name="clusterName" value="pz_api_caller_cluster" />
+                    <property name="zkAddr" value="localhost:2181" />
+                    <property name="numPartitions" value="2" />
+                    <property name="quorum" value="1" />
+                    <property name="zkSessionTimeoutMs" value="3000" />
+                    <property name="zkConnectionTimeoutMs" value="3000" />
+                    <property name="checkpointIntervalMs" value="300000" />
+                </bean>
+            </list>
+        </property>
+
+        <property name="checkpointDirectoryLocation" value="../../data-dir/client_checkpoint_directory" />
+    </bean>
+</beans>
\ No newline at end of file
diff --git a/samples/sample-api-caller-client-cluster-consumer/src/main/resources/project.properties b/samples/sample-api-caller-client-cluster-consumer/src/main/resources/project.properties
new file mode 100644
index 0000000..437d9a7
--- /dev/null
+++ b/samples/sample-api-caller-client-cluster-consumer/src/main/resources/project.properties
@@ -0,0 +1,9 @@
+CHECKPOINT_DIR_LOCATION=${checkpoint_dir_location}
+ZK_ADDR=${zk_addr}
+MAPPER_CONFIG_FILE_PATH=${mapper_config_file_path}
+RELAY_HOST=${relay_host}
+DENORMALIZED_DB=${denormalized_db}
+DENORMALIZED_DB_USER=${denormalized_db_user}
+DENORMALIZED_DB_PASSWORD=${denormalized_db_password}
+DENORMALIZED_DB_JDBC_URL=${denormalized_db_jdbc_url}
+NUM_PARTITIONS=${num_partitions}
\ No newline at end of file
diff --git a/samples/sample-api-caller-client-cluster-consumer/src/main/resources/scripts/start.sh b/samples/sample-api-caller-client-cluster-consumer/src/main/resources/scripts/start.sh
new file mode 100644
index 0000000..826e433
--- /dev/null
+++ b/samples/sample-api-caller-client-cluster-consumer/src/main/resources/scripts/start.sh
@@ -0,0 +1 @@
+java -cp "lib/*" org.trpr.platform.runtime.impl.bootstrap.BootstrapLauncher resources/external/bootstrap.xml
\ No newline at end of file