npm package discovery and stats viewer.

Discover Tips

  • General search

    [free text search, go nuts!]

  • Package details

    pkg:[package-name]

  • User packages

    @[username]

Sponsor

Optimize Toolset

I’ve always been into building performant and accessible sites, but lately I’ve been taking it extremely seriously. So much so that I’ve been building a tool to help me optimize and monitor the sites that I build to make sure that I’m making an attempt to offer the best experience to those who visit them. If you’re into performant, accessible and SEO friendly sites, you might like it too! You can check it out at Optimize Toolset.

About

Hi, 👋, I’m Ryan Hefner  and I built this site for me, and you! The goal of this site was to provide an easy way for me to check the stats on my npm packages, both for prioritizing issues and updates, and to give me a little kick in the pants to keep up on stuff.

As I was building it, I realized that I was actually using the tool to build the tool, and figured I might as well put this out there and hopefully others will find it to be a fast and useful way to search and browse npm packages as I have.

If you’re interested in other things I’m working on, follow me on Twitter or check out the open source projects I’ve been publishing on GitHub.

I am also working on a Twitter bot for this site to tweet the most popular, newest, random packages from npm. Please follow that account now and it will start sending out packages soon–ish.

Open Software & Tools

This site wouldn’t be possible without the immense generosity and tireless efforts from the people who make contributions to the world and share their work via open source initiatives. Thank you 🙏

© 2024 – Pkg Stats / Ryan Hefner

@datafire/amazonaws_kafka

v5.0.0

Published

DataFire integration for Managed Streaming for Kafka

Downloads

3

Vulnerabilities

Powered byPowered by Snyk
  • 0High
  • 0Medium
  • 0Low

Links

Git

Maintainers

datafiredatafire

Keywords

Readme

@datafire/amazonaws_kafka

Client library for Managed Streaming for Kafka

Installation and Usage

npm install --save @datafire/amazonaws_kafka
let amazonaws_kafka = require('@datafire/amazonaws_kafka').create({
  accessKeyId: "",
  secretAccessKey: "",
  region: ""
});

.then(data => {
  console.log(data);
});

Description

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

Actions

ListClusters

amazonaws_kafka.ListClusters({}, context)

Input

  • input object
    • clusterNameFilter string
    • maxResults integer
    • nextToken string
    • MaxResults string
    • NextToken string

Output

CreateCluster

amazonaws_kafka.CreateCluster({
  "brokerNodeGroupInfo": {},
  "clusterName": "",
  "kafkaVersion": "",
  "numberOfBrokerNodes": 0
}, context)

Input

  • input object
    • tags object:
    • brokerNodeGroupInfo required object:
      • BrokerAZDistribution
      • ClientSubnets
      • InstanceType
      • SecurityGroups
      • StorageInfo
        • EbsStorageInfo
          • VolumeSize
    • clientAuthentication object:
      • Sasl
        • Scram
          • Enabled
      • Tls
        • CertificateAuthorityArnList
    • clusterName required string:
    • configurationInfo object:
      • Arn
      • Revision
    • encryptionInfo object:
      • EncryptionAtRest
        • DataVolumeKMSKeyId required
      • EncryptionInTransit
        • ClientBroker
        • InCluster
    • enhancedMonitoring string (values: DEFAULT, PER_BROKER, PER_TOPIC_PER_BROKER, PER_TOPIC_PER_PARTITION):
    • kafkaVersion required string:
    • loggingInfo object
      • BrokerLogs
        • CloudWatchLogs
          • Enabled required
          • LogGroup
        • Firehose
          • DeliveryStream
          • Enabled required
        • S3
          • Bucket
          • Enabled required
          • Prefix
    • numberOfBrokerNodes required integer:
    • openMonitoring object:
      • Prometheus
        • JmxExporter
          • EnabledInBroker required
        • NodeExporter
          • EnabledInBroker required

Output

DeleteCluster

amazonaws_kafka.DeleteCluster({
  "clusterArn": ""
}, context)

