EventStream pipeline example

uses Ingestion pipeline

    <dependency>
      <groupId>com.event.ingestion.pipeline</groupId>
      <artifactId>event-ingestion-pipeline</artifactId>
      <version>1.0</version>
    </dependency>

Running

mvn -DskipTests=true clean package
cp target/event-pipeline1.war /usr/local/apache-tomcat-9.0.14/webapps/

Ingestion

curl --user "ingestion-example:ingestion-example" -H "Content-Type: application/json" -X POST -d '{"eventType" : "TestIngestionEvent", "eventUuid": "1", "requiredField1" : "someValue1"}' localhost:8080/event-pipeline1/ingest
{"eventId":"1","responseCode":"SUCCESS","responseMessage":"Payload accepted"}

curl --user "ingestion-example:ingestion-example" -H "Content-Type: application/json" -X POST -d '{"eventType":"CampaignEvent","eventUuid":1,"userId":"00e39e26-0728-4407-92c4-7f24fb70ff08","campaignId":"00e39e26-0728-4407-92c4-7f24fb70ff08","campaignDate":"2019-05-04T15:53:10.250479-07:00[America/Los_Angeles]"}' localhost:8080/event-pipeline1/ingest
{"eventId":"1","responseCode":"SUCCESS","responseMessage":"Payload accepted"}

curl --user "ingestion-example:ingestion-example" -H "Content-Type: application/json" -X POST -d '{"eventType":"PageViewedEvent","eventUuid":2,"userId":"43271343-2742-4fde-91cb-04c7be364b6a","pageId":"00e39e26-0728-4407-92c4-7f24fb70ff08","pageViewedDate":"2019-05-04T15:53:10.250479-07:00[America/Los_Angeles]"}' localhost:8080/event-pipeline1/ingest

Eventstream

$ /usr/local/kafka_2.11-0.10.1.1/bin/kafka-console-consumer.sh --bootstrap-server localhost:2181 --topic "Pipeline1Stream" --from-beginning
{"MessageHeader" : { "EventName" : "TestIngestionEvent"}, "someField1" : "someValue1"}