OfX-Kafka 3.3.0

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 Kafka 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!