Sha256: 72515da5cae5a6443423c1f137b6a3ddcc7eb26a1cfd5ab23c0a7d845fa874d5
Contents?: true
Size: 1003 Bytes
Versions: 22
Compression:
Stored size: 1003 Bytes
Contents
'<%= file_name %>':
name: <%%= ENV.fetch('ENV_VARIABLE_WITH_GROUP_NAME'){ '<%= group_name %>' } %><%%= ENV.fetch('CONSUMER_GROUP_SUFFIX'){ '' } %>
<%- if @items.empty? -%>
topics: []
<%- else -%>
topics:
<%- @items.each do |topic, item_name| -%>
<%- next if topic.blank? -%>
<%- inbox_item = item_name.presence || "YourModelName::InboxItem" -%>
<%- consumer_name = inbox_item.split('::').first.presence || "#{topic}_item" -%>
- name: "<%= topic %>"
consumer:
# Change the line below to the desired consumer
# if InboxConsumer doesn't suit your needs
klass: "Sbmt::KafkaConsumer::InboxConsumer"
init_attrs:
name: "<%= consumer_name.underscore.pluralize %>"
inbox_item: "<%= inbox_item %>"
# deserializer: # This deserializer is used by default
# klass: "Sbmt::KafkaConsumer::Serialization::NullDeserializer"
<%- end -%>
<%- end -%>
Version data entries
22 entries across 22 versions & 1 rubygems