Input

  • input object
    • clusterArn required string
    • currentVersion string

Output

DescribeCluster

amazonaws_kafka.DescribeCluster({
  "clusterArn": ""
}, context)

Input

  • input object
    • clusterArn required string

Output

GetBootstrapBrokers

amazonaws_kafka.GetBootstrapBrokers({
  "clusterArn": ""
}, context)

Input

  • input object
    • clusterArn required string

Output

UpdateClusterConfiguration

amazonaws_kafka.UpdateClusterConfiguration({
  "clusterArn": "",
  "configurationInfo": {},
  "currentVersion": ""
}, context)

Input

  • input object
    • clusterArn required string
    • configurationInfo required object:
      • Arn
      • Revision
    • currentVersion required string:

Output

UpdateMonitoring

amazonaws_kafka.UpdateMonitoring({
  "clusterArn": "",
  "currentVersion": ""
}, context)

Input

  • input object
    • clusterArn required string
    • currentVersion required string:
    • enhancedMonitoring string (values: DEFAULT, PER_BROKER, PER_TOPIC_PER_BROKER, PER_TOPIC_PER_PARTITION):
    • loggingInfo object
      • BrokerLogs
        • CloudWatchLogs
          • Enabled required
          • LogGroup
        • Firehose
          • DeliveryStream
          • Enabled required
        • S3
          • Bucket
          • Enabled required
          • Prefix
    • openMonitoring object:
      • Prometheus
        • JmxExporter
          • EnabledInBroker required
        • NodeExporter
          • EnabledInBroker required

Output

ListNodes

amazonaws_kafka.ListNodes({
  "clusterArn": ""
}, context)

Input

  • input object
    • clusterArn required string
    • maxResults integer
    • nextToken string
    • MaxResults string
    • NextToken string

Output

UpdateBrokerCount

amazonaws_kafka.UpdateBrokerCount({
  "clusterArn": "",
  "currentVersion": "",
  "targetNumberOfBrokerNodes": 0
}, context)

Input

  • input object
    • clusterArn required string
    • currentVersion required string:
    • targetNumberOfBrokerNodes required integer:

Output

UpdateBrokerStorage

amazonaws_kafka.UpdateBrokerStorage({
  "clusterArn": "",
  "currentVersion": "",
  "targetBrokerEBSVolumeInfo": []
}, context)

Input

  • input object
    • clusterArn required string
    • currentVersion required string:
    • targetBrokerEBSVolumeInfo required array:

Output

ListClusterOperations

amazonaws_kafka.ListClusterOperations({
  "clusterArn": ""
}, context)

Input

  • input object
    • clusterArn required string
    • maxResults integer
    • nextToken string
    • MaxResults string
    • NextToken string

Output

RebootBroker

amazonaws_kafka.RebootBroker({
  "clusterArn": "",
  "brokerIds": []
}, context)

Input

  • input object
    • clusterArn required string
    • brokerIds required array:

Output

ListScramSecrets

amazonaws_kafka.ListScramSecrets({
  "clusterArn": ""
}, context)

Input

  • input object
    • clusterArn required string
    • maxResults integer
    • nextToken string
    • MaxResults string
    • NextToken string

Output

BatchDisassociateScramSecret

amazonaws_kafka.BatchDisassociateScramSecret({
  "clusterArn": "",
  "secretArnList": []
}, context)

Input

  • input object
    • clusterArn required string
    • secretArnList required array:

Output

BatchAssociateScramSecret

amazonaws_kafka.BatchAssociateScramSecret({
  "clusterArn": "",
  "secretArnList": []
}, context)

Input

  • input object
    • clusterArn required string
    • secretArnList required array:

Output

UpdateClusterKafkaVersion

amazonaws_kafka.UpdateClusterKafkaVersion({
  "clusterArn": "",
  "currentVersion": "",
  "targetKafkaVersion": ""
}, context)

