Contents

module OpenStax::Aws
  class MskCluster

    attr_reader :client, :cluster_arn

    delegate_missing_to :@client

    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

3 entries across 3 versions & 1 rubygems

Version	Path
openstax_aws-1.4.0	lib/openstax/aws/msk_cluster.rb
openstax_aws-1.3.0	lib/openstax/aws/msk_cluster.rb
openstax_aws-1.2.0	lib/openstax/aws/msk_cluster.rb