
Product
Socket Now Protects the Chrome Extension Ecosystem
Socket is launching experimental protection for Chrome extensions, scanning for malware and risky permissions to prevent silent supply chain attacks.
@aws-sdk/client-kafka-node
Advanced tools
<p>The operations for managing an Amazon MSK cluster.</p>
To install the this package using NPM, simply type the following into a terminal window:
npm install @aws-sdk/client-kafka-node
The AWS SDK is modulized by clients and commands in CommonJS modules. To send a request, you only need to import the client(KafkaClient
) and the commands you need, for example CreateClusterCommand
:
//JavaScript
const { KafkaClient } = require("@aws-sdk/client-kafka-node/KafkaClient");
const {
CreateClusterCommand
} = require("@aws-sdk/client-kafka-node/commands/CreateClusterCommand");
//TypeScript
import { KafkaClient } from "@aws-sdk/client-kafka-node/KafkaClient";
import { CreateClusterCommand } from "@aws-sdk/client-kafka-node/commands/CreateClusterCommand";
To send a request, you:
send
operation on client with command object as input.destroy()
to close open connections.const kafka = new KafkaClient({region: 'region'});
//clients can be shared by different commands
const params = {
BrokerNodeGroupInfo: { /**an object specifying BrokerNodeGroupInfo*/ },
ClusterName: /**a string value*/,
KafkaVersion: /**a string value*/,
NumberOfBrokerNodes: /**a integer value*/,
};
const createClusterCommand = new CreateClusterCommand(params);
kafka.send(createClusterCommand).then(data => {
// do something
}).catch(error => {
// error handling
})
In addition to using promises, there are 2 other ways to send a request:
// async/await
try {
const data = await kafka.send(createClusterCommand);
// do something
} catch (error) {
// error handling
}
// callback
kafka.send(createClusterCommand, (err, data) => {
//do something
});
The SDK can also send requests using the simplified callback style from version 2 of the SDK.
import * as AWS from "@aws-sdk/@aws-sdk/client-kafka-node/Kafka";
const kafka = new AWS.Kafka({ region: "region" });
kafka.createCluster(params, (err, data) => {
//do something
});
When the service returns an exception, the error will include the exception information, as well as response metadata (e.g. request id).
try {
const data = await kafka.send(createClusterCommand);
// do something
} catch (error) {
const metadata = error.$metadata;
console.log(
`requestId: ${metadata.requestId}
cfId: ${metadata.cfId}
extendedRequestId: ${metadata.extendedRequestId}`
);
/*
The keys within exceptions are also parsed. You can access them by specifying exception names:
if(error.name === 'SomeServiceException') {
const value = error.specialKeyInException;
}
*/
}
Please use these community resources for getting help. We use the GitHub issues for tracking bugs and feature requests and have limited bandwidth to address them.
aws-sdk-js
This client code is generated automatically. Any modifications will be overwritten the next time the `@aws-sdk/@aws-sdk/client-kafka-node' package is updated. To contribute to SDK you can checkout our code generator package.
This SDK is distributed under the Apache License, Version 2.0, see LICENSE for more information.
FAQs
Node SDK for Managed Streaming for Kafka
We found that @aws-sdk/client-kafka-node demonstrated a not healthy version release cadence and project activity because the last version was released a year ago. It has 4 open source maintainers collaborating on the project.
Did you know?
Socket for GitHub automatically highlights issues in each pull request and monitors the health of all your open source dependencies. Discover the contents of your packages and block harmful activity before you install or update your dependencies.
Product
Socket is launching experimental protection for Chrome extensions, scanning for malware and risky permissions to prevent silent supply chain attacks.
Product
Add secure dependency scanning to Claude Desktop with Socket MCP, a one-click extension that keeps your coding conversations safe from malicious packages.
Product
Socket now supports Scala and Kotlin, bringing AI-powered threat detection to JVM projects with easy manifest generation and fast, accurate scans.