Input

  • input object
    • clusterArn required string
    • configurationInfo object:
      • Arn
      • Revision
    • currentVersion required string:
    • targetKafkaVersion required string:

Output

GetCompatibleKafkaVersions

amazonaws_kafka.GetCompatibleKafkaVersions({}, context)

Input

  • input object
    • clusterArn string

Output

ListConfigurations

amazonaws_kafka.ListConfigurations({}, context)

Input

  • input object
    • maxResults integer
    • nextToken string
    • MaxResults string
    • NextToken string

Output

CreateConfiguration

amazonaws_kafka.CreateConfiguration({
  "name": "",
  "serverProperties": ""
}, context)

Input

  • input object
    • description string:
    • kafkaVersions array:
    • name required string:
    • serverProperties required string:

Output

DeleteConfiguration

amazonaws_kafka.DeleteConfiguration({
  "arn": ""
}, context)

Input

  • input object
    • arn required string

Output

DescribeConfiguration

amazonaws_kafka.DescribeConfiguration({
  "arn": ""
}, context)

Input

  • input object
    • arn required string

Output

UpdateConfiguration

amazonaws_kafka.UpdateConfiguration({
  "arn": "",
  "serverProperties": ""
}, context)

Input

  • input object
    • arn required string
    • description string:
    • serverProperties required string:

Output

ListConfigurationRevisions

amazonaws_kafka.ListConfigurationRevisions({
  "arn": ""
}, context)

Input

  • input object
    • arn required string
    • maxResults integer
    • nextToken string
    • MaxResults string
    • NextToken string

Output

DescribeConfigurationRevision

amazonaws_kafka.DescribeConfigurationRevision({
  "arn": "",
  "revision": 0
}, context)

Input

  • input object
    • arn required string
    • revision required integer

Output

ListKafkaVersions

amazonaws_kafka.ListKafkaVersions({}, context)

Input

  • input object
    • maxResults integer
    • nextToken string
    • MaxResults string
    • NextToken string

Output

DescribeClusterOperation

amazonaws_kafka.DescribeClusterOperation({
  "clusterOperationArn": ""
}, context)

Input

  • input object
    • clusterOperationArn required string

Output

ListTagsForResource

amazonaws_kafka.ListTagsForResource({
  "resourceArn": ""
}, context)

Input

  • input object
    • resourceArn required string

Output

TagResource

amazonaws_kafka.TagResource({
  "resourceArn": "",
  "tags": {}
}, context)

Input

  • input object
    • resourceArn required string
    • tags required object:

Output

Output schema unknown

UntagResource

amazonaws_kafka.UntagResource({
  "resourceArn": "",
  "tagKeys": []
}, context)

Input

  • input object
    • resourceArn required string
    • tagKeys required array

Output

Output schema unknown

Definitions

BadRequestException

BatchAssociateScramSecretRequest

  • BatchAssociateScramSecretRequest object:

BatchAssociateScramSecretResponse

BatchDisassociateScramSecretRequest

  • BatchDisassociateScramSecretRequest object:

BatchDisassociateScramSecretResponse

BrokerAZDistribution

  • BrokerAZDistribution string (values: DEFAULT):

BrokerEBSVolumeInfo

  • BrokerEBSVolumeInfo object:
    • KafkaBrokerNodeId required
    • VolumeSizeGB required

BrokerLogs

  • BrokerLogs object
    • CloudWatchLogs
      • Enabled required
      • LogGroup
    • Firehose
      • DeliveryStream
      • Enabled required
    • S3
      • Bucket
      • Enabled required
      • Prefix

BrokerNodeGroupInfo

  • BrokerNodeGroupInfo object:
    • BrokerAZDistribution
    • ClientSubnets required
    • InstanceType required
    • SecurityGroups
    • StorageInfo
      • EbsStorageInfo
        • VolumeSize

BrokerNodeInfo

  • BrokerNodeInfo object:
    • AttachedENIId
    • BrokerId
    • ClientSubnet
    • ClientVpcIpAddress
    • CurrentBrokerSoftwareInfo
      • ConfigurationArn
      • ConfigurationRevision
      • KafkaVersion
    • Endpoints

