打开几何 confluent-kafka-javascript 节点J的仪器
灵感来自 @eqxjs/kafka-server-node-rdkafka 财务报告和审定财务报表 @opentelemetry/instrumentation-kafkajs
本模块为下列人员提供自动仪器: @confluentinc/kafka-javascript 软件包,可以使用 @opentelemetry/sdk-trace-node 软件包,并包含在 @opentelemetry/auto-instrumentations-node 捆绑.
如果总安装尺寸不受限制,建议使用 @opentelemetry/auto-instrumentations-node 捆绑在一起 @ opletemetry/ sdk- 节点 对于最无缝的仪器体验.
与 OpenTeleometry JS API 和 SDK 兼容 1.0+。 。 。 .
安装
npm install --save @drazke/instrumentation-confluent-kafka-javascript
支持的版本
@confluentinc/kafka-javascript版本>=1.3.0
使用量
const { NodeTracerProvider } = require('@opentelemetry/sdk-trace-node');
const {
ConfluentKafkaInstrumentation,
} = require('@drazke/instrumentation-confluent-kafka-javascript');
const { registerInstrumentations } = require('@opentelemetry/instrumentation');
const provider = new NodeTracerProvider();
provider.register();
registerInstrumentations({
instrumentations: [
new ConfluentKafkaInstrumentation({
// see below for available configuration
}),
],
});
仪器选项
您可以设置如下:
| 选项 | 类型 | 说明 |
|---|---|---|
producerHook | KafkaProducerCustomAttributeFunction | 在发送制作人消息前调用函数 。 允许在跨度上添加自定义属性 . |
consumerHook | KafkaConsumerCustomAttributeFunction | 在处理消费者信息之前调用函数 。 允许在跨度上添加自定义属性 . |
语义公约
此软件包使用 @opentelemetry/semantic-conventions 版本 1.30+,执行语义公约 1.3.0.0版本 翻译:
泉水喷出
| KafkaJS 对象 | 行动 | Span 宽度 | 宽边名 | 操作类型/ 名称 |
|---|---|---|---|---|
| 消费者 | data | 消费者 | <topic-name> | receive 编号 : received |
| 制作人 | delivery-report | 制作人 | <topic-name> | deliver 编号 : delivery-report |
| 制作人 | produce | 制作人 | <topic-name> | send 编号 : produce |
已收集属性
这些属性尽可能地被添加到跨度和度量中.
| 属性 | 简短说明 |
|---|---|
messaging.system | 正在使用的邮件系统标识符(即:. "kafka") (中文(简体) ). |
messaging.destination.name | 消息目的地名称 . |
messaging.operation.type | 一个字符串来识别消息操作的类型 . |
messaging.operation.name | 消息操作的系统特有名称. |
messaging.client.id | 客户身份. |
messaging.kafka.message.key | 代表 Kafka 信件密钥的字符串值( 如果存在 ) . |
messaging.kafka.message.tombstone | 如果讯息是墓碑的话. |
messaging.kafka.offset | 相应卡夫卡分区记录的相抵. |
messaging.destination.partition.id | 分区信件的标识符发送到或接收到,在 messaging.destination.name。 。 。 . 说明: 仅供生产者使用. |
有用链接
- 关于OpenTeleometry的更多信息,请访问: https://opentelemetry.io/ 互联网档案馆的存檔,存档日期2013-12-02
许可证
Apache 2. 0 - 见 自由主义 更多信息.