👁 Image
Raycynix.Extensions.Messaging.Kafka 1.0.1

Raycynix.Extensions.Messaging.Kafka

Raycynix.Extensions.Messaging.Kafka contains the Kafka transport integration for Raycynix messaging.

What it contains

• AddKafka(...)
• KafkaMessagingConfiguration
• Kafka-backed IMessagePublisher
• Kafka producer setup through Confluent.Kafka
• message publishing to Kafka topics using MessageEnvelope<TMessage>.Destination

What it does not contain

• Kafka consumer hosted services
• consumer group processing pipeline
• schema registry integration
• outbox persistence
• retry topic orchestration

Usage

Example appsettings.json:

{
 "KafkaMessagingConfiguration": {
 "BootstrapServers": [
 "localhost:9092"
 ],
 "ClientId": "orders-service",
 "EnableIdempotence": true,
 "Acks": "all",
 "Consumer": {
 "Enabled": true,
 "Topics": [
 "orders.created"
 ]
 }
 }
}

Register the transport:

builder.Services.AddRaycynixMessaging(builder.Configuration)
 .AddKafka(builder.Configuration);

Publish to a Kafka topic:

public class OrderPublisher(
 IMessageEnvelopeFactory envelopeFactory,
 IMessagePublisher messagePublisher)
{
 public async Task PublishAsync(string orderId, CancellationToken cancellationToken)
 {
 var envelope = envelopeFactory.Create(
 new OrderCreatedMessage(orderId),
 destination: "orders.created",
 format: MessageFormat.Json);

 await messagePublisher.PublishAsync(envelope, cancellationToken);
 }
}

The envelope destination is used as the Kafka topic name, and the package publishes:

• serialized payload bytes
• message-id, correlation-id, causation-id
• contract/version headers from the base messaging layer