BrokerSoftwareInfo

  • BrokerSoftwareInfo object:
    • ConfigurationArn
    • ConfigurationRevision
    • KafkaVersion

ClientAuthentication

  • ClientAuthentication object:
    • Sasl
      • Scram
        • Enabled
    • Tls
      • CertificateAuthorityArnList

ClientBroker

  • ClientBroker string (values: TLS, TLS_PLAINTEXT, PLAINTEXT):

CloudWatchLogs

  • CloudWatchLogs object
    • Enabled required
    • LogGroup

ClusterInfo

  • ClusterInfo object:
    • ActiveOperationArn
    • BrokerNodeGroupInfo
      • BrokerAZDistribution
      • ClientSubnets required
      • InstanceType required
      • SecurityGroups
      • StorageInfo
        • EbsStorageInfo
          • VolumeSize
    • ClientAuthentication
      • Sasl
        • Scram
          • Enabled
      • Tls
        • CertificateAuthorityArnList
    • ClusterArn
    • ClusterName
    • CreationTime
    • CurrentBrokerSoftwareInfo
      • ConfigurationArn
      • ConfigurationRevision
      • KafkaVersion
    • CurrentVersion
    • EncryptionInfo
      • EncryptionAtRest
        • DataVolumeKMSKeyId required
      • EncryptionInTransit
        • ClientBroker
        • InCluster
    • EnhancedMonitoring
    • LoggingInfo
      • BrokerLogs required
        • CloudWatchLogs
          • Enabled required
          • LogGroup
        • Firehose
          • DeliveryStream
          • Enabled required
        • S3
          • Bucket
          • Enabled required
          • Prefix
    • NumberOfBrokerNodes
    • OpenMonitoring
      • Prometheus required
        • JmxExporter
          • EnabledInBroker required
        • NodeExporter
          • EnabledInBroker required
    • State
    • StateInfo
      • Code
      • Message
    • Tags
    • ZookeeperConnectString
    • ZookeeperConnectStringTls

ClusterOperationInfo

  • ClusterOperationInfo object:
    • ClientRequestId
    • ClusterArn
    • CreationTime
    • EndTime
    • ErrorInfo
      • ErrorCode
      • ErrorString
    • OperationArn
    • OperationState
    • OperationSteps
    • OperationType
    • SourceClusterInfo
      • BrokerEBSVolumeInfo
      • ConfigurationInfo
        • Arn required
        • Revision required
      • EnhancedMonitoring
      • KafkaVersion
      • LoggingInfo
        • BrokerLogs required
          • CloudWatchLogs
            • Enabled required
            • LogGroup
          • Firehose
            • DeliveryStream
            • Enabled required
          • S3
            • Bucket
            • Enabled required
            • Prefix
      • NumberOfBrokerNodes
      • OpenMonitoring
        • Prometheus required
          • JmxExporter
            • EnabledInBroker required
          • NodeExporter
            • EnabledInBroker required
    • TargetClusterInfo
      • BrokerEBSVolumeInfo
      • ConfigurationInfo
        • Arn required
        • Revision required
      • EnhancedMonitoring
      • KafkaVersion
      • LoggingInfo
        • BrokerLogs required
          • CloudWatchLogs
            • Enabled required
            • LogGroup
          • Firehose
            • DeliveryStream
            • Enabled required
          • S3
            • Bucket
            • Enabled required
            • Prefix
      • NumberOfBrokerNodes
      • OpenMonitoring
        • Prometheus required
          • JmxExporter
            • EnabledInBroker required
          • NodeExporter
            • EnabledInBroker required

ClusterOperationStep

  • ClusterOperationStep object:
    • StepInfo
      • StepStatus
    • StepName

ClusterOperationStepInfo

  • ClusterOperationStepInfo object:
    • StepStatus

