Sha256: ab2d9696f0eddc26e4cedcd9d610ad6399b78d7412039b2e164110204b6f6661

Contents?: true

Size: 213 Bytes

Versions: 22

Compression:

Stored size: 213 Bytes

Contents

# frozen_string_literal: true

<%- module_namespacing do -%>
class <%= @consumer_name %> < Sbmt::KafkaConsumer::BaseConsumer
  def process_message(_message)
    # Add message processing here
  end
end
<%- end -%>

Version data entries

22 entries across 22 versions & 1 rubygems

Version Path
sbmt-kafka_consumer-2.1.0 lib/generators/kafka_consumer/consumer/templates/consumer.rb.erb
sbmt-kafka_consumer-2.0.0 lib/generators/kafka_consumer/consumer/templates/consumer.rb.erb