Adding a working ci build v1

.circleci/config.yml

@@ -1,15 +1,36 @@
-# Use the latest 2.1 version of CircleCI pipeline processing engine, see https://circleci.com/docs/2.0/configuration-reference/
-version: 2.1
+version: 2
+jobs:
+  integration:
+    working_directory: ~/app
+    docker:
+      - image: circleci/node:4.8.
+      - image: wurstmeister/kafka:2.11-0.11.0.3
+        environment:
+          KAFKA_ADVERTISED_HOST_NAME: localhost
+          KAFKA_ADVERTISED_PORT: 9092
+          KAFKA_PORT: 9092
+          KAFKA_ZOOKEEPER_CONNECT: localhost:2181
+          KAFKA_DELETE_TOPIC_ENABLE: true
+    steps:
+      - checkout
+      - run:
+          name: update-npm
+          command: 'sudo npm install -g npm@latest'
+      - restore_cache:
+          key: dependency-cache-{{ checksum "package.json" }}
+      - run:
+          name: install-npm-wee
+          command: npm install
+      - save_cache:
+          key: dependency-cache-{{ checksum "package.json" }}
+          paths:
+            - ./node_modules
+      - run:
+          name: test
+          command: npm test:integration
 
-# Use a package of configuration called an orb, see https://circleci.com/docs/2.0/orb-intro/
-orbs:
-  # Declare a dependency on the welcome-orb
-  welcome: circleci/[email protected]
-
-# Orchestrate or schedule a set of jobs, see https://circleci.com/docs/2.0/workflows/
-workflows:
-  # Name the workflow "Welcome"
-  Welcome:
-    # Run the welcome/run job in its own container
+workflow:
+  version: 2
+  test:
     jobs:
-      - welcome/run
+      - integration

test/integration/create-topic-produce-consume.js

@@ -5,7 +5,7 @@ const kafka = require('kafka-node')
 const config = require('../../app/config/consumer-config')
 
 // Setup - Constants
-const testTopicName = 'test-create-topic-produce-consume'
+const testTopicName = `test-create-topic-produce-consume-${Date.now()}`
 
 const topicsToCreate = [{
   topic: testTopicName,
@@ -22,18 +22,21 @@ const payloads = [{
 
 // Client setup
 const client = new kafka.KafkaClient(config.clientOptions)
-const consumer = new kafka.Consumer(client, [{ topic: testTopicName }], config.consumerOptions)
-const producer = new kafka.Producer(client)
 
 // Create the topic if it does not exist
 client.createTopics(topicsToCreate, (error, result) => {
   if(error !== null) {
     console.log('\nCreating topic error', error)
+    process.exit(1)
   } else {
     console.log('\nCreating topic result', result)
   }
 })
 
+// Consumer/Producer Setup
+const consumer = new kafka.Consumer(client, [{ topic: testTopicName }], config.consumerOptions)
+const producer = new kafka.Producer(client)
+
 // Produce a new message
 producer.on('ready', function () {
   producer.send(payloads, function (err, data) {