ClusterState

  • ClusterState string (values: ACTIVE, CREATING, DELETING, FAILED, HEALING, MAINTENANCE, REBOOTING_BROKER, UPDATING):

CompatibleKafkaVersion

  • CompatibleKafkaVersion object:
    • SourceVersion
    • TargetVersions

Configuration

  • Configuration object:
    • Arn required
    • CreationTime required
    • Description required
    • KafkaVersions required
    • LatestRevision required
      • CreationTime required
      • Description
      • Revision required
    • Name required
    • State required

ConfigurationInfo

  • ConfigurationInfo object:
    • Arn required
    • Revision required

ConfigurationRevision

  • ConfigurationRevision object:
    • CreationTime required
    • Description
    • Revision required

ConfigurationState

  • ConfigurationState string (values: ACTIVE, DELETING, DELETE_FAILED):

ConflictException

CreateClusterRequest

  • CreateClusterRequest object
    • BrokerNodeGroupInfo required
      • BrokerAZDistribution
      • ClientSubnets required
      • InstanceType required
      • SecurityGroups
      • StorageInfo
        • EbsStorageInfo
          • VolumeSize
    • ClientAuthentication
      • Sasl
        • Scram
          • Enabled
      • Tls
        • CertificateAuthorityArnList
    • ClusterName required
    • ConfigurationInfo
      • Arn required
      • Revision required
    • EncryptionInfo
      • EncryptionAtRest
        • DataVolumeKMSKeyId required
      • EncryptionInTransit
        • ClientBroker
        • InCluster
    • EnhancedMonitoring
    • KafkaVersion required
    • LoggingInfo
      • BrokerLogs required
        • CloudWatchLogs
          • Enabled required
          • LogGroup
        • Firehose
          • DeliveryStream
          • Enabled required
        • S3
          • Bucket
          • Enabled required
          • Prefix
    • NumberOfBrokerNodes required
    • OpenMonitoring
      • Prometheus required
        • JmxExporter
          • EnabledInBroker required
        • NodeExporter
          • EnabledInBroker required
    • Tags

CreateClusterResponse

  • CreateClusterResponse object
    • ClusterArn
    • ClusterName
    • State

CreateConfigurationRequest

  • CreateConfigurationRequest object
    • Description
    • KafkaVersions
    • Name required
    • ServerProperties required

CreateConfigurationResponse

  • CreateConfigurationResponse object
    • Arn
    • CreationTime
    • LatestRevision
      • CreationTime required
      • Description
      • Revision required
    • Name
    • State

DeleteClusterRequest

  • DeleteClusterRequest object

DeleteClusterResponse

  • DeleteClusterResponse object
    • ClusterArn
    • State

DeleteConfigurationRequest

  • DeleteConfigurationRequest object

DeleteConfigurationResponse

  • DeleteConfigurationResponse object
    • Arn
    • State

DescribeClusterOperationRequest

  • DescribeClusterOperationRequest object

DescribeClusterOperationResponse

  • DescribeClusterOperationResponse object
    • ClusterOperationInfo
      • ClientRequestId
      • ClusterArn
      • CreationTime
      • EndTime
      • ErrorInfo
        • ErrorCode
        • ErrorString
      • OperationArn
      • OperationState
      • OperationSteps
      • OperationType
      • SourceClusterInfo
        • BrokerEBSVolumeInfo
        • ConfigurationInfo
          • Arn required
          • Revision required
        • EnhancedMonitoring
        • KafkaVersion
        • LoggingInfo
          • BrokerLogs required
            • CloudWatchLogs
            • Firehose
            • S3
        • NumberOfBrokerNodes
        • OpenMonitoring
          • Prometheus required
            • JmxExporter
            • NodeExporter
      • TargetClusterInfo
        • BrokerEBSVolumeInfo
        • ConfigurationInfo
          • Arn required
          • Revision required
        • EnhancedMonitoring
        • KafkaVersion
        • LoggingInfo
          • BrokerLogs required
            • CloudWatchLogs
            • Firehose
            • S3
        • NumberOfBrokerNodes
        • OpenMonitoring
          • Prometheus required
            • JmxExporter
            • NodeExporter

