Raduz.KafkaClient.Client 4.0.0

| _ \ / \ | _ | | | |__ / | |/ /__ _ / | | ____ _ / | () ___ _ __ | | | |) | / _ \ | | | | | | | / / | ' // | |_| |/ / _ | | | | |/ _ \ ' | __| | _ < / ___ | || | || |/ / | . \ (| | | < (| | || | | / | | | | || _// __/ ___//()|__,|| ||__,|_|||___|| ||__|

How to use:

1. Add settings to your appsettings.json: KafkaClientConsumerConfig - inherits from https://docs.confluent.io/platform/current/clients/confluent-kafka-dotnet/_site/api/Confluent.Kafka.ConsumerConfig.html + MaxConsumeRetryCount count of retries (retry pattern)

   KafkaClientProducerConfig - inherits from https://docs.confluent.io/platform/current/clients/confluent-kafka-dotnet/_site/api/Confluent.Kafka.ProducerConfig.html + AllowCreateTopic - create topic, if there is non while publishing

   SchemaRegistryConfig https://docs.confluent.io/platform/current/clients/confluent-kafka-dotnet/_site/api/Confluent.SchemaRegistry.SchemaRegistryConfig.html

2. Register ConfigureKafkaConsumer and ConfigureKafkaPublisher to services container

   Publisher is used like:

   var publisher = app.Services.GetService<IKafkaPublisher>()!; // or some other way to obtain await publisher.PublishAsync("{TOPIC-NAME}", "{SOME-KEY}", {YOUR-AVRO-OBJECT}, cancellationToken);

   For Consumers create handlers for each topic like:

   public class YourRequest : KafkaConsumerHandler<{YOUR-AVRO-OBJECT}> { public YourRequest() : base("{TOPIC-NAME}") { } }

3. Implement Exception handlers

   For Publisher implement IPublisherExceptionHandler

   For Consumer implement IConsumerExceptionHandler

4. Implement consumer pipeline behaviour

   IConsumerPipelineBehaviour

5. Enjoy easily used package 😃

Issues or feature requests report here, please https://github.com/Rades98/Raduz.KafkaClient/issues