@aws-sdk/client-kafka-node

@aws-sdk/client-kafka-node

Description

           <p>The operations for managing an Amazon MSK cluster.</p>

Installing

To install the this package using NPM, simply type the following into a terminal window:

npm install @aws-sdk/client-kafka-node

Getting Started

Import

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";

Usage

To send a request, you:

• Initiate client with configuration (e.g. credentials, region). For more information you can refer to the API reference.
• Initiate command with input parameters.
• Call send operation on client with command object as input.
• If you are using a custom http handler, you may call 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
});

Troubleshooting

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;
    }
*/
}

Getting Help

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.

• Ask a question on StackOverflow and tag it with aws-sdk-js
• Come join the AWS JavaScript community on gitter
• If it turns out that you may have found a bug, please open an issue

Contributing

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.

License

This SDK is distributed under the Apache License, Version 2.0, see LICENSE for more information.