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