@ovotech/avro-kafkajs
Advanced tools
Comparing version 0.6.2 to 0.6.3
@@ -1,2 +0,2 @@ | ||
export { SchemaRegistry, AvroBuffer, DecodeItem, EncodeCache, DecodeCache, SchemaRegistryConfig, } from './SchemaRegistry'; | ||
export { SchemaRegistry, AvroBuffer, DecodeItem, EncodeCache, DecodeCache, SchemaRegistryConfig, SchemaVersion, } from './SchemaRegistry'; | ||
export { AvroKafka } from './AvroKafka'; | ||
@@ -3,0 +3,0 @@ export { AvroProducer } from './AvroProducer'; |
@@ -7,2 +7,8 @@ /// <reference types="node" /> | ||
} | ||
export interface SchemaVersion { | ||
subject: string; | ||
id: number; | ||
version: number; | ||
schema: string; | ||
} | ||
export declare const deconstructMessage: (buffer: Buffer) => AvroBuffer; | ||
@@ -55,2 +61,3 @@ export declare const constructMessage: ({ id, buffer }: AvroBuffer) => Buffer; | ||
getSubjectVersions(subject: string): Promise<number[]>; | ||
getSubjectVersion(subject: string, version: number): Promise<SchemaVersion>; | ||
getSubjectVersionSchema(subject: string, version: number): Promise<Schema>; | ||
@@ -57,0 +64,0 @@ getSubjectLastVersionSchema(subject: string): Promise<Schema>; |
@@ -44,2 +44,5 @@ "use strict"; | ||
} | ||
async getSubjectVersion(subject, version) { | ||
return await schema_registry_api_1.getSubjectVersion(this.uri, subject, version); | ||
} | ||
async getSubjectVersionSchema(subject, version) { | ||
@@ -46,0 +49,0 @@ return await schema_registry_api_1.getSubjectVersionSchema(this.uri, subject, version); |
{ | ||
"name": "@ovotech/avro-kafkajs", | ||
"version": "0.6.2", | ||
"version": "0.6.3", | ||
"main": "dist/index.js", | ||
@@ -47,7 +47,7 @@ "types": "dist/index.d.ts", | ||
"dependencies": { | ||
"@ovotech/schema-registry-api": "^1.0.7", | ||
"@ovotech/schema-registry-api": "^1.1.1", | ||
"avsc": "^5.5.6", | ||
"long": "^4.0.0" | ||
}, | ||
"gitHead": "e601f487340655a1d7f8770c060b19f620fb44b9" | ||
"gitHead": "0b3311823e692c937e238d20376652e6f4742334" | ||
} |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
48024
759