Product
Introducing SSO
Streamline your login process and enhance security by enabling Single Sign-On (SSO) on the Socket platform, now available for all customers on the Enterprise plan, supporting 20+ identity providers.
@jm18457/kafkajs-msk-iam-authentication-mechanism
Advanced tools
Changelog
Readme
Requires kafkajs
version 2.2.0
or higher.
For more information look at https://kafka.js.org/docs/next/configuration#custom-authentication-mechanisms.
npm i @jm18457/kafkajs-msk-iam-authentication-mechanism
const { Kafka } = require('kafkajs')
const {
createMechanism
} = require('@jm18457/kafkajs-msk-iam-authentication-mechanism')
const kafka = new Kafka({
brokers: ['kafka1:9092', 'kafka2:9092'],
clientId: 'my-app',
ssl: true,
sasl: createMechanism({ region: 'eu-central-1' })
})
You can also use the old way of importing the library.
const { Kafka } = require('kafkajs')
const {
Type,
awsIamAuthenticator,
} = require('@jm18457/kafkajs-msk-iam-authentication-mechanism')
const provider = awsIamAuthenticator({
region: 'eu-central-1'
})
const kafka = new Kafka({
brokers: ['kafka1:9092', 'kafka2:9092'],
clientId: 'my-app',
ssl: true,
sasl: {
mechanism: Type,
authenticationProvider: provider
}
})
For working examples look at the examples
folder.
Ƭ Options: Object
Name | Type | Description |
---|---|---|
credentials? | AwsCredentialIdentity | Provider <AwsCredentialIdentity > | Default fromNodeProviderChain() |
region | string | The AWS region in which the Kafka broker exists. |
ttl? | string | Provides the time period, in seconds, for which the generated presigned URL is valid. Default 900 |
userAgent? | string | Is a string passed in by the client library to describe the client. Default MSK_IAM |
• Const
TYPE: "AWS_MSK_IAM"
• Const
Type: "AWS_MSK_IAM"
▸ awsIamAuthenticator(options
): (args
: AuthenticationProviderArgs
) => Authenticator
Name | Type |
---|---|
options | Options |
fn
▸ (args
): Authenticator
Name | Type |
---|---|
args | AuthenticationProviderArgs |
Authenticator
▸ createAuthenticator(options
): (args
: AuthenticationProviderArgs
) => Authenticator
Name | Type |
---|---|
options | Options |
fn
▸ (args
): Authenticator
Name | Type |
---|---|
args | AuthenticationProviderArgs |
Authenticator
▸ createMechanism(options
, mechanism?
): Mechanism
Name | Type | Default value |
---|---|---|
options | Options | undefined |
mechanism | string | TYPE |
Mechanism
FAQs
Authentication mechanism for AWS MSK IAM for KafkaJS.
The npm package @jm18457/kafkajs-msk-iam-authentication-mechanism receives a total of 23,832 weekly downloads. As such, @jm18457/kafkajs-msk-iam-authentication-mechanism popularity was classified as popular.
We found that @jm18457/kafkajs-msk-iam-authentication-mechanism demonstrated a healthy version release cadence and project activity because the last version was released less than a year ago. It has 1 open source maintainer 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
Streamline your login process and enhance security by enabling Single Sign-On (SSO) on the Socket platform, now available for all customers on the Enterprise plan, supporting 20+ identity providers.
Security News
Tea.xyz, a crypto project aimed at rewarding open source contributions, is once again facing backlash due to an influx of spam packages flooding public package registries.
Security News
As cyber threats become more autonomous, AI-powered defenses are crucial for businesses to stay ahead of attackers who can exploit software vulnerabilities at scale.