Module: KafkaCommand

Defined in:

lib/kafka_command.rb,
app/jobs/application_job.rb,
lib/kafka_command/engine.rb,
lib/kafka_command/errors.rb,
lib/kafka_command/version.rb,
app/mailers/application_mailer.rb,
app/models/kafka_command/topic.rb,
app/models/kafka_command/broker.rb,
app/models/kafka_command/client.rb,
lib/kafka_command/configuration.rb,
app/models/kafka_command/cluster.rb,
app/models/kafka_command/partition.rb,
app/models/kafka_command/group_member.rb,
app/models/kafka_command/consumer_group.rb,
app/helpers/kafka_command/application_helper.rb,
app/controllers/kafka_command/topics_controller.rb,
app/helpers/kafka_command/consumer_group_helper.rb,
app/controllers/kafka_command/brokers_controller.rb,
app/controllers/kafka_command/clusters_controller.rb,
app/models/kafka_command/consumer_group_partition.rb,
app/controllers/kafka_command/application_controller.rb,
app/controllers/kafka_command/consumer_groups_controller.rb

Defined Under Namespace

Modules: ApplicationHelper, ConsumerGroupHelper Classes: ApplicationController, ApplicationJob, ApplicationMailer, Broker, BrokersController, Client, Cluster, ClustersController, Configuration, ConfigurationError, ConsumerGroup, ConsumerGroupPartition, ConsumerGroupsController, Engine, GroupMember, Partition, Topic, TopicsController, UnsupportedApiError

Constant Summary

VERSION =

'0.0.1'

Class Method Summary

• .config ⇒ Object
• .config=(config_hash) ⇒ Object

Class Method Details

.config ⇒ Object

# File 'lib/kafka_command/configuration.rb', line 8

def self.config
  @config
end

.config=(config_hash) ⇒ Object

# File 'lib/kafka_command/configuration.rb', line 4

def self.config=(config_hash)
  @config ||= Configuration.new(config_hash)
end