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

  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
openstax_aws-1.1.0	lib/openstax/aws/msk_cluster.rb
openstax_aws-1.0.0	lib/openstax/aws/msk_cluster.rb