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

Version Path
sbmt-kafka_consumer-3.4.1 lib/generators/kafka_consumer/consumer/USAGE
sbmt-kafka_consumer-3.4.0 lib/generators/kafka_consumer/consumer/USAGE
sbmt-kafka_consumer-3.3.2 lib/generators/kafka_consumer/consumer/USAGE
sbmt-kafka_consumer-3.3.1 lib/generators/kafka_consumer/consumer/USAGE
sbmt-kafka_consumer-3.3.0 lib/generators/kafka_consumer/consumer/USAGE
sbmt-kafka_consumer-3.2.2 lib/generators/kafka_consumer/consumer/USAGE
sbmt-kafka_consumer-3.2.1 lib/generators/kafka_consumer/consumer/USAGE
sbmt-kafka_consumer-3.2.0 lib/generators/kafka_consumer/consumer/USAGE
sbmt-kafka_consumer-3.1.0 lib/generators/kafka_consumer/consumer/USAGE
sbmt-kafka_consumer-2.8.0 lib/generators/kafka_consumer/consumer/USAGE
sbmt-kafka_consumer-3.0.0 lib/generators/kafka_consumer/consumer/USAGE
sbmt-kafka_consumer-2.7.1 lib/generators/kafka_consumer/consumer/USAGE
sbmt-kafka_consumer-2.7.0 lib/generators/kafka_consumer/consumer/USAGE
sbmt-kafka_consumer-2.6.1 lib/generators/kafka_consumer/consumer/USAGE
sbmt-kafka_consumer-2.6.0 lib/generators/kafka_consumer/consumer/USAGE
sbmt-kafka_consumer-2.5.0 lib/generators/kafka_consumer/consumer/USAGE
sbmt-kafka_consumer-2.4.1 lib/generators/kafka_consumer/consumer/USAGE
sbmt-kafka_consumer-2.4.0 lib/generators/kafka_consumer/consumer/USAGE
sbmt-kafka_consumer-2.3.1 lib/generators/kafka_consumer/consumer/USAGE
sbmt-kafka_consumer-2.3.0 lib/generators/kafka_consumer/consumer/USAGE