Repository files navigation

AtomicKafka is a lightweight NPM Package developed to simplify the process of establishing bidirectional, real-time data streaming with Apache Kafka in your web-app.
Website  |  Library  |  Demo Apps  |  Featured on Medium

AtomicKafkaConsumer demonstrates a functioning standalone Consumer microservice built into a React Component. This demo app was built to be used alongsideAtomicKafkaProducer.

If you are running the correspondingProducer, the Consumer will listen to the data that you produce from your producer app in real time. Try it with your colleagues by setting up a freeConfluent Cloud and sharing theAPI credentials with each to see how AtomicKafka integrates with the cloud!

Docker:

• If using Docker, use the.yml file provided herein and run in the root directory of this app.

  docker-compose up -d

Confluent Cloud:

• Follow the steps onConfluent Cloud to create a free account. Obtain theAPI_ACCESS_KEY,API_ACCESS_SECRET, andBOOTSTRAP_SERVER.
• Note that if you already have a Kafka instance running from a docker image (e.g. from the Producer demo), you do not need to compose again.

• Default ports are configured on the local host for the dev-server9002 and the Kafka broker3002.
• Docker .env config: (API_KEY andAPI_SECRET are intentionally left blank).

  API_KEY=API_SECRET=KAFKA_BOOTSTRAP_SERVER=localhost:9092

• Confluent Cloud .env config:

  API_KEY=<API_ACCESS_KEY>API_SECRET=<API_ACCESS_SECRET>KAFKA_BOOTSTRAP_SERVER=<BOOTSTRAP_SERVER>

$ npm install$ npm run build

$ npm run dev