文件名称:kafka-avro:具有Avro模式序列化的librdkafka的Node.js绑定
文件大小:62KB
文件格式:ZIP
更新时间:2024-05-22 07:31:14
JavaScript
卡夫卡-阿夫罗 具有Avro模式序列化的librdkafka的Node.js绑定。 kafka-avro库是将和库组合在一起的包装程序,以允许通过Avro验证和序列化的kafka上的消息的生产和消费。 安装 使用NPM安装模块: npm install kafka-avro --save 文献资料 kafka-avro库按以下步骤操作: 您将您的Kafka经纪人和架构注册表(SR)网址提供给kafka-avro的新实例。 初始化kafka-avro,它将告诉库查询SR以获取所有已注册的模式,并评估它们并将其存储在运行时内存中。 然后,kafka-avro将公开getConsumer()和getProducer()方法,这两个方法均从库返回相应构造函数的实例。 由kafka-avro返回的“ node-rdkafka”实例被黑客入侵,以拦截产生和消耗的消息,并由Avro de /
【文件预览】:
kafka-avro-master
----.travis.yml(299B)
----.eslintrc.yml(532B)
----.nvmrc(4B)
----package.json(1KB)
----test()
--------mocha.opts(31B)
--------spec()
--------lib()
--------fixtures()
----LICENSE(1KB)
----package-lock.json(121KB)
----Gruntfile.js(833B)
----docker-compose.yml(948B)
----.gitignore(81B)
----circle.yml(2KB)
----lib()
--------magic-byte.js(2KB)
--------schema-registry.js(16KB)
--------kafka-producer.js(4KB)
--------subject-strategy.js(3KB)
--------log.lib.js(1KB)
--------kafka-consumer.js(6KB)
--------kafka-avro.js(4KB)
----README.md(20KB)
----.editorconfig(431B)