@ovotech/kafka-consumer
A generic kafka consumer
Last updated a year ago by ikerin .
Apache-2.0 · Original npm · Tarball · package.json
$ cnpm install @ovotech/kafka-consumer 
SYNC missed versions from official npm registry.

Kafka Consumer

A generic kafka consumer.

Using

yarn add @ovotech/kafka-consumer
const onDetectNotification = async (message: AvroMessage) => {
  //handle notification
};

createKafkaConsumer(
  {
    OPTIONS: {},
    KAFKA_SCHEMA_REGISTRY: env.KAFKA_SCHEMA_REGISTRY!,
    KAFKA_TOPICS: ['topic_v1', 'topic_v2'],
  },
  logger,
  onDetectNotification,
);

Running the tests

Then you can run the tests with:

yarn test

Coding style (linting, etc) tests

Style is maintained with prettier and tslint

yarn lint

Deployment

Deployment is preferment by lerna automatically on merge / push to master, but you'll need to bump the package version numbers yourself. Only updated packages with newer versions will be pushed to the npm registry.

Contributing

Have a bug? File an issue with a simple example that reproduces this so we can take a look & confirm.

Want to make a change? Submit a PR, explain why it's useful, and make sure you've updated the docs (this file) and the tests (see test folder).

License

This project is licensed under Apache 2 - see the LICENSE file for details

Current Tags

  • 0.0.1                                ...           latest (a year ago)

1 Versions

  • 0.0.1                                ...           a year ago
Downloads
Today 0
This Week 0
This Month 1
Last Day 0
Last Week 1
Last Month 0
Dev Dependencies (10)
Dependents (0)
None

Copyright 2014 - 2016 © taobao.org |