diff --git a/example/kafka-stream-reconnect.mjs b/example/kafka-stream-reconnect.mjs index ae711a3..caa3c56 100644 --- a/example/kafka-stream-reconnect.mjs +++ b/example/kafka-stream-reconnect.mjs @@ -94,6 +94,4 @@ async function startConsumer() { await setupConsumerWithRetry() } - await startConsumer() - diff --git a/js-binding.d.ts b/js-binding.d.ts index a03be84..3f28db3 100644 --- a/js-binding.d.ts +++ b/js-binding.d.ts @@ -13,7 +13,7 @@ export interface RetryStrategy { } export enum CommitMode { Sync = 0, - Async = 1 + Async = 1, } export interface ConsumerConfiguration { groupId: string @@ -25,7 +25,7 @@ export interface ConsumerConfiguration { export enum PartitionPosition { Beginning = 'Beginning', End = 'End', - Stored = 'Stored' + Stored = 'Stored', } export interface OffsetModel { offset?: number @@ -44,7 +44,7 @@ export enum SecurityProtocol { Plaintext = 'Plaintext', Ssl = 'Ssl', SaslPlaintext = 'SaslPlaintext', - SaslSsl = 'SaslSsl' + SaslSsl = 'SaslSsl', } export interface KafkaConfiguration { brokers: string diff --git a/js-binding.js b/js-binding.js index ed9ebbf..d39d466 100644 --- a/js-binding.js +++ b/js-binding.js @@ -63,7 +63,7 @@ switch (platform) { switch (arch) { case 'x64': localFileExisted = existsSync( - join(__dirname, 'kafka-crab-js.win32-x64-msvc.node') + join(__dirname, 'kafka-crab-js.win32-x64-msvc.node'), ) try { if (localFileExisted) { @@ -77,7 +77,7 @@ switch (platform) { break case 'ia32': localFileExisted = existsSync( - join(__dirname, 'kafka-crab-js.win32-ia32-msvc.node') + join(__dirname, 'kafka-crab-js.win32-ia32-msvc.node'), ) try { if (localFileExisted) { @@ -91,7 +91,7 @@ switch (platform) { break case 'arm64': localFileExisted = existsSync( - join(__dirname, 'kafka-crab-js.win32-arm64-msvc.node') + join(__dirname, 'kafka-crab-js.win32-arm64-msvc.node'), ) try { if (localFileExisted) { @@ -132,7 +132,7 @@ switch (platform) { break case 'arm64': localFileExisted = existsSync( - join(__dirname, 'kafka-crab-js.darwin-arm64.node') + join(__dirname, 'kafka-crab-js.darwin-arm64.node'), ) try { if (localFileExisted) { @@ -168,7 +168,7 @@ switch (platform) { case 'x64': if (isMusl()) { localFileExisted = existsSync( - join(__dirname, 'kafka-crab-js.linux-x64-musl.node') + join(__dirname, 'kafka-crab-js.linux-x64-musl.node'), ) try { if (localFileExisted) { @@ -181,7 +181,7 @@ switch (platform) { } } else { localFileExisted = existsSync( - join(__dirname, 'kafka-crab-js.linux-x64-gnu.node') + join(__dirname, 'kafka-crab-js.linux-x64-gnu.node'), ) try { if (localFileExisted) { @@ -197,7 +197,7 @@ switch (platform) { case 'arm64': if (isMusl()) { localFileExisted = existsSync( - join(__dirname, 'kafka-crab-js.linux-arm64-musl.node') + join(__dirname, 'kafka-crab-js.linux-arm64-musl.node'), ) try { if (localFileExisted) { @@ -210,7 +210,7 @@ switch (platform) { } } else { localFileExisted = existsSync( - join(__dirname, 'kafka-crab-js.linux-arm64-gnu.node') + join(__dirname, 'kafka-crab-js.linux-arm64-gnu.node'), ) try { if (localFileExisted) { @@ -226,7 +226,7 @@ switch (platform) { case 'arm': if (isMusl()) { localFileExisted = existsSync( - join(__dirname, 'kafka-crab-js.linux-arm-musleabihf.node') + join(__dirname, 'kafka-crab-js.linux-arm-musleabihf.node'), ) try { if (localFileExisted) { @@ -239,7 +239,7 @@ switch (platform) { } } else { localFileExisted = existsSync( - join(__dirname, 'kafka-crab-js.linux-arm-gnueabihf.node') + join(__dirname, 'kafka-crab-js.linux-arm-gnueabihf.node'), ) try { if (localFileExisted) { @@ -255,7 +255,7 @@ switch (platform) { case 'riscv64': if (isMusl()) { localFileExisted = existsSync( - join(__dirname, 'kafka-crab-js.linux-riscv64-musl.node') + join(__dirname, 'kafka-crab-js.linux-riscv64-musl.node'), ) try { if (localFileExisted) { @@ -268,7 +268,7 @@ switch (platform) { } } else { localFileExisted = existsSync( - join(__dirname, 'kafka-crab-js.linux-riscv64-gnu.node') + join(__dirname, 'kafka-crab-js.linux-riscv64-gnu.node'), ) try { if (localFileExisted) { @@ -283,7 +283,7 @@ switch (platform) { break case 's390x': localFileExisted = existsSync( - join(__dirname, 'kafka-crab-js.linux-s390x-gnu.node') + join(__dirname, 'kafka-crab-js.linux-s390x-gnu.node'), ) try { if (localFileExisted) { @@ -310,7 +310,8 @@ if (!nativeBinding) { throw new Error(`Failed to load native binding`) } -const { KafkaConsumer, CommitMode, PartitionPosition, SecurityProtocol, KafkaClientConfig, KafkaProducer } = nativeBinding +const { KafkaConsumer, CommitMode, PartitionPosition, SecurityProtocol, KafkaClientConfig, KafkaProducer } = + nativeBinding module.exports.KafkaConsumer = KafkaConsumer module.exports.CommitMode = CommitMode diff --git a/js-src/js-binding.d.ts b/js-src/js-binding.d.ts index a03be84..3f28db3 100644 --- a/js-src/js-binding.d.ts +++ b/js-src/js-binding.d.ts @@ -13,7 +13,7 @@ export interface RetryStrategy { } export enum CommitMode { Sync = 0, - Async = 1 + Async = 1, } export interface ConsumerConfiguration { groupId: string @@ -25,7 +25,7 @@ export interface ConsumerConfiguration { export enum PartitionPosition { Beginning = 'Beginning', End = 'End', - Stored = 'Stored' + Stored = 'Stored', } export interface OffsetModel { offset?: number @@ -44,7 +44,7 @@ export enum SecurityProtocol { Plaintext = 'Plaintext', Ssl = 'Ssl', SaslPlaintext = 'SaslPlaintext', - SaslSsl = 'SaslSsl' + SaslSsl = 'SaslSsl', } export interface KafkaConfiguration { brokers: string diff --git a/js-src/js-binding.js b/js-src/js-binding.js index ed9ebbf..d39d466 100644 --- a/js-src/js-binding.js +++ b/js-src/js-binding.js @@ -63,7 +63,7 @@ switch (platform) { switch (arch) { case 'x64': localFileExisted = existsSync( - join(__dirname, 'kafka-crab-js.win32-x64-msvc.node') + join(__dirname, 'kafka-crab-js.win32-x64-msvc.node'), ) try { if (localFileExisted) { @@ -77,7 +77,7 @@ switch (platform) { break case 'ia32': localFileExisted = existsSync( - join(__dirname, 'kafka-crab-js.win32-ia32-msvc.node') + join(__dirname, 'kafka-crab-js.win32-ia32-msvc.node'), ) try { if (localFileExisted) { @@ -91,7 +91,7 @@ switch (platform) { break case 'arm64': localFileExisted = existsSync( - join(__dirname, 'kafka-crab-js.win32-arm64-msvc.node') + join(__dirname, 'kafka-crab-js.win32-arm64-msvc.node'), ) try { if (localFileExisted) { @@ -132,7 +132,7 @@ switch (platform) { break case 'arm64': localFileExisted = existsSync( - join(__dirname, 'kafka-crab-js.darwin-arm64.node') + join(__dirname, 'kafka-crab-js.darwin-arm64.node'), ) try { if (localFileExisted) { @@ -168,7 +168,7 @@ switch (platform) { case 'x64': if (isMusl()) { localFileExisted = existsSync( - join(__dirname, 'kafka-crab-js.linux-x64-musl.node') + join(__dirname, 'kafka-crab-js.linux-x64-musl.node'), ) try { if (localFileExisted) { @@ -181,7 +181,7 @@ switch (platform) { } } else { localFileExisted = existsSync( - join(__dirname, 'kafka-crab-js.linux-x64-gnu.node') + join(__dirname, 'kafka-crab-js.linux-x64-gnu.node'), ) try { if (localFileExisted) { @@ -197,7 +197,7 @@ switch (platform) { case 'arm64': if (isMusl()) { localFileExisted = existsSync( - join(__dirname, 'kafka-crab-js.linux-arm64-musl.node') + join(__dirname, 'kafka-crab-js.linux-arm64-musl.node'), ) try { if (localFileExisted) { @@ -210,7 +210,7 @@ switch (platform) { } } else { localFileExisted = existsSync( - join(__dirname, 'kafka-crab-js.linux-arm64-gnu.node') + join(__dirname, 'kafka-crab-js.linux-arm64-gnu.node'), ) try { if (localFileExisted) { @@ -226,7 +226,7 @@ switch (platform) { case 'arm': if (isMusl()) { localFileExisted = existsSync( - join(__dirname, 'kafka-crab-js.linux-arm-musleabihf.node') + join(__dirname, 'kafka-crab-js.linux-arm-musleabihf.node'), ) try { if (localFileExisted) { @@ -239,7 +239,7 @@ switch (platform) { } } else { localFileExisted = existsSync( - join(__dirname, 'kafka-crab-js.linux-arm-gnueabihf.node') + join(__dirname, 'kafka-crab-js.linux-arm-gnueabihf.node'), ) try { if (localFileExisted) { @@ -255,7 +255,7 @@ switch (platform) { case 'riscv64': if (isMusl()) { localFileExisted = existsSync( - join(__dirname, 'kafka-crab-js.linux-riscv64-musl.node') + join(__dirname, 'kafka-crab-js.linux-riscv64-musl.node'), ) try { if (localFileExisted) { @@ -268,7 +268,7 @@ switch (platform) { } } else { localFileExisted = existsSync( - join(__dirname, 'kafka-crab-js.linux-riscv64-gnu.node') + join(__dirname, 'kafka-crab-js.linux-riscv64-gnu.node'), ) try { if (localFileExisted) { @@ -283,7 +283,7 @@ switch (platform) { break case 's390x': localFileExisted = existsSync( - join(__dirname, 'kafka-crab-js.linux-s390x-gnu.node') + join(__dirname, 'kafka-crab-js.linux-s390x-gnu.node'), ) try { if (localFileExisted) { @@ -310,7 +310,8 @@ if (!nativeBinding) { throw new Error(`Failed to load native binding`) } -const { KafkaConsumer, CommitMode, PartitionPosition, SecurityProtocol, KafkaClientConfig, KafkaProducer } = nativeBinding +const { KafkaConsumer, CommitMode, PartitionPosition, SecurityProtocol, KafkaClientConfig, KafkaProducer } = + nativeBinding module.exports.KafkaConsumer = KafkaConsumer module.exports.CommitMode = CommitMode diff --git a/tsconfig.json b/tsconfig.json index d4b0aca..93e199c 100644 --- a/tsconfig.json +++ b/tsconfig.json @@ -9,14 +9,14 @@ "allowJs": true, "skipLibCheck": true, "rootDir": "./js-src", - "outDir": "./dist", + "outDir": "./dist" }, "include": [ - "**/*.ts", + "**/*.ts" ], "copyFiles": [ "js_src/js-binding.d.ts", - "js_src/js-binding.js", + "js_src/js-binding.js" ], "exclude": [ "__test__", @@ -27,5 +27,5 @@ "npm", "js-binding.js", "js-binding.d.ts" - ], -} \ No newline at end of file + ] +}