Contents

module OpenStax::Aws
  class MskCluster

    attr_reader :client, :cluster_arn

    delegate_missing_to :@client

    def self.physical_resource_id_attribute
      :cluster_arn
    end

    def initialize(cluster_arn:, region:)
      @cluster_arn = cluster_arn
      @client = ::Aws::Kafka::Client.new(region: region)
    end

    def bootstrap_broker_string
      client.get_bootstrap_brokers(cluster_arn: cluster_arn).bootstrap_broker_string
    end

    def sorted_bootstrap_broker_string
      bootstrap_broker_string.split(',').sort.join(',')
    end

  end
end

Version data entries

6 entries across 6 versions & 1 rubygems

Version	Path
openstax_aws-2.1.0	lib/openstax/aws/msk_cluster.rb
openstax_aws-2.0.1	lib/openstax/aws/msk_cluster.rb
openstax_aws-2.0.0	lib/openstax/aws/msk_cluster.rb
openstax_aws-1.6.1	lib/openstax/aws/msk_cluster.rb
openstax_aws-1.6.0	lib/openstax/aws/msk_cluster.rb
openstax_aws-1.5.0	lib/openstax/aws/msk_cluster.rb