DescribeClusterRequest

  • DescribeClusterRequest object

DescribeClusterResponse

  • DescribeClusterResponse object
    • ClusterInfo
      • ActiveOperationArn
      • BrokerNodeGroupInfo
        • BrokerAZDistribution
        • ClientSubnets required
        • InstanceType required
        • SecurityGroups
        • StorageInfo
          • EbsStorageInfo
            • VolumeSize
      • ClientAuthentication
        • Sasl
          • Scram
            • Enabled
        • Tls
          • CertificateAuthorityArnList
      • ClusterArn
      • ClusterName
      • CreationTime
      • CurrentBrokerSoftwareInfo
        • ConfigurationArn
        • ConfigurationRevision
        • KafkaVersion
      • CurrentVersion
      • EncryptionInfo
        • EncryptionAtRest
          • DataVolumeKMSKeyId required
        • EncryptionInTransit
          • ClientBroker
          • InCluster
      • EnhancedMonitoring
      • LoggingInfo
        • BrokerLogs required
          • CloudWatchLogs
            • Enabled required
            • LogGroup
          • Firehose
            • DeliveryStream
            • Enabled required
          • S3
            • Bucket
            • Enabled required
            • Prefix
      • NumberOfBrokerNodes
      • OpenMonitoring
        • Prometheus required
          • JmxExporter
            • EnabledInBroker required
          • NodeExporter
            • EnabledInBroker required
      • State
      • StateInfo
        • Code
        • Message
      • Tags
      • ZookeeperConnectString
      • ZookeeperConnectStringTls

DescribeConfigurationRequest

  • DescribeConfigurationRequest object

DescribeConfigurationResponse

  • DescribeConfigurationResponse object
    • Arn
    • CreationTime
    • Description
    • KafkaVersions
    • LatestRevision
      • CreationTime required
      • Description
      • Revision required
    • Name
    • State

DescribeConfigurationRevisionRequest

  • DescribeConfigurationRevisionRequest object

DescribeConfigurationRevisionResponse

  • DescribeConfigurationRevisionResponse object
    • Arn
    • CreationTime
    • Description
    • Revision
    • ServerProperties

EBSStorageInfo

  • EBSStorageInfo object:
    • VolumeSize

EncryptionAtRest

  • EncryptionAtRest object:
    • DataVolumeKMSKeyId required

EncryptionInTransit

  • EncryptionInTransit object:
    • ClientBroker
    • InCluster

EncryptionInfo

  • EncryptionInfo object:
    • EncryptionAtRest
      • DataVolumeKMSKeyId required
    • EncryptionInTransit
      • ClientBroker
      • InCluster

EnhancedMonitoring

  • EnhancedMonitoring string (values: DEFAULT, PER_BROKER, PER_TOPIC_PER_BROKER, PER_TOPIC_PER_PARTITION):

ErrorInfo

  • ErrorInfo object:
    • ErrorCode
    • ErrorString

Firehose

  • Firehose object
    • DeliveryStream
    • Enabled required

ForbiddenException

GetBootstrapBrokersRequest

  • GetBootstrapBrokersRequest object

GetBootstrapBrokersResponse

  • GetBootstrapBrokersResponse object
    • BootstrapBrokerString
    • BootstrapBrokerStringSaslScram
    • BootstrapBrokerStringTls

GetCompatibleKafkaVersionsRequest

  • GetCompatibleKafkaVersionsRequest object

GetCompatibleKafkaVersionsResponse

InternalServerErrorException

JmxExporter

  • JmxExporter object:
    • EnabledInBroker required

JmxExporterInfo

  • JmxExporterInfo object:
    • EnabledInBroker required

KafkaVersion

  • KafkaVersion object
    • Status
    • Version

KafkaVersionStatus

  • KafkaVersionStatus string (values: ACTIVE, DEPRECATED)

