PubSub Tool

pubsub-tool 是一款專為 Kafka 訂閱與發布設計的工具庫，提供 Confluent Schema Registry 和 Avro 解析能力，簡化 Kafka 消息處理流程。

Install

npm i pubsub-tool --save

Table of Contents

• Feature
• API
  • ConfluentSubResolveStrategy: for kafka consumer
  • ConfluentPubResolveStrategy: for kafka producer

Feature

• Confluent Schema Registry and Avro Resolver

API

Confluent Schema Registry and Avro Resolver Usage

ConfluentSubResolveStrategy

Parameter	Type	Description
schemaRegistry	SchemaRegistry	Schema Registry
avroResolver	AvroResolveStrategy	Avro Resolve Strategy

Full Example

import {
  ConfluentAvroStrategy,
  ConfluentMultiRegistry,
  ConfluentSubResolveStrategy,
} from 'pubsub-tool';

const registryHost = 'http://localhost:8585,http://localhost:8585,http://localhost:8585';

const schemaRegistry = new ConfluentMultiRegistry(registryHost);
const avro = new ConfluentAvroStrategy();
const resolver = new ConfluentSubResolveStrategy(schemaRegistry, avro);

const data = new Buffer();
resolver.resolve(data).then(val => console.log(val));

ConfluentPubResolveStrategy

Parameter	Type	Description
schemaRegistry	SchemaRegistry	Schema Registry
avroResolver	AvroResolveStrategy	Avro Resolve Strategy
destination	string	Pubish destination

Full Example

import {
  ConfluentAvroStrategy,
  ConfluentMultiRegistry,
  ConfluentPubResolveStrategy,
} from 'pubsub-tool';

const registryHost = 'http://localhost:8585,http://localhost:8585,http://localhost:8585';
const topic = 'testing.topic'

const schemaRegistry = new ConfluentMultiRegistry(registryHost);
const avro = new ConfluentAvroStrategy();
const resolver = new ConfluentPubResolveStrategy(schemaRegistry, avro, topic);

const data = { name: 'name', age: 18 };
resolver.resolve(data).then(buf => console.log(buf));