{"repo":"Kuper-Tech/sbmt-kafka_producer","free":true,"listed":false,"github":"https://github.com/Kuper-Tech/sbmt-kafka_producer","clone":"git clone https://github.com/Kuper-Tech/sbmt-kafka_producer.git","description":"Ruby gem for producing Kafka messages","language":"Ruby","stars":32,"topics":["gem","kafka","outbox","ruby"],"license":"MIT","category":"data-pipelines","readme_excerpt":"Sbmt-KafkaProducer This gem is used to produce Kafka messages. It is a wrapper over the waterdrop gem, and it is recommended for use as a transport with the sbmt-outbox gem. Installation Add this line to your app'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 a result, the config/kafka producer.yml file will be created. Producer class A producer class can be generated with the following command: As the result, a sync producer will be created. Outbox producer To generate an Outbox producer for use with Gem sbmt-Outbox, run the following command: Manual configuration The config/kafka producer.yml file is the main configuration for this gem. auth config section The gem supports 2 variants: plaintext (default) and SASL-plaintext SASL-plaintext: If you need to use another variant, use the low-level custom Kafka options kafka config: of config/kafka producer.yml . These options will overwrite the options in the auth section. Example of SASL SSL protocol auth via kafka config : kafka config section The servers key is required a","default_branch":null,"files":null,"tree":[],"storefront":"/r/Kuper-Tech","claimed":false,"request_supported":{"post":"https://gitbuyer.com/r/Kuper-Tech/sbmt-kafka_producer/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."}