ListClusterOperationsRequest

  • ListClusterOperationsRequest object

ListClusterOperationsResponse

ListClustersRequest

  • ListClustersRequest object

ListClustersResponse

  • ListClustersResponse object

ListConfigurationRevisionsRequest

  • ListConfigurationRevisionsRequest object

ListConfigurationRevisionsResponse

ListConfigurationsRequest

  • ListConfigurationsRequest object

ListConfigurationsResponse

  • ListConfigurationsResponse object

ListKafkaVersionsRequest

  • ListKafkaVersionsRequest object

ListKafkaVersionsResponse

  • ListKafkaVersionsResponse object

ListNodesRequest

  • ListNodesRequest object

ListNodesResponse

  • ListNodesResponse object

ListScramSecretsRequest

  • ListScramSecretsRequest object

ListScramSecretsResponse

  • ListScramSecretsResponse object

ListTagsForResourceRequest

  • ListTagsForResourceRequest object

ListTagsForResourceResponse

  • ListTagsForResourceResponse object
    • Tags

LoggingInfo

  • LoggingInfo object
    • BrokerLogs required
      • CloudWatchLogs
        • Enabled required
        • LogGroup
      • Firehose
        • DeliveryStream
        • Enabled required
      • S3
        • Bucket
        • Enabled required
        • Prefix

MaxResults

  • MaxResults integer

MutableClusterInfo

  • MutableClusterInfo object:
    • BrokerEBSVolumeInfo
    • ConfigurationInfo
      • Arn required
      • Revision required
    • EnhancedMonitoring
    • KafkaVersion
    • LoggingInfo
      • BrokerLogs required
        • CloudWatchLogs
          • Enabled required
          • LogGroup
        • Firehose
          • DeliveryStream
          • Enabled required
        • S3
          • Bucket
          • Enabled required
          • Prefix
    • NumberOfBrokerNodes
    • OpenMonitoring
      • Prometheus required
        • JmxExporter
          • EnabledInBroker required
        • NodeExporter
          • EnabledInBroker required

NodeExporter

  • NodeExporter object:
    • EnabledInBroker required

NodeExporterInfo

  • NodeExporterInfo object:
    • EnabledInBroker required

NodeInfo

  • NodeInfo object:
    • AddedToClusterTime
    • BrokerNodeInfo
      • AttachedENIId
      • BrokerId
      • ClientSubnet
      • ClientVpcIpAddress
      • CurrentBrokerSoftwareInfo
        • ConfigurationArn
        • ConfigurationRevision
        • KafkaVersion
      • Endpoints
    • InstanceType
    • NodeARN
    • NodeType
    • ZookeeperNodeInfo
      • AttachedENIId
      • ClientVpcIpAddress
      • Endpoints
      • ZookeeperId
      • ZookeeperVersion

NodeType

  • NodeType string (values: BROKER):

NotFoundException

OpenMonitoring

  • OpenMonitoring object:
    • Prometheus required
      • JmxExporter
        • EnabledInBroker required
      • NodeExporter
        • EnabledInBroker required

OpenMonitoringInfo

  • OpenMonitoringInfo object:
    • Prometheus required
      • JmxExporter
        • EnabledInBroker required
      • NodeExporter
        • EnabledInBroker required

Prometheus

  • Prometheus object:
    • JmxExporter
      • EnabledInBroker required
    • NodeExporter
      • EnabledInBroker required

PrometheusInfo

  • PrometheusInfo object:
    • JmxExporter
      • EnabledInBroker required
    • NodeExporter
      • EnabledInBroker required

RebootBrokerRequest

  • RebootBrokerRequest object: Reboots a node.

RebootBrokerResponse

  • RebootBrokerResponse object
    • ClusterArn
    • ClusterOperationArn

S3

  • S3 object
    • Bucket
    • Enabled required
    • Prefix

Sasl

  • Sasl object:
    • Scram
      • Enabled

Scram

  • Scram object:
    • Enabled

ServiceUnavailableException

StateInfo

  • StateInfo object
    • Code
    • Message

StorageInfo

  • StorageInfo object:
    • EbsStorageInfo
      • VolumeSize

TagResourceRequest

  • TagResourceRequest object
    • Tags required

Tls

  • Tls object:
    • CertificateAuthorityArnList

TooManyRequestsException

UnauthorizedException

UnprocessedScramSecret

  • UnprocessedScramSecret object:
    • ErrorCode
    • ErrorMessage
    • SecretArn

UntagResourceRequest

  • UntagResourceRequest object

UpdateBrokerCountRequest

  • UpdateBrokerCountRequest object
    • CurrentVersion required
    • TargetNumberOfBrokerNodes required

UpdateBrokerCountResponse

  • UpdateBrokerCountResponse object
    • ClusterArn
    • ClusterOperationArn

UpdateBrokerStorageRequest

  • UpdateBrokerStorageRequest object

UpdateBrokerStorageResponse

  • UpdateBrokerStorageResponse object
    • ClusterArn
    • ClusterOperationArn

UpdateClusterConfigurationRequest

  • UpdateClusterConfigurationRequest object
    • ConfigurationInfo required
      • Arn required
      • Revision required
    • CurrentVersion required

UpdateClusterConfigurationResponse

  • UpdateClusterConfigurationResponse object
    • ClusterArn
    • ClusterOperationArn

UpdateClusterKafkaVersionRequest

  • UpdateClusterKafkaVersionRequest object
    • ConfigurationInfo
      • Arn required
      • Revision required
    • CurrentVersion required
    • TargetKafkaVersion required

UpdateClusterKafkaVersionResponse

  • UpdateClusterKafkaVersionResponse object
    • ClusterArn
    • ClusterOperationArn

UpdateConfigurationRequest

  • UpdateConfigurationRequest object
    • Description
    • ServerProperties required

UpdateConfigurationResponse

  • UpdateConfigurationResponse object
    • Arn
    • LatestRevision
      • CreationTime required
      • Description
      • Revision required

UpdateMonitoringRequest

  • UpdateMonitoringRequest object: Request body for UpdateMonitoring.
    • CurrentVersion required
    • EnhancedMonitoring
    • LoggingInfo
      • BrokerLogs required
        • CloudWatchLogs
          • Enabled required
          • LogGroup
        • Firehose
          • DeliveryStream
          • Enabled required
        • S3
          • Bucket
          • Enabled required
          • Prefix
    • OpenMonitoring
      • Prometheus required
        • JmxExporter
          • EnabledInBroker required
        • NodeExporter
          • EnabledInBroker required

UpdateMonitoringResponse

  • UpdateMonitoringResponse object
    • ClusterArn
    • ClusterOperationArn

ZookeeperNodeInfo

  • ZookeeperNodeInfo object:
    • AttachedENIId
    • ClientVpcIpAddress
    • Endpoints
    • ZookeeperId
    • ZookeeperVersion

__blob

  • __blob string

__boolean

  • __boolean boolean

__double

  • __double number

__integer

  • __integer integer

__integerMin1Max15

  • __integerMin1Max15 integer

__integerMin1Max16384

  • __integerMin1Max16384 integer

__listOfBrokerEBSVolumeInfo

__listOfClusterInfo

__listOfClusterOperationInfo

__listOfClusterOperationStep

__listOfCompatibleKafkaVersion

__listOfConfiguration

__listOfConfigurationRevision

__listOfKafkaVersion

__listOfNodeInfo

__listOfUnprocessedScramSecret

__listOf__string

__long

  • __long integer

__mapOf__string

  • __mapOf__string object

__string

  • __string string

__stringMin1Max128

  • __stringMin1Max128 string

__stringMin1Max64

  • __stringMin1Max64 string

__stringMin5Max32

  • __stringMin5Max32 string

__timestampIso8601

  • __timestampIso8601 string