文件名称:iris:avro和kafka混搭
文件大小:188KB
文件格式:ZIP
更新时间:2024-05-17 16:54:51
JavaScript
虹膜 Kafka和Avro混搭 一个kafka库,用于使用Confluent的定义的来验证产生的消息并解码消耗的消息。 它通过使用与模式注册表支持的Kafka部署一起工作的编码来包装生产者的生产方法或消费者的消耗方法,从而在使用了出色的库。 它使用处理JSON消息的avro编码/解码。 安装 npm install @parkhub/iris 用法 为您的架构注册表提供URL,对其进行初始化并创建客户端! 在调整生产者/消费者选项之前,请务必先掌握您的Kafka知识! import iris from '@parkhub/iris' ; const registryUrl = 'http://registry:8081' ; const brokerList = 'kafka-1:9092,kafka-2:9092' ; const schemaCfgs = [ {
【文件预览】:
iris-master
----codefresh.yml(1KB)
----.gitignore(99B)
----.babelrc(260B)
----Dockerfile(187B)
----.flowconfig(129B)
----.eslintrc(143B)
----package.json(2KB)
----ROADMAP.md(0B)
----package-lock.json(519KB)
----src()
--------index.js(3KB)
--------lib()
----.dockerignore(66B)
----jest.integration.json(390B)
----package-scripts.js(2KB)
----LICENSE(11KB)
----docker-compose.ci-integration.yml(1KB)
----flow-typed()
--------npm()
----docker-compose.yml(2KB)
----.opt-in(22B)
----__tests__()
--------schemaRegistry.integration.test.js(1011B)
--------both.integration.test.js(3KB)
--------consumer.integration.test.js(5KB)
--------fixtures()
--------producer.integration.test.js(4KB)
----TODOS.md(382B)
----README.md(10KB)
----.tern-project(162B)
----.eslintignore(27B)