Ready to take your JavaScript development to the next level? Meet npm Enterprise - the ultimate in enterprise JavaScript. Learn more »

kafka-connect

3.7.0 • Public • Published

node-kafka-connect

Greenkeeper badge

Build Status

Coverage Status

What can I do with this?

The framework can be used to build connectors, that transfer data to and from Apache Kafka and Databases, very easily. If you are looking for already implemented connectors for you favorite datastore, take a look at the Available Connector Implementations below.

Info

  • node-kafka-connect is a framework to implement large kafka -> datastore & datastore -> kafka data movements.
  • it can be used to easily built connectors from/to kafka to any kind of datastore/database.
  • a connector might consist of a SourceConnector + SourceTask to poll data from a datastore into a kafka topic.
  • a connector might consist of a SinkConnector + SinkTask to put data from a kafka topic into a datastore.
  • Converters might be used to apply alteration to any data-stream.
  • any operation in node-kafka-connect is asynchronous
  • ships with auto http server (health-checks, kafka-stats)
  • ships with auto metrics (prometheus)

Available Connector Implementations

Creating custom Connectors

npm install --save kafka-connect
const source = new TestSourceConfig(config, 
    TestSourceConnector, 
    TestSourceTask, 
    [TestConverter]);
    
source.run().then();
const sink = new TestSinkConfig(config,
    TestSinkConnector, 
    TestSinkTask, 
    [TestConverter]);
 
sink.run().then();

Docs

Debugging

  • You can use DEBUG=kafka-connect:* to debug the sink configuration.

FAQ

  • Q: it is running slow / only synchronous / 1 by 1 messages ?
  • A: just set the config.batch object as it is described here

install

npm i kafka-connect

Downloadsweekly downloads

47

version

3.7.0

license

MIT

homepage

github.com

repository

Gitgithub

last publish

collaborators

  • avatar
Report a vulnerability