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