{"repo":"Kuper-Tech/sbmt-kafka_consumer","free":true,"listed":false,"github":"https://github.com/Kuper-Tech/sbmt-kafka_consumer","clone":"git clone https://github.com/Kuper-Tech/sbmt-kafka_consumer.git","description":"Ruby gem for consuming Kafka messages","language":"Ruby","stars":29,"topics":["gem","inbox","kafka","outbox","ruby"],"license":"MIT","category":"data-pipelines","readme_excerpt":"Sbmt-KafkaConsumer This gem is used to consume Kafka messages. It is a wrapper over the Karafka gem, and is recommended for use as a transport with the sbmt-outbox gem. Installation Add this line to your application's Gemfile: And then execute: Demo Learn how to use this gem and how it works with Ruby on Rails at here https://github.com/Kuper-Tech/outbox-example-apps Auto configuration We recommend going through the configuration and file creation process using the following Rails generators. Each generator can be run by using the --help option to learn more about the available arguments. Initial configuration If you plug the gem into your application for the first time, you can generate the initial configuration: As the result, the config/kafka consumer.yml file will be created. Consumer class A consumer class can be generated with the following command: Inbox consumer To generate an Inbox consumer for use with gem sbmt-outbox, run the following command: Regexp consumer To generate a regexp-topic consumer: Where: - GROUP KEY — YAML key for the consumer group (e.g. order ) - CONSUMER KLASS — consumer class name (e.g. MyApp::OrderConsumer ) - TOPIC REGEXP — topic regexp (e.g. 'my\\.app\\.order(\\.\\d+)?$' ) - --env-prefix (required) — prefix for the ENV PREFIX CONSUMER GROUP NAME and ENV PREFIX TOPIC REGEXP environment variables - --init-attrs key:value ... — optional consumer init attrs as key:value pairs; boolean values ( true / false ) are emitted unquoted - --deserializer-klas","default_branch":null,"files":null,"tree":[],"storefront":"/r/Kuper-Tech","claimed":false,"request_supported":{"post":"https://gitbuyer.com/r/Kuper-Tech/sbmt-kafka_consumer/request-supported","requests":0},"note":"indexed from public GitHub; nothing is for sale on this page. Clone it from GitHub. Paid listings live at /search."}