Skip to content

Latest commit

 

History

History
45 lines (34 loc) · 2.09 KB

README.md

File metadata and controls

45 lines (34 loc) · 2.09 KB

Nasdaq Cloud Data Service (NCDS) Dockerfiles

Update properties file

Replace example bootstrap.servers property in the file kafka.properties (https://github.com/Nasdaq/CloudDataService/blob/master/docker/kafka.properties) with provided values during on-boarding.

Replace example oauth.token.endpoint.uri property in the file auth.properties (https://github.com/Nasdaq/CloudDataService/blob/master/docker/auth.properties) with provided values during on-boarding.

Building

Run docker build in project home directory

docker build -f docker/Dockerfile . -t sdk-app --no-cache

Running Locally Built Images

Replace client id({clinet-id-value}) and client secret({client-secret-value}) provided during on-boarding from Nasdaq team.

docker run -e "OAUTH_CLIENT_ID={clinet-id-value}" -e "OAUTH_CLIENT_SECRET={client-secret-value} sdk-app:latest

User can pass arguments to run the application with specific commands

-opt -- Provide the operation you want to perform \n" +
  "        * TOP - View the top nnn records in the Topic/Stream\n"+
  "        * SCHEMA - Display the Schema for the topic\n"+
  "        * METRICS - Display the Metrics for the topic\n"+
  "        * TOPICS - List the eligible topics for the client\n"+
  "        * GETMSG - Get one example message for the\n"+
  "        * CONTSTREAM   - Retrieve continuous stream  \n"+
  "        * HELP - help \n"+
"-topic -- Provide topic for selected option         --- REQUIRED for TOP,SCHEMA,METRICS and GETMSG \n"+
"-n -- Provide number of messages to retrieve        --- REQUIRED for TOP \n"+
"-msgName -- Provide name of message based on schema --- REQUIRED for GETMSG \n"+

Example to get TOP 10 messages from GIDS stream

docker run -e "OAUTH_CLIENT_ID={clinet-id-value}" -e "OAUTH_CLIENT_SECRET={client-secret-value} sdk-app:latest -opt TOP -n 10 -topic GIDS

Nasdaq Cloud Data Service - Kafka mirroring with MirrorMaker

Kafka's mirroring feature makes it possible to maintain a replica of an existing Kafka cluster. (https://github.com/Nasdaq/CloudDataService/tree/master/docker/mirrormaker)