class OpenStax::Aws::MskCluster

Attributes

client[R]
cluster_arn[R]

Public Class Methods

new(cluster_arn:, region:) click to toggle source
# File lib/openstax/aws/msk_cluster.rb, line 8
def initialize(cluster_arn:, region:)
  @cluster_arn = cluster_arn
  @client = ::Aws::Kafka::Client.new(region: region)
end

Public Instance Methods

bootstrap_broker_string() click to toggle source
# File lib/openstax/aws/msk_cluster.rb, line 13
def bootstrap_broker_string
  client.get_bootstrap_brokers(cluster_arn: cluster_arn).bootstrap_broker_string
end
sorted_bootstrap_broker_string() click to toggle source
# File lib/openstax/aws/msk_cluster.rb, line 17
def sorted_bootstrap_broker_string
  bootstrap_broker_string.split(',').sort.join(',')
end