{"repo":"glazkovalex/Rebus.Kafka","free":true,"listed":false,"github":"https://github.com/glazkovalex/Rebus.Kafka","clone":"git clone https://github.com/glazkovalex/Rebus.Kafka.git","description":"Apache Kafka transport for Rebus","language":"C#","stars":20,"topics":["kafka","rebus","transport-messages"],"license":"MIT","category":"data-pipelines","readme_excerpt":"Rebus.Kafka Provides a Apache Kafka transport implementation for Rebus. Getting started Rebus.Kafka: 1. Implement Getting started for Rebus 2. Add transport as UseKafka All parameters for the producer and the consumer can be specified in detail. See this example. It is possible to configures Rebus to use Apache Kafka to transport messages as a one-way client (i.e. will not be able to receive any messages). See this example. See examples and tests for other usage examples. This provider supports the following Rebus bus functions: Additional Apache Kafka transport. The tests use an confluentinc/cp-kafka container. Routing Pub sub messaging Process managers (sagas). See example. Workers and parallelism Automatic retries and error handling \"Transaction\" Headers Timeouts Many others are probably supported too, but I haven't checked. Additional features: When using the Rebus package.Service Provider, to avoid deadlock, events should be subscribed await bus.Subscribe () to only after the bus is started, but NOT in the \"onCreate\" rebus event! At the request of the transport users, the Rebus.Kafka transport automatically creates topics by default. However, I do not recommend using allow.auto.create.topics=true for production! To disable allow.auto.create.topics, pass your ConsumerConfig or ConsumerAndBehaviorConfig configuration to the transport with the AllowAutoCreateTopics = false parameter disabled. The Rebus.Kafka transport has a new overload with the ConsumerAndBehaviorConfig pa","default_branch":null,"files":null,"tree":[],"storefront":"/r/glazkovalex","claimed":false,"request_supported":{"post":"https://gitbuyer.com/r/glazkovalex/Rebus.Kafka/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."}