文件名称:kafka-penguin
文件大小:193KB
文件格式:ZIP
更新时间:2024-04-14 08:36:30
JavaScript
卡夫卡企鹅 插件通过快速失败来处理消息处理失败。 快速失败是一种策略,使开发人员可以立即从内部解决问题,并立即解决依赖于Kafka的不同微服务的任何数据流问题。 WIP:该项目尚未准备好使用 用法 const allStrategies = require ( './index.ts' ) ; const testClient = require ( './clientConfig.ts' ) const failfast = allStrategies . failfastSource ; //INSTANTIATING PRODUCER //const producer = client.producer(failfastSetting) ---> set num of retries //Ex: const producer =
【文件预览】:
kafka-penguin-main
----consumer()
--------consumer.js(937B)
--------topic.js(1KB)
--------client.ts(319B)
--------__test__()
--------consumer.ts(1KB)
--------producer_TK.js(2KB)
----.gitignore(41B)
----tsconfig.json(262B)
----README.md(1KB)
----failfastProducer.ts(1KB)
----LICENSE(1KB)
----package.json(2KB)
----clientConfig.test.ts(542B)
----client()
--------components()
--------index.tsx(754B)
--------.DS_Store(6KB)
----src()
--------deadLetterQueue.ts(109B)
--------failfast.ts(1KB)
--------index.ts(270B)
----build()
--------bundle.js(535KB)
----jest.config.js(69B)
----index.ts(190B)
----jest.config.ts(6KB)
----example.ts(2KB)
----clientConfig.ts(382B)
----webpack.config.js(2KB)
----babel.config.js(138B)
----.DS_Store(8KB)