OfX-Kafka 3.1.12

OfX-Kafka

OfX-Kafka is an extension package for OfX that leverages Kafka for efficient data transportation. This package provides a high-performance, strongly-typed communication layer for OfX’s Attribute-based Data Mapping, enabling streamlined data retrieval across distributed systems.

Demo Project!

Introduction

Kafka-based Transport: Implements RabbitMq to handle data communication between services, providing a fast, secure, and scalable solution.

Installation

To install the OfX-Kafka package, use the following NuGet command:

dotnet add package OfX-Kafka

Or via the NuGet Package Manager:

Install-Package OfX-Kafka

How to Use

1. Register OfX-Kafka

Add OfX-Kafka to your service configuration during application startup:

builder.Services.AddOfX(cfg =>
{
    cfg.AddContractsContainNamespaces(typeof(SomeContractAssemblyMarker).Assembly);
    cfg.AddKafka(c => c.Host("localhost:9092"));
});

...

var app = builder.Build();
app.StartKafkaListeningAsync(); // When you want to create Kafka Listening
app.Run();

Note: OfX-Kafka uses topics that start with ofx-response-topic-[application.friendly.name]. Therefore, you should avoid using other topics. Additionally, OfX-Kafka automatically creates the topic ofx-request-topic-[ofx.attribute.metadata], so you should avoid creating a topic with the same name in your application.

That All, enjoy your moment!

| Package Name | Description | .NET Version | Document | |--------------------------------------------------------------|---------------------------------------------------------------------------------------------------------|--------------|------------------------------------------------------------------------------------------| | OfX | OfX core | 8.0, 9.0 | ReadMe | | OfX-EFCore | This is the OfX extension package using EntityFramework to fetch data | 8.0, 9.0 | ReadMe | | OfX-gRPC | OfX-gRPC is an extension package for OfX that leverages gRPC for efficient data transportation. | 8.0, 9.0 | ReadMe | | OfX-Nats | OfX-Nats is an extension package for OfX that leverages Nats for efficient data transportation. | 8.0, 9.0 | ReadMe | | OfX-RabbitMq | OfX-RabbitMq is an extension package for OfX that leverages RabbitMq for efficient data transportation. | 8.0, 9.0 | ReadMe | | OfX-Kafka | OfX-Kafka is an extension package for OfX that leverages Kafka for efficient data transportation. | 8.0, 9.0 | This Document |