Sha256: 63947ae0270c36df464ffc9107b2e4fd5dea36d6ca1e807d4c2c01ed96d672af
Contents?: true
Size: 926 Bytes
Versions: 23
Compression:
Stored size: 926 Bytes
Contents
Description:
Stubs out a new non-inbox consumer. Pass the consumer name, either
CamelCased or under_scored.
Example:
bin/rails generate kafka_consumer:consumer Test
This will create:
app/consumers/test_consumer.rb
This will optionally insert:
'group_key':
name: <%= ENV.fetch('ENV_VARIABLE_WITH_GROUP_NAME'){ 'group.name' } %><%= ENV.fetch('ENV_VARIABLE_WITH_GROUP_SUFFIX'){ '' } %>
topics:
- name: 'topic.name'
consumer:
klass: "TestConsumer"
# init_attrs:
# skip_on_error: false # This is the default value
deserializer:
klass: "Sbmt::KafkaConsumer::Serialization::ProtobufDeserializer"
init_attrs:
message_decoder_klass: "YourMessageDecoderClassName"
# skip_decoding_error: false # This is the default value
Version data entries
23 entries across 23 versions & 